Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(5)

Side by Side Diff: components/tracing/core/scattered_stream_writer_unittest.cc

Issue 2138903002: tracing v2: refactor fake_scattered_buffer class for tests (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: petr review Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « components/tracing/BUILD.gn ('k') | components/tracing/test/fake_scattered_buffer.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "components/tracing/core/scattered_stream_writer.h" 5 #include "components/tracing/core/scattered_stream_writer.h"
6 6
7 #include <string.h> 7 #include <string.h>
8 8
9 #include <memory> 9 #include <memory>
10 #include <vector>
11 10
12 #include "base/strings/string_number_conversions.h" 11 #include "components/tracing/test/fake_scattered_buffer.h"
13 #include "testing/gtest/include/gtest/gtest.h" 12 #include "testing/gtest/include/gtest/gtest.h"
14 13
15 namespace tracing { 14 namespace tracing {
16 namespace v2 { 15 namespace v2 {
17 namespace { 16 namespace {
18 17
19 class MockDelegate : public ScatteredStreamWriter::Delegate { 18 const size_t kChunkSize = 8;
20 public:
21 static const size_t kChunkSize = 8;
22
23 ContiguousMemoryRange GetNewBuffer() override {
24 std::unique_ptr<uint8_t[]> chunk(new uint8_t[kChunkSize]);
25 uint8_t* begin = chunk.get();
26 memset(begin, 0, kChunkSize);
27 chunks.push_back(std::move(chunk));
28 return {begin, begin + kChunkSize};
29 }
30
31 std::string GetChunkAsString(int chunk_index) {
32 return base::HexEncode(chunks[chunk_index].get(), kChunkSize);
33 }
34
35 std::vector<std::unique_ptr<uint8_t[]>> chunks;
36 };
37 19
38 TEST(ScatteredStreamWriterTest, ScatteredWrites) { 20 TEST(ScatteredStreamWriterTest, ScatteredWrites) {
39 MockDelegate delegate; 21 FakeScatteredBuffer delegate(kChunkSize);
40 ScatteredStreamWriter ssw(&delegate); 22 ScatteredStreamWriter ssw(&delegate);
41 23
42 const uint8_t kOneByteBuf[] = {0x40}; 24 const uint8_t kOneByteBuf[] = {0x40};
43 const uint8_t kThreeByteBuf[] = {0x50, 0x51, 0x52}; 25 const uint8_t kThreeByteBuf[] = {0x50, 0x51, 0x52};
44 const uint8_t kFourByteBuf[] = {0x60, 0x61, 0x62, 0x63}; 26 const uint8_t kFourByteBuf[] = {0x60, 0x61, 0x62, 0x63};
45 uint8_t kTwentyByteBuf[20]; 27 uint8_t kTwentyByteBuf[20];
46 for (uint8_t i = 0; i < sizeof(kTwentyByteBuf); ++i) 28 for (uint8_t i = 0; i < sizeof(kTwentyByteBuf); ++i)
47 kTwentyByteBuf[i] = 0xA0 + i; 29 kTwentyByteBuf[i] = 0xA0 + i;
48 30
49 // Writing up to the chunk size should cause only the initial extension. 31 // Writing up to the chunk size should cause only the initial extension.
50 for (uint8_t i = 0; i < MockDelegate::kChunkSize; ++i) { 32 for (uint8_t i = 0; i < kChunkSize; ++i) {
51 ssw.WriteByte(i); 33 ssw.WriteByte(i);
52 EXPECT_EQ(MockDelegate::kChunkSize - i - 1, ssw.bytes_available()); 34 EXPECT_EQ(kChunkSize - i - 1, ssw.bytes_available());
53 } 35 }
54 EXPECT_EQ(1u, delegate.chunks.size()); 36 EXPECT_EQ(1u, delegate.chunks().size());
55 EXPECT_EQ(0u, ssw.bytes_available()); 37 EXPECT_EQ(0u, ssw.bytes_available());
56 38
57 // This extra write will cause the first extension. 39 // This extra write will cause the first extension.
58 ssw.WriteBytes(kOneByteBuf, sizeof(kOneByteBuf)); 40 ssw.WriteBytes(kOneByteBuf, sizeof(kOneByteBuf));
59 EXPECT_EQ(2u, delegate.chunks.size()); 41 EXPECT_EQ(2u, delegate.chunks().size());
60 EXPECT_EQ(7u, ssw.bytes_available()); 42 EXPECT_EQ(7u, ssw.bytes_available());
61 43
62 // This starts at offset 1, to make sure we don't hardcode any assumption 44 // This starts at offset 1, to make sure we don't hardcode any assumption
63 // about alignment. 45 // about alignment.
64 ContiguousMemoryRange reserved_range_1 = ssw.ReserveBytes(4); 46 ContiguousMemoryRange reserved_range_1 = ssw.ReserveBytes(4);
65 EXPECT_EQ(2u, delegate.chunks.size()); 47 EXPECT_EQ(2u, delegate.chunks().size());
66 EXPECT_EQ(3u, ssw.bytes_available()); 48 EXPECT_EQ(3u, ssw.bytes_available());
67 49
68 ssw.WriteByte(0xFF); 50 ssw.WriteByte(0xFF);
69 ssw.WriteBytes(kThreeByteBuf, sizeof(kThreeByteBuf)); 51 ssw.WriteBytes(kThreeByteBuf, sizeof(kThreeByteBuf));
70 EXPECT_EQ(3u, delegate.chunks.size()); 52 EXPECT_EQ(3u, delegate.chunks().size());
71 EXPECT_EQ(7u, ssw.bytes_available()); 53 EXPECT_EQ(7u, ssw.bytes_available());
72 54
73 ContiguousMemoryRange reserved_range_2 = ssw.ReserveBytes(4); 55 ContiguousMemoryRange reserved_range_2 = ssw.ReserveBytes(4);
74 ssw.WriteBytes(kTwentyByteBuf, sizeof(kTwentyByteBuf)); 56 ssw.WriteBytes(kTwentyByteBuf, sizeof(kTwentyByteBuf));
75 EXPECT_EQ(6u, delegate.chunks.size()); 57 EXPECT_EQ(6u, delegate.chunks().size());
76 EXPECT_EQ(7u, ssw.bytes_available()); 58 EXPECT_EQ(7u, ssw.bytes_available());
77 59
78 // Writing reserved bytes should not change the bytes_available(). 60 // Writing reserved bytes should not change the bytes_available().
79 memcpy(reserved_range_1.begin, kFourByteBuf, sizeof(kFourByteBuf)); 61 memcpy(reserved_range_1.begin, kFourByteBuf, sizeof(kFourByteBuf));
80 memcpy(reserved_range_2.begin, kFourByteBuf, sizeof(kFourByteBuf)); 62 memcpy(reserved_range_2.begin, kFourByteBuf, sizeof(kFourByteBuf));
81 EXPECT_EQ(6u, delegate.chunks.size()); 63 EXPECT_EQ(6u, delegate.chunks().size());
82 EXPECT_EQ(7u, ssw.bytes_available()); 64 EXPECT_EQ(7u, ssw.bytes_available());
83 65
84 // Check that reserving more bytes than what left creates a brand new chunk 66 // Check that reserving more bytes than what left creates a brand new chunk
85 // even if the previous one is not exhausted 67 // even if the previous one is not exhausted
86 for (uint8_t i = 0; i < 5; ++i) 68 for (uint8_t i = 0; i < 5; ++i)
87 ssw.WriteByte(0xFF); 69 ssw.WriteByte(0xFF);
88 memcpy(ssw.ReserveBytes(4).begin, kFourByteBuf, sizeof(kFourByteBuf)); 70 memcpy(ssw.ReserveBytes(4).begin, kFourByteBuf, sizeof(kFourByteBuf));
89 EXPECT_EQ(7u, delegate.chunks.size()); 71 EXPECT_EQ(7u, delegate.chunks().size());
90 EXPECT_EQ(4u, ssw.bytes_available()); 72 EXPECT_EQ(4u, ssw.bytes_available());
91 73
92 EXPECT_EQ("0001020304050607", delegate.GetChunkAsString(0)); 74 EXPECT_EQ("0001020304050607", delegate.GetChunkAsString(0));
93 EXPECT_EQ("4060616263FF5051", delegate.GetChunkAsString(1)); 75 EXPECT_EQ("4060616263FF5051", delegate.GetChunkAsString(1));
94 EXPECT_EQ("5260616263A0A1A2", delegate.GetChunkAsString(2)); 76 EXPECT_EQ("5260616263A0A1A2", delegate.GetChunkAsString(2));
95 EXPECT_EQ("A3A4A5A6A7A8A9AA", delegate.GetChunkAsString(3)); 77 EXPECT_EQ("A3A4A5A6A7A8A9AA", delegate.GetChunkAsString(3));
96 EXPECT_EQ("ABACADAEAFB0B1B2", delegate.GetChunkAsString(4)); 78 EXPECT_EQ("ABACADAEAFB0B1B2", delegate.GetChunkAsString(4));
97 EXPECT_EQ("B3FFFFFFFFFF0000", delegate.GetChunkAsString(5)); 79 EXPECT_EQ("B3FFFFFFFFFF0000", delegate.GetChunkAsString(5));
98 EXPECT_EQ("6061626300000000", delegate.GetChunkAsString(6)); 80 EXPECT_EQ("6061626300000000", delegate.GetChunkAsString(6));
99 81
100 // Finally reset the writer to a new buffer. 82 // Finally reset the writer to a new buffer.
101 uint8_t other_buffer[8] = {0}; 83 uint8_t other_buffer[8] = {0};
102 ssw.Reset({other_buffer, other_buffer + sizeof(other_buffer)}); 84 ssw.Reset({other_buffer, other_buffer + sizeof(other_buffer)});
103 EXPECT_EQ(other_buffer, ssw.write_ptr()); 85 EXPECT_EQ(other_buffer, ssw.write_ptr());
104 ssw.WriteByte(1); 86 ssw.WriteByte(1);
105 ssw.WriteBytes(kThreeByteBuf, sizeof(kThreeByteBuf)); 87 ssw.WriteBytes(kThreeByteBuf, sizeof(kThreeByteBuf));
106 EXPECT_EQ(1u, other_buffer[0]); 88 EXPECT_EQ(1u, other_buffer[0]);
107 EXPECT_EQ(0x52u, other_buffer[3]); 89 EXPECT_EQ(0x52u, other_buffer[3]);
108 } 90 }
109 91
110 } // namespace 92 } // namespace
111 } // namespace v2 93 } // namespace v2
112 } // namespace tracing 94 } // namespace tracing
OLDNEW
« no previous file with comments | « components/tracing/BUILD.gn ('k') | components/tracing/test/fake_scattered_buffer.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698