Searched refs:Queue (Results 1 – 20 of 20) sorted by relevance
| /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 | 41 std::shared_ptr<acl_manager::AclConnection::Queue> queue_;
47 std::shared_ptr<acl_manager::AclConnection::Queue> queue);
|
| D | le_acl_connection.cc | 68 impl(LeAclConnectionInterface* le_acl_connection_interface, std::shared_ptr<Queue> queue, in impl()
78 std::shared_ptr<Queue> queue_;
86 LeAclConnection::LeAclConnection(std::shared_ptr<Queue> queue, LeAclConnectionInterface* le_acl_con… in LeAclConnection()
|
| D | acl_connection.h | 37 using Queue = common::BidiQueue<PacketView<kLittleEndian>, BasePacketBuilder>; variable
|
| D | le_acl_connection.h | 32 …LeAclConnection(std::shared_ptr<Queue> queue, LeAclConnectionInterface* le_acl_connection_interfac…
|
| D | classic_acl_connection.h | 31 …ClassicAclConnection(std::shared_ptr<Queue> queue, AclConnectionInterface* acl_connection_interfac…
|
| D | classic_acl_connection.cc | 287 impl(AclConnectionInterface* acl_connection_interface, std::shared_ptr<Queue> queue) in impl()
297 std::shared_ptr<Queue> queue_;
303 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 | 147 auto queue = std::make_shared<AclConnection::Queue>(10); in on_le_connection_complete()
200 auto queue = std::make_shared<AclConnection::Queue>(10); in on_le_enhanced_connection_complete()
|
| D | classic_impl.h | 211 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/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:
|