| /system/libfmq/fuzzer/ |
| D | fmq_fuzzer.cpp | 70 template <typename Queue, typename Desc>
72 Queue readMq(desc); in reader()
79 typename Queue::MemTransaction tx; in reader()
98 template <typename Queue>
99 void writer(Queue& writeMq, FuzzedDataProvider& fdp) { in writer()
101 typename Queue::MemTransaction tx; in writer()
123 template <typename Queue, typename Desc>
127 Queue writeMq(fdp.ConsumeIntegralInRange<size_t>(1, kMaxNumElements), fdp.ConsumeBool()); in fuzzAidlWithReaders()
137 clients.emplace_back(reader<Queue, Desc>, std::ref(desc), std::ref(readerData[i])); in fuzzAidlWithReaders()
140 writer<Queue>(writeMq, fdp); in fuzzAidlWithReaders()
[all …]
|
| /system/bt/gd/os/linux_generic/ |
| D | queue.tpp | 18 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};
21 Queue<T>::~Queue() {
27 void Queue<T>::RegisterEnqueue(Handler* handler, EnqueueCallback callback) {
34 base::Bind(&Queue<T>::EnqueueCallbackInternal, base::Unretained(this), std::move(callback)),
39 void Queue<T>::UnregisterEnqueue() {
59 void Queue<T>::RegisterDequeue(Handler* handler, DequeueCallback callback) {
69 void Queue<T>::UnregisterDequeue() {
89 std::unique_ptr<T> Queue<T>::TryDequeue() {
107 void Queue<T>::EnqueueCallbackInternal(EnqueueCallback callback) {
|
| D | queue_unittest.cc | 67 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd()
116 Queue<std::string>* queue_;
132 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd()
180 Queue<std::string>* queue_;
204 Queue<std::string> queue(kQueueSize); in TEST_F()
228 Queue<std::string> queue(kQueueSize); in TEST_F()
246 Queue<std::string> queue(kQueueSize); in TEST_F()
280 Queue<std::string> queue(kQueueSize); in TEST_F()
313 Queue<std::string> queue(kQueueSize); in TEST_F()
346 Queue<std::string> queue(kQueueSize); in TEST_F()
[all …]
|
| /system/bt/gd/os/ |
| D | queue_benchmark.cc | 59 …explicit TestEnqueueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestEnqueueEnd()
98 Queue<std::string>* queue_;
109 …explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestDequeueEnd()
132 Queue<std::string>* queue_;
143 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F()
177 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F()
|
| D | queue.h | 58 class Queue : public IQueueEnqueue<T>, public IQueueDequeue<T> {
67 explicit Queue(size_t capacity);
68 ~Queue();
|
| D | handler.h | 93 friend class Queue; variable
|
| /system/bt/gd/hci/acl_manager/ |
| D | round_robin_scheduler_test.cc | 178 auto connection_queue = std::make_shared<AclConnection::Queue>(10); in TEST_F()
185 auto connection_queue = std::make_shared<AclConnection::Queue>(10); in TEST_F()
206 auto connection_queue = std::make_shared<AclConnection::Queue>(10); in TEST_F()
207 auto le_connection_queue = std::make_shared<AclConnection::Queue>(10); in TEST_F()
232 auto connection_queue = std::make_shared<AclConnection::Queue>(15); in TEST_F()
274 auto connection_queue1 = std::make_shared<AclConnection::Queue>(10); in TEST_F()
275 auto connection_queue2 = std::make_shared<AclConnection::Queue>(10); in TEST_F()
276 auto le_connection_queue1 = std::make_shared<AclConnection::Queue>(10); in TEST_F()
277 auto le_connection_queue2 = std::make_shared<AclConnection::Queue>(10); in TEST_F()
330 auto connection_queue = std::make_shared<AclConnection::Queue>(10); in TEST_F()
[all …]
|
| D | round_robin_scheduler.h | 42 std::shared_ptr<acl_manager::AclConnection::Queue> queue_;
49 std::shared_ptr<acl_manager::AclConnection::Queue> queue);
|
| D | le_acl_connection.cc | 86 …impl(LeAclConnectionInterface* le_acl_connection_interface, std::shared_ptr<Queue> queue, uint16_t… in impl()
95 std::shared_ptr<Queue> queue_;
104 std::shared_ptr<Queue> queue, in LeAclConnection()
|
| D | acl_connection.h | 39 using Queue = common::BidiQueue<PacketView<kLittleEndian>, BasePacketBuilder>; variable
|
| D | le_acl_connection.h | 33 std::shared_ptr<Queue> queue,
|
| D | classic_acl_connection.h | 31 …ClassicAclConnection(std::shared_ptr<Queue> queue, AclConnectionInterface* acl_connection_interfac…
|
| D | classic_acl_connection.cc | 326 std::shared_ptr<Queue> queue, in impl()
338 std::shared_ptr<Queue> queue_;
344 ClassicAclConnection::ClassicAclConnection(std::shared_ptr<Queue> queue, in ClassicAclConnection()
|
| D | round_robin_scheduler.cc | 43 std::shared_ptr<acl_manager::AclConnection::Queue> queue) { in Register()
|
| D | le_impl.h | 184 auto queue = std::make_shared<AclConnection::Queue>(10); in on_le_connection_complete()
250 auto queue = std::make_shared<AclConnection::Queue>(10); in on_le_enhanced_connection_complete()
|
| D | classic_impl.h | 267 auto queue = std::make_shared<AclConnection::Queue>(10); in on_connection_complete()
|
| /system/bt/gd/common/ |
| D | bidi_queue.h | 79 ::bluetooth::os::Queue<TUP> up_queue_;
80 ::bluetooth::os::Queue<TDOWN> down_queue_;
|
| /system/extras/pagecache/ |
| D | pagecache.py | 11 import Queue
287 stdout_queue = Queue.Queue(maxsize=128)
288 stderr_queue = Queue.Queue()
324 except Queue.Empty:
|
| /system/bt/gd/l2cap/fuzz/ |
| D | fuzz_l2cap.cc | 64 auto throwaway_queue = std::make_shared<AclConnection::Queue>(10); in LLVMFuzzerTestOneInput()
|
| /system/bt/vendor_libs/test_vendor_lib/scripts/ |
| D | link_layer_socket.py | 87 self.packets_ = queue.Queue()
|
| D | hci_socket.py | 224 self.packets_ = queue.Queue()
|
| /system/bt/gd/docs/architecture/ |
| D | architecture.md | 207 A pure data use case of `Reactor` is a `Reactive Queue`, see its definition at:
|