OLD | NEW |
---|---|
(Empty) | |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "components/tracing/core/scattered_stream_writer.h" | |
6 | |
7 #include <string.h> | |
8 | |
9 #include "base/logging.h" | |
10 | |
11 namespace tracing { | |
12 namespace v2 { | |
13 | |
14 ScatteredStreamWriter::ScatteredStreamWriter(Delegate* delegate) | |
15 : delegate_(delegate), | |
16 cur_range_({nullptr, nullptr}), | |
17 write_ptr_(nullptr) {} | |
18 | |
19 ScatteredStreamWriter::~ScatteredStreamWriter() {} | |
20 | |
21 void ScatteredStreamWriter::Reset( | |
22 ScatteredStreamWriter::ContiguousMemoryRange range) { | |
23 cur_range_ = range; | |
24 write_ptr_ = range.begin; | |
25 DCHECK_LT(write_ptr_, cur_range_.end); | |
26 } | |
27 | |
28 void ScatteredStreamWriter::Expand() { | |
oystein (OOO til 10th of July)
2016/06/15 08:35:09
Maybe Extend() instead? Or Advance() to signal tha
Primiano Tucci (use gerrit)
2016/06/29 09:32:02
Right. Expand is the worst word given that nothing
| |
29 Reset(delegate_->GetNewContiguousMemoryBuffer()); | |
30 } | |
31 | |
32 void ScatteredStreamWriter::WriteByte(uint8_t value) { | |
33 if (write_ptr_ >= cur_range_.end) | |
34 Expand(); | |
35 *write_ptr_++ = value; | |
36 } | |
37 | |
38 void ScatteredStreamWriter::WriteBytes(const uint8_t* src, size_t size) { | |
39 uint8_t* const end = const_cast<uint8_t*>(write_ptr_) + size; | |
40 if (end <= cur_range_.end) { | |
41 // Fast-path, the buffer fits into the current contiguous range. | |
42 // TODO(primiano): there is some potential perf optimization here, this is | |
43 // a tracing hot path. Looks like this is faster than memcpy for small | |
oystein (OOO til 10th of July)
2016/06/15 08:35:09
Huh interesting (and surprising). Any ideas what
alph
2016/06/15 10:08:22
Compiler should be able to handle this optimizatio
Primiano Tucci (use gerrit)
2016/06/29 09:32:02
Ok let's do something, I want to look with a fresh
| |
44 // sizes. Should probably split this into WriteFewBytes() (for varints) | |
45 // and WriteManyBytes() (for strings). | |
46 for (size_t i = 0; i < size; ++i) | |
47 write_ptr_[i] = src[i]; | |
48 write_ptr_ = end; | |
49 return; | |
50 } else { | |
51 // Slow path, scatter the writes. | |
52 size_t bytes_left = size; | |
53 while (bytes_left > 0) { | |
54 if (write_ptr_ >= cur_range_.end) | |
55 Expand(); | |
56 const size_t burst_size = std::min(bytes_available(), bytes_left); | |
57 WriteBytes(src, burst_size); | |
58 bytes_left -= burst_size; | |
59 src += burst_size; | |
60 } | |
61 } | |
62 } | |
63 | |
64 // TODO(primiano): perf optimization: I suspect that at the end this will always | |
65 // be called with size == 4, in which case we might jsut hardcode it. Ditto for | |
66 // WriteReservedBytes() below. | |
67 ScatteredStreamWriter::ContiguousMemoryRange | |
68 ScatteredStreamWriter::ReserveBytes(size_t size) { | |
69 if (write_ptr_ + size > cur_range_.end) | |
70 Expand(); | |
71 uint8_t* begin = write_ptr_; | |
72 write_ptr_ += size; | |
alph
2016/06/15 10:08:22
Some bytes may be left at the end of the previous
Primiano Tucci (use gerrit)
2016/06/29 09:32:02
Yes, so, are you talking about the fact that the l
| |
73 #ifndef NDEBUG | |
74 memset(begin, '\x42', size); | |
75 #endif | |
76 return {begin, begin + size}; | |
77 } | |
78 | |
79 void ScatteredStreamWriter::WriteReservedBytes( | |
80 const ScatteredStreamWriter::ContiguousMemoryRange& reserved_range, | |
81 const uint8_t* src) { | |
82 DCHECK_EQ(4, reserved_range.end - reserved_range.begin); | |
83 for(uint8_t* dst = reserved_range.begin; dst < reserved_range.end;) | |
84 *dst++ = *src++; | |
85 } | |
86 | |
87 } // namespace v2 | |
88 } // namespace tracing | |
OLD | NEW |