Chromium Code Reviews| Index: components/tracing/core/trace_ring_buffer.h |
| diff --git a/components/tracing/core/trace_ring_buffer.h b/components/tracing/core/trace_ring_buffer.h |
| index 4a86a8bbc4fc1b8d9c024e313e99c85cf128f939..d1147510bda1134faaa6bf268784cd3a5ae45661 100644 |
| --- a/components/tracing/core/trace_ring_buffer.h |
| +++ b/components/tracing/core/trace_ring_buffer.h |
| @@ -5,10 +5,11 @@ |
| #ifndef COMPONENTS_TRACING_CORE_TRACE_RING_BUFFER_H_ |
| #define COMPONENTS_TRACING_CORE_TRACE_RING_BUFFER_H_ |
| +#include <memory> |
| + |
| #include "base/atomicops.h" |
| #include "base/macros.h" |
| #include "base/synchronization/lock.h" |
| -#include "base/threading/thread.h" |
| #include "components/tracing/tracing_export.h" |
| namespace tracing { |
| @@ -39,14 +40,23 @@ class TRACING_EXPORT TraceRingBuffer { |
| return base::subtle::NoBarrier_Load(header()); |
| } |
| + void set_next_in_owner_list(Chunk* next) { next_in_owner_list_ = next; } |
| + Chunk* next_in_owner_list() const { return next_in_owner_list_; } |
| + |
| + // Owner is a flag matching the id of the TraceBufferWriter, 0 if not owned. |
| // Accesses to |owner_| must happen under the buffer |lock_|. |
| - bool is_owned() const { return owner_ != base::kInvalidThreadId; } |
| - void clear_owner() { owner_ = base::kInvalidThreadId; } |
| - void set_owner(base::PlatformThreadId tid) { owner_ = tid; } |
| + bool is_owned() const { return owner_ != 0; } |
| + uint32_t owner() const { return owner_; } |
| + void clear_owner() { owner_ = 0; } |
| + void set_owner(uint32_t owner) { owner_ = owner; } |
|
alph
2016/07/30 07:41:14
DCHECK(owner != 0)
Primiano Tucci (use gerrit)
2016/08/04 15:26:55
Done.
|
| private: |
| uint8_t* begin_; |
| - base::PlatformThreadId owner_; // kInvalidThreadId -> Chunk is not owned. |
| + uint32_t owner_; // 0 -> Chunk is not owned. |
|
alph
2016/07/30 07:41:15
static const uint32_t kNoOwner = 0; ?
Primiano Tucci (use gerrit)
2016/08/04 15:26:55
Done.
|
| + |
| + // When a chunk is owned, this is the next pointer to keep track of all |
| + // owned chunks in a singly linked list. |
| + Chunk* next_in_owner_list_; |
| DISALLOW_COPY_AND_ASSIGN(Chunk); |
| }; |
| @@ -54,13 +64,23 @@ class TRACING_EXPORT TraceRingBuffer { |
| TraceRingBuffer(uint8_t* begin, size_t size); |
| ~TraceRingBuffer(); |
| - Chunk* TakeChunk(); |
| - void ReturnChunk(Chunk* chunk, uint32_t used_size); |
| + Chunk* TakeChunk(uint32_t writer_id); |
| + void ReturnChunk(Chunk* chunk); |
| + |
| + size_t num_chunks() const { return num_chunks_; } |
| + |
| + // Returns the number of chunks taken and not returned, without counting any |
| + // bankrupcy chunk obtained when the ring buffer was full. |
| + size_t GetNumChunksTaken() const; |
| + |
| + const Chunk* chunks_for_testing() const { return chunks_.get(); } |
| + bool IsBankrupcyChunkForTesting(const Chunk*) const; |
| private: |
| - base::Lock lock_; |
| + mutable base::Lock lock_; |
| std::unique_ptr<Chunk[]> chunks_; |
| const size_t num_chunks_; |
| + size_t num_chunks_taken_; |
| size_t current_chunk_idx_; |
| // An emergency chunk used in the rare case in which all chunks are in flight. |