| /external/deqp/framework/delibs/decpp/ |
| D | deRingBuffer.hpp | 35 class RingBuffer class
38 RingBuffer (int size);
39 ~RingBuffer (void);
70 RingBuffer<T>::RingBuffer (int size) in RingBuffer() function in de::RingBuffer
81 RingBuffer<T>::~RingBuffer () in ~RingBuffer()
87 void RingBuffer<T>::clear (void) in clear()
95 void RingBuffer<T>::resize (int newSize) in resize()
122 inline void RingBuffer<T>::pushFront (const T& elem) in pushFront()
131 void RingBuffer<T>::pushFront (const T* elemBuf, int count) in pushFront()
141 inline T RingBuffer<T>::popBack () in popBack()
[all …]
|
| /external/perfetto/src/base/ |
| D | metatrace_unittest.cc | 54 ASSERT_EQ(m::RingBuffer::GetSizeForTesting(), 0u); in TEST_F()
59 ASSERT_EQ(m::RingBuffer::GetSizeForTesting(), 0u); in TEST_F()
81 auto it = m::RingBuffer::GetReadIterator(); in TEST_F()
95 auto it = m::RingBuffer::GetReadIterator(); in TEST_F()
114 auto* record = m::RingBuffer::AppendNewRecord(); in TEST_F()
121 auto it = m::RingBuffer::GetReadIterator(); in TEST_F()
143 for (size_t i = 0; i < m::RingBuffer::kCapacity; i++) in TEST_F()
145 ASSERT_EQ(m::RingBuffer::GetSizeForTesting(), m::RingBuffer::kCapacity); in TEST_F()
146 ASSERT_FALSE(m::RingBuffer::has_overruns()); in TEST_F()
151 ASSERT_TRUE(m::RingBuffer::has_overruns()); in TEST_F()
[all …]
|
| D | metatrace.cc | 32 constexpr size_t RingBuffer::kCapacity;
33 std::array<Record, RingBuffer::kCapacity> RingBuffer::records_;
34 std::atomic<bool> RingBuffer::read_task_queued_;
35 std::atomic<uint64_t> RingBuffer::wr_index_;
36 std::atomic<uint64_t> RingBuffer::rd_index_;
37 std::atomic<bool> RingBuffer::has_overruns_;
38 Record RingBuffer::bankruptcy_record_;
71 RingBuffer::Reset(); in Enable()
87 void RingBuffer::Reset() { in Reset()
98 Record* RingBuffer::AppendNewRecord() { in AppendNewRecord()
[all …]
|
| /external/webrtc/common_audio/ |
| D | ring_buffer.h | 27 typedef struct RingBuffer { struct
34 } RingBuffer; argument
37 RingBuffer* WebRtc_CreateBuffer(size_t element_count, size_t element_size);
38 void WebRtc_InitBuffer(RingBuffer* handle);
52 size_t WebRtc_ReadBuffer(RingBuffer* handle,
58 size_t WebRtc_WriteBuffer(RingBuffer* handle,
67 int WebRtc_MoveReadPtr(RingBuffer* handle, int element_count);
70 size_t WebRtc_available_read(const RingBuffer* handle);
73 size_t WebRtc_available_write(const RingBuffer* handle);
|
| D | ring_buffer.c | 25 static size_t GetBufferReadRegions(RingBuffer* buf, in GetBufferReadRegions()
54 RingBuffer* WebRtc_CreateBuffer(size_t element_count, size_t element_size) { in WebRtc_CreateBuffer()
55 RingBuffer* self = NULL; in WebRtc_CreateBuffer()
60 self = malloc(sizeof(RingBuffer)); in WebRtc_CreateBuffer()
79 void WebRtc_InitBuffer(RingBuffer* self) { in WebRtc_InitBuffer()
89 RingBuffer* self = (RingBuffer*)handle; in WebRtc_FreeBuffer()
98 size_t WebRtc_ReadBuffer(RingBuffer* self, in WebRtc_ReadBuffer()
143 size_t WebRtc_WriteBuffer(RingBuffer* self, in WebRtc_WriteBuffer()
177 int WebRtc_MoveReadPtr(RingBuffer* self, int element_count) { in WebRtc_MoveReadPtr()
214 size_t WebRtc_available_read(const RingBuffer* self) { in WebRtc_available_read()
[all …]
|
| D | ring_buffer_unittest.cc | 26 typedef std::unique_ptr<RingBuffer, FreeBufferDeleter> scoped_ring_buffer;
145 RingBuffer* buffer = WebRtc_CreateBuffer(1, 1); in TEST()
|
| /external/webrtc/modules/audio_processing/agc2/rnn_vad/ |
| D | ring_buffer.h | 25 class RingBuffer {
32 RingBuffer() : tail_(0) {} in RingBuffer() function
33 RingBuffer(const RingBuffer&) = delete;
34 RingBuffer& operator=(const RingBuffer&) = delete;
35 ~RingBuffer() = default;
|
| D | ring_buffer_unittest.cc | 39 RingBuffer<T, S, N> ring_buf; in TestRingBuffer()
73 RingBuffer<int, s, n> ring_buf; in TEST()
|
| /external/llvm-project/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_ring_buffer_test.cpp | 29 TEST(RingBuffer, Construct) { in TEST() argument
30 RingBuffer<int64_t> *RBlong = RingBuffer<int64_t>::New(20); in TEST()
36 RingBuffer<T> *RB; in TestRB()
39 RB = RingBuffer<T>::New(Size); in TestRB()
44 RB = RingBuffer<T>::New(4); in TestRB()
69 TEST(RingBuffer, int64) { in TEST() argument
73 TEST(RingBuffer, LargeStruct) { in TEST() argument
|
| /external/llvm-project/compiler-rt/lib/sanitizer_common/ |
| D | sanitizer_ring_buffer.h | 22 class RingBuffer {
25 static RingBuffer *New(uptr Size) { in New()
27 RingBuffer *RB = reinterpret_cast<RingBuffer*>(Ptr); in New()
64 RingBuffer() {} in RingBuffer() function
65 ~RingBuffer() {} in ~RingBuffer()
66 RingBuffer(const RingBuffer&) = delete;
|
| /external/perfetto/src/trace_processor/ |
| D | tp_metatrace.h | 91 class RingBuffer {
95 RingBuffer();
96 ~RingBuffer() = default;
115 static RingBuffer* GetInstance() { in GetInstance()
116 static RingBuffer* rb = new RingBuffer(); in GetInstance()
145 if (RingBuffer::GetInstance()->HasOverwritten(record_idx_)) in ~ScopedEvent()
166 RingBuffer::GetInstance()->AppendRecord(event_id);
|
| D | tp_metatrace.cc | 33 RingBuffer::GetInstance()->ReadAll(fn); in DisableAndReadBuffer()
36 RingBuffer::RingBuffer() { in RingBuffer() function in perfetto::trace_processor::metatrace::RingBuffer
41 void RingBuffer::ReadAll(std::function<void(Record*)> fn) { in ReadAll()
|
| /external/libchrome/base/containers/ |
| D | ring_buffer.h | 25 class RingBuffer {
27 RingBuffer() : current_index_(0) {} in RingBuffer() function
88 Iterator(const RingBuffer<T, kSize>& buffer, size_t index) in Iterator()
91 const RingBuffer<T, kSize>& buffer_;
95 friend class RingBuffer<T, kSize>; variable
128 DISALLOW_COPY_AND_ASSIGN(RingBuffer);
|
| /external/brotli/c/enc/ |
| D | ringbuffer.h | 32 typedef struct RingBuffer { struct
47 } RingBuffer; argument
49 static BROTLI_INLINE void RingBufferInit(RingBuffer* rb) { in RingBufferInit()
57 const BrotliEncoderParams* params, RingBuffer* rb) { in RingBufferSetup()
66 static BROTLI_INLINE void RingBufferFree(MemoryManager* m, RingBuffer* rb) { in RingBufferFree()
73 MemoryManager* m, const uint32_t buflen, RingBuffer* rb) { in RingBufferInitBuffer()
94 const uint8_t* bytes, size_t n, RingBuffer* rb) { in RingBufferWriteTail()
106 MemoryManager* m, const uint8_t* bytes, size_t n, RingBuffer* rb) { in RingBufferWrite()
|
| /external/perfetto/include/perfetto/ext/base/ |
| D | metatrace.h | 151 class RingBuffer {
171 PERFETTO_DCHECK(cur_ >= RingBuffer::rd_index_); in ~ReadIterator()
172 PERFETTO_DCHECK(cur_ <= RingBuffer::wr_index_); in ~ReadIterator()
173 RingBuffer::rd_index_.store(cur_, std::memory_order_release); in ~ReadIterator()
177 const Record* operator->() const { return RingBuffer::At(cur_); }
201 friend class RingBuffer;
223 PERFETTO_DCHECK(RingBuffer::IsOnValidTaskRunner()); in GetReadIterator()
266 Record* record = RingBuffer::AppendNewRecord(); in TraceCounter()
281 record_ = RingBuffer::AppendNewRecord(); in ScopedEvent()
|
| /external/scudo/standalone/fuzz/ |
| D | get_error_info_fuzzer.cpp | 49 std::vector<char> RingBuffer(AllocatorT::getRingBufferSize(), 0); in LLVMFuzzerTestOneInput() local
50 for (size_t i = 0; i < RingBufferBytes.length() && i < RingBuffer.size(); in LLVMFuzzerTestOneInput()
52 RingBuffer[i] = RingBufferBytes[i]; in LLVMFuzzerTestOneInput()
57 RegionInfo.data(), RingBuffer.data(), Memory, in LLVMFuzzerTestOneInput()
|
| /external/mesa3d/src/gallium/drivers/swr/rasterizer/core/ |
| D | ringbuffer.h | 33 class RingBuffer
36 RingBuffer() : mpRingBuffer(nullptr), mNumEntries(0), mRingHead(0), mRingTail(0) {} in RingBuffer() function
38 ~RingBuffer() { Destroy(); } in ~RingBuffer()
|
| /external/opencensus-java/impl/src/main/java/io/opencensus/impl/internal/ |
| D | DisruptorEventQueue.java | 21 import com.lmax.disruptor.RingBuffer;
106 private final RingBuffer<DisruptorEvent> ringBuffer;
113 RingBuffer<DisruptorEvent> ringBuffer, in DisruptorEventQueue()
134 final RingBuffer<DisruptorEvent> ringBuffer = disruptor.getRingBuffer(); in create()
|
| /external/pigweed/pw_trace_tokenized/ |
| D | trace_buffer.cc | 66 pw::ring_buffer::PrefixedEntryRingBuffer& RingBuffer() { in RingBuffer() function in pw::trace::__anon76b02f780111::TraceBuffer
84 void ClearBuffer() { trace_buffer_instance.RingBuffer().Clear(); } in ClearBuffer()
87 return &trace_buffer_instance.RingBuffer(); in GetBuffer()
|
| /external/crosvm/devices/src/usb/xhci/ |
| D | ring_buffer.rs | 39 pub struct RingBuffer { struct
48 impl Display for RingBuffer { argument
55 impl RingBuffer { implementation
58 RingBuffer { in new()
158 let mut transfer_ring = RingBuffer::new(String::new(), gm.clone()); in ring_test_dequeue()
237 let mut transfer_ring = RingBuffer::new(String::new(), gm.clone()); in transfer_ring_test_dequeue_failure()
272 let mut transfer_ring = RingBuffer::new(String::new(), gm.clone()); in ring_test_toggle_cycle()
|
| D | ring_buffer_controller.rs | 15 use super::ring_buffer::RingBuffer;
77 ring_buffer: Mutex<RingBuffer>,
105 ring_buffer: Mutex::new(RingBuffer::new(name, mem)), in new_with_handler()
121 fn lock_ring_buffer(&self) -> MutexGuard<RingBuffer> { in lock_ring_buffer() argument
|
| /external/webrtc/modules/audio_coding/codecs/opus/test/ |
| D | audio_ring_buffer.h | 18 struct RingBuffer;
52 std::vector<RingBuffer*> buffers_;
|
| /external/webrtc/modules/audio_processing/aecm/ |
| D | aecm_core.h | 46 RingBuffer* farFrameBuf;
47 RingBuffer* nearNoisyFrameBuf;
48 RingBuffer* nearCleanFrameBuf;
49 RingBuffer* outFrameBuf;
|
| /external/perfetto/src/tracing/core/ |
| D | metatrace_writer.cc | 73 for (auto it = metatrace::RingBuffer::GetReadIterator(); it; ++it) { in WriteAllAvailableEvents()
93 if (metatrace::RingBuffer::has_overruns()) in WriteAllAvailableEvents()
|
| /external/deqp/executor/ |
| D | xeContainerFormatParser.hpp | 111 de::RingBuffer<deUint8> m_buf;
|