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

Unified Diff: components/tracing/core/trace_ring_buffer.h

Issue 2197563002: tracing v2: minor refactoring to TraceRingBuffer test helpers (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: 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 side-by-side diff with in-line comments
Download patch
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.

Powered by Google App Engine
This is Rietveld 408576698