Home
last modified time | relevance | path

Searched refs:BufferQueue (Results 1 – 22 of 22) sorted by relevance

/external/llvm-project/compiler-rt/lib/xray/tests/unit/
Dbuffer_queue_test.cpp30 BufferQueue Buffers(kSize, 1, Success); in TEST()
36 BufferQueue Buffers(kSize, 1, Success); in TEST()
38 BufferQueue::Buffer Buf; in TEST()
39 ASSERT_EQ(Buffers.getBuffer(Buf), BufferQueue::ErrorCode::Ok); in TEST()
41 ASSERT_EQ(Buffers.releaseBuffer(Buf), BufferQueue::ErrorCode::Ok); in TEST()
47 BufferQueue Buffers(kSize, 1, Success); in TEST()
49 BufferQueue::Buffer Buf0; in TEST()
50 EXPECT_EQ(Buffers.getBuffer(Buf0), BufferQueue::ErrorCode::Ok); in TEST()
51 BufferQueue::Buffer Buf1; in TEST()
52 EXPECT_EQ(BufferQueue::ErrorCode::NotEnoughMemory, Buffers.getBuffer(Buf1)); in TEST()
[all …]
Dfdr_log_writer_test.cpp41 BufferQueue Buffers(kSize, 1, Success); in TEST()
42 BufferQueue::Buffer B; in TEST()
43 ASSERT_EQ(Buffers.getBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
59 ASSERT_EQ(Buffers.releaseBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
61 ASSERT_EQ(Buffers.finalize(), BufferQueue::ErrorCode::Ok); in TEST()
79 BufferQueue Buffers(kSize, 1, Success); in TEST()
80 BufferQueue::Buffer B; in TEST()
81 ASSERT_EQ(Buffers.getBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
102 ASSERT_EQ(Buffers.releaseBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
106 ASSERT_EQ(Buffers.getBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
[all …]
Dfdr_controller_test.cpp46 BufferQueue::Buffer B{};
47 std::unique_ptr<BufferQueue> BQ;
54 BQ = std::make_unique<BufferQueue>(4096, 1, Success); in SetUp()
56 ASSERT_EQ(BQ->getBuffer(B), BufferQueue::ErrorCode::Ok); in SetUp()
66 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
90 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
110 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
125 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
149 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
173 ASSERT_EQ(BQ->finalize(), BufferQueue::ErrorCode::Ok); in TEST_F()
[all …]
Dallocator_test.cpp61 BufferQueue BQ(GetPageSizeCached(), 10, Success); in TEST()
63 BufferQueue::Buffer B; in TEST()
64 ASSERT_EQ(BQ.getBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
77 ASSERT_EQ(BQ.releaseBuffer(B), BufferQueue::ErrorCode::Ok); in TEST()
Dprofile_collector_test.cpp113 BufferQueue BQ(profilingFlags()->per_thread_allocator_max, in TEST()
117 ASSERT_EQ(BQ.getBuffer(Buffers.NodeBuffer), BufferQueue::ErrorCode::Ok); in TEST()
118 ASSERT_EQ(BQ.getBuffer(Buffers.RootsBuffer), BufferQueue::ErrorCode::Ok); in TEST()
120 BufferQueue::ErrorCode::Ok); in TEST()
121 ASSERT_EQ(BQ.getBuffer(Buffers.NodeIdPairBuffer), BufferQueue::ErrorCode::Ok); in TEST()
184 static BufferQueue BQ(profilingFlags()->per_thread_allocator_max, in threadProcessing()
Dtest_helpers.cpp70 std::string serialize(BufferQueue &Buffers, int32_t Version) { in serialize()
83 Buffers.apply([&](const BufferQueue::Buffer &B) { in serialize()
Dtest_helpers.h60 std::string serialize(BufferQueue &Buffers, int32_t Version);
/external/llvm-project/compiler-rt/lib/xray/
Dxray_buffer_queue.cpp30 BufferQueue::ControlBlock *allocControlBlock(size_t Size, size_t Count) { in allocControlBlock()
32 allocateBuffer((sizeof(BufferQueue::ControlBlock) - 1) + (Size * Count)); in allocControlBlock()
34 : reinterpret_cast<BufferQueue::ControlBlock *>(B); in allocControlBlock()
37 void deallocControlBlock(BufferQueue::ControlBlock *C, size_t Size, in deallocControlBlock()
40 (sizeof(BufferQueue::ControlBlock) - 1) + (Size * Count)); in deallocControlBlock()
43 void decRefCount(BufferQueue::ControlBlock *C, size_t Size, size_t Count) { in decRefCount()
50 void incRefCount(BufferQueue::ControlBlock *C) { in incRefCount()
70 BufferQueue::ErrorCode BufferQueue::init(size_t BS, size_t BC) { in init()
74 return BufferQueue::ErrorCode::AlreadyInitialized; in init()
84 return BufferQueue::ErrorCode::NotEnoughMemory; in init()
[all …]
Dxray_profiling.cpp51 static std::aligned_storage<sizeof(BufferQueue), alignof(BufferQueue)>::type
53 static BufferQueue *BQ = nullptr;
101 if (BQ->getBuffer(ThreadBuffers.NodeBuffer) != BufferQueue::ErrorCode::Ok) in getThreadLocalData()
108 if (BQ->getBuffer(ThreadBuffers.RootsBuffer) != BufferQueue::ErrorCode::Ok) in getThreadLocalData()
116 BufferQueue::ErrorCode::Ok) in getThreadLocalData()
124 BufferQueue::ErrorCode::Ok) in getThreadLocalData()
394 BufferQueue(profilingFlags()->per_thread_allocator_max, in profilingLoggingInit()
406 BQ = reinterpret_cast<BufferQueue *>(&BufferQueueStorage); in profilingLoggingInit()
412 if (InitStatus != BufferQueue::ErrorCode::Ok) { in profilingLoggingInit()
415 BufferQueue::getErrorString(InitStatus)); in profilingLoggingInit()
Dxray_fdr_logging.cpp54 BufferQueue::Buffer Buffer{};
55 BufferQueue *BQ = nullptr;
80 static std::aligned_storage<sizeof(BufferQueue)>::type BufferQueueStorage;
81 static BufferQueue *BQ = nullptr;
222 static BufferQueue::const_iterator It{}; in fdrIterator()
223 static BufferQueue::const_iterator End{}; in fdrIterator()
360 BQ->apply([&](const BufferQueue::Buffer &B) { in fdrLoggingFlush()
468 TLD.BQ->releaseBuffer(TLD.Buffer) != BufferQueue::ErrorCode::Ok) in setupTLD()
472 if (TLD.BQ->getBuffer(TLD.Buffer) != BufferQueue::ErrorCode::Ok) in setupTLD()
666 BQ = reinterpret_cast<BufferQueue *>(&BufferQueueStorage); in fdrLoggingInit()
[all …]
Dxray_profile_collector.cpp60 BufferQueue *BQ;
75 sizeof(BufferQueue), alignof(BufferQueue)>::type BufferQueueStorage;
76 static BufferQueue *BQ = nullptr;
77 static BufferQueue::Buffer Buffer;
108 void post(BufferQueue *Q, FunctionCallTrie &&T, in post()
344 BufferQueue(profilingFlags()->global_allocator_max, 1, Success); in reset()
347 BQ = reinterpret_cast<BufferQueue *>(&BufferQueueStorage); in reset()
352 BufferQueue::ErrorCode::Ok) in reset()
356 if (BQ->getBuffer(Buffer) != BufferQueue::ErrorCode::Ok) in reset()
Dxray_buffer_queue.h31 class BufferQueue {
61 friend class BufferQueue;
199 BufferQueue(size_t B, size_t N, bool &Success);
275 ~BufferQueue();
Dxray_fdr_controller.h26 BufferQueue *BQ;
27 BufferQueue::Buffer &B;
56 if (BQ->getBuffer(B) != BufferQueue::ErrorCode::Ok) in getNewBuffer()
142 return BQ->releaseBuffer(B) == BufferQueue::ErrorCode::Ok; in returnBuffer()
236 FDRController(BufferQueue *BQ, BufferQueue::Buffer &B, FDRLogWriter &W, in FDRController()
Dxray_fdr_log_writer.h78 BufferQueue::Buffer &Buffer;
92 explicit FDRLogWriter(BufferQueue::Buffer &B, char *P)
98 explicit FDRLogWriter(BufferQueue::Buffer &B)
Dxray_profile_collector.h39 void post(BufferQueue *Q, FunctionCallTrie &&T,
Dxray_function_call_trie.h165 BufferQueue::Buffer NodeBuffer;
166 BufferQueue::Buffer RootsBuffer;
167 BufferQueue::Buffer ShadowStackBuffer;
168 BufferQueue::Buffer NodeIdPairBuffer;
/external/webrtc/rtc_base/
Dbuffer_queue.cc20 BufferQueue::BufferQueue(size_t capacity, size_t default_size) in BufferQueue() function in rtc::BufferQueue
23 BufferQueue::~BufferQueue() { in ~BufferQueue()
34 size_t BufferQueue::size() const { in size()
39 void BufferQueue::Clear() { in Clear()
47 bool BufferQueue::ReadFront(void* buffer, size_t bytes, size_t* bytes_read) { in ReadFront()
69 bool BufferQueue::WriteBack(const void* buffer, in WriteBack()
Dbuffer_queue.h26 class BufferQueue {
29 BufferQueue(size_t capacity, size_t default_size);
30 virtual ~BufferQueue();
59 RTC_DISALLOW_COPY_AND_ASSIGN(BufferQueue);
Dbuffer_queue_unittest.cc24 BufferQueue queue1(1, kSize); in TEST()
25 BufferQueue queue2(2, kSize); in TEST()
Dssl_stream_adapter_unittest.cc233 class BufferQueueStream : public rtc::BufferQueue, public rtc::StreamInterface {
236 : rtc::BufferQueue(capacity, default_size) {} in BufferQueueStream()
/external/webrtc/p2p/base/
Ddtls_transport.h59 rtc::BufferQueue packets_;
/external/walt/docs/usage/
DWALT_usage.md135 [OpenSLES BufferQueue callback that enqueued the buffer](https://github.com/google/walt/blob/master…