| /system/bt/osi/src/ |
| D | fixed_queue.cc | 68 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
85 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
96 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
103 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
110 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
116 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
130 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
147 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
162 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue()
179 void* fixed_queue_try_peek_first(fixed_queue_t* queue) { in fixed_queue_try_peek_first()
[all …]
|
| D | alarm.cc | 101 fixed_queue_t* queue; // The processing queue to add this alarm to member
227 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
547 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue()
604 static void alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in alarm_queue_ready()
|
| D | thread.cc | 246 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb() local
|
| /system/bt/osi/test/ |
| D | fixed_queue_test.cc | 40 static void fixed_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in fixed_queue_ready()
55 fixed_queue_t* queue; in TEST_F() local
83 fixed_queue_t* queue; in TEST_F() local
125 fixed_queue_t* queue; in TEST_F() local
147 fixed_queue_t* queue; in TEST_F() local
169 fixed_queue_t* queue; in TEST_F() local
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
[all …]
|
| /system/bt/gd/os/linux_generic/ |
| D | queue_unittest.cc | 67 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd()
132 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd()
204 Queue<std::string> queue(kQueueSize); in TEST_F() local
228 Queue<std::string> queue(kQueueSize); in TEST_F() local
246 Queue<std::string> queue(kQueueSize); in TEST_F() local
280 Queue<std::string> queue(kQueueSize); in TEST_F() local
313 Queue<std::string> queue(kQueueSize); in TEST_F() local
346 Queue<std::string> queue(kQueueSize); in TEST_F() local
382 Queue<std::string> queue(kQueueSize); in TEST_F() local
411 Queue<std::string> queue(kQueueSize); in TEST_F() local
[all …]
|
| /system/bt/common/ |
| D | leaky_bonded_queue_unittest.cc | 54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); in TEST() local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
|
| /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()
109 …explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestDequeueEnd()
143 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
177 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
|
| D | queue.h | 108 EnqueueBuffer(IQueueEnqueue<T>* queue) : queue_(queue) {} in EnqueueBuffer()
|
| /system/bt/gd/os/fuzz/ |
| D | fuzz_inject_queue.h | 28 FuzzInjectQueue(IQueueEnqueue<T>* queue, Handler* handler) : handler_(handler) { in FuzzInjectQueue()
|
| D | dev_null_queue.h | 29 DevNullQueue(IQueueDequeue<T>* queue, Handler* handler) : queue_(queue), handler_(handler) {} in DevNullQueue()
|
| /system/core/adb/ |
| D | adb_utils.h | 70 std::vector<T> queue; variable
|
| /system/bt/gd/dumpsys/ |
| D | filter_test.cc | 67 std::queue<TableAddFunction> queue; in PopulateTestSchema() local
|
| /system/core/storaged/include/ |
| D | storaged_diskstats.h | 110 uint32_t queue; // I/Os in queue member
158 stream_stats queue; // I/Os in queue member
|
| /system/bt/common/benchmark/ |
| D | thread_performance_benchmark.cc | 39 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch() local
50 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue()
56 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
|
| /system/bt/osi/test/fuzzers/fixed_queue/ |
| D | fuzz_fixed_queue.cc | 32 void fqCb(fixed_queue_t* queue, void* data) { in fqCb()
|
| /system/core/init/ |
| D | mount_handler.cpp | 82 auto queue = "/sys/block/" + value + "/queue"; in SetMountProperty() local
|
| /system/core/debuggerd/tombstoned/ |
| D | tombstoned.cpp | 102 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
109 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
|
| /system/bt/gd/common/ |
| D | bidi_queue_unittest.cc | 120 BidiQueue<A, B> queue(100); in TEST_F() local
|
| /system/bt/gd/ |
| D | module.cc | 135 std::queue<DumpsysDataFinisher> queue; in DumpState() local
|
| /system/bt/gd/hci/acl_manager/ |
| 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() local
200 auto queue = std::make_shared<AclConnection::Queue>(10); in on_le_enhanced_connection_complete() local
|
| D | le_acl_connection.cc | 86 LeAclConnection::LeAclConnection(std::shared_ptr<Queue> queue, LeAclConnectionInterface* le_acl_con… in LeAclConnection()
|
| /system/extras/simpleperf/ |
| D | callchain.h | 91 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; in SortByPeriod() local
|
| /system/bt/common/test/ |
| D | thread_performance_test.cc | 40 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
|
| /system/libfmq/tests/ |
| D | msgq_test_client.cpp | 151 MessageQueueUnsync* queue = nullptr; in TEST_F() local
199 MessageQueueUnsync* queue = nullptr; in TEST_F() local
|