OLD | NEW |
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 |
OLD | NEW |