| /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() argument
41 void* msg = fixed_queue_try_dequeue(queue); in fixed_queue_ready()
55 fixed_queue_t* queue; in TEST_F() local
58 queue = fixed_queue_new(0); in TEST_F()
59 EXPECT_TRUE(queue != NULL); in TEST_F()
60 fixed_queue_free(queue, NULL); in TEST_F()
63 queue = fixed_queue_new(1); in TEST_F()
64 EXPECT_TRUE(queue != NULL); in TEST_F()
65 fixed_queue_free(queue, NULL); in TEST_F()
68 queue = fixed_queue_new((size_t)-1); in TEST_F()
[all …]
|
| /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() argument
69 if (!queue) return; in fixed_queue_free()
71 fixed_queue_unregister_dequeue(queue); in fixed_queue_free()
74 for (const list_node_t* node = list_begin(queue->list); in fixed_queue_free()
75 node != list_end(queue->list); node = list_next(node)) in fixed_queue_free()
78 list_free(queue->list); in fixed_queue_free()
79 semaphore_free(queue->enqueue_sem); in fixed_queue_free()
80 semaphore_free(queue->dequeue_sem); in fixed_queue_free()
81 delete queue->mutex; in fixed_queue_free()
82 osi_free(queue); in fixed_queue_free()
[all …]
|
| D | alarm.cc | 101 fixed_queue_t* queue; // The processing queue to add this alarm to member
140 fixed_queue_t* queue, bool for_msg_loop);
145 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
153 static void alarm_register_processing_queue(fixed_queue_t* queue,
227 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal() argument
236 alarm->queue = queue; in alarm_set_internal()
273 alarm->queue = NULL; in alarm_cancel_internal()
412 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) { in remove_pending_alarm()
551 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue() argument
553 CHECK(queue != NULL); in alarm_register_processing_queue()
[all …]
|
| D | thread.cc | 249 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb() local
250 work_item_t* item = static_cast<work_item_t*>(fixed_queue_dequeue(queue)); in work_queue_read_cb()
|
| /system/bt/common/ |
| D | leaky_bonded_queue_unittest.cc | 54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
55 EXPECT_EQ(queue->Capacity(), static_cast<size_t>(3)); in TEST()
56 EXPECT_EQ(queue->Length(), static_cast<size_t>(0)); in TEST()
57 queue->Enqueue(item1); in TEST()
58 EXPECT_EQ(queue->Length(), static_cast<size_t>(1)); in TEST()
59 queue->Enqueue(item2); in TEST()
60 EXPECT_EQ(queue->Length(), static_cast<size_t>(2)); in TEST()
61 queue->Enqueue(item3); in TEST()
62 EXPECT_EQ(queue->Length(), static_cast<size_t>(3)); in TEST()
64 queue->Enqueue(item4); in TEST()
[all …]
|
| /system/bt/osi/include/ |
| D | fixed_queue.h | 31 typedef void (*fixed_queue_cb)(fixed_queue_t* queue, void* context);
44 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
49 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
53 bool fixed_queue_is_empty(fixed_queue_t* queue);
57 size_t fixed_queue_length(fixed_queue_t* queue);
61 size_t fixed_queue_capacity(fixed_queue_t* queue);
66 void fixed_queue_enqueue(fixed_queue_t* queue, void* data);
71 void* fixed_queue_dequeue(fixed_queue_t* queue);
77 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data);
82 void* fixed_queue_try_dequeue(fixed_queue_t* queue);
[all …]
|
| /system/core/toolbox/upstream-netbsd/usr.bin/grep/ |
| D | queue.c | 54 static STAILQ_HEAD(, qentry) queue = STAILQ_HEAD_INITIALIZER(queue);
72 STAILQ_INSERT_TAIL(&queue, item, list); in enqueue()
86 item = STAILQ_FIRST(&queue); in dequeue()
90 STAILQ_REMOVE_HEAD(&queue, list); in dequeue()
|
| /system/core/storaged/ |
| D | storaged_diskstats.cpp | 47 << " q: " << perf->queue; in log_debug_disk_perf()
182 perf.queue = (stats->io_in_queue + (stats->io_ticks >> 1)) / in get_disk_perf()
230 mMean.queue = (uint32_t)mStats.queue.get_mean(); in update_mean()
240 mStd.queue = (uint32_t)mStats.queue.get_std(); in update_std()
249 mStats.queue.add(perf->queue); in add()
257 mStats.queue.evict(perf->queue); in evict()
262 return ((double)perf->queue >= (double)mMean.queue + mSigma * (double)mStd.queue) && in detect()
|
| /system/extras/simpleperf/ |
| D | callchain.h | 91 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; in SortByPeriod() local
92 queue.push(&children); in SortByPeriod()
93 while (!queue.empty()) { in SortByPeriod()
94 std::vector<std::unique_ptr<NodeT>>* v = queue.front(); in SortByPeriod()
95 queue.pop(); in SortByPeriod()
99 queue.push(&node->children); in SortByPeriod()
|
| /system/bt/stack/rfcomm/ |
| D | port_utils.cc | 125 p_port->tx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
126 p_port->rx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
209 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
215 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
237 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
238 p_port->tx.queue = nullptr; in port_release_port()
239 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
240 p_port->rx.queue = nullptr; in port_release_port()
391 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
487 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
|
| D | port_api.cc | 1081 count = fixed_queue_length(p_port->rx.queue); in PORT_Purge()
1083 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != NULL) in PORT_Purge()
1097 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != NULL) in PORT_Purge()
1156 if (fixed_queue_is_empty(p_port->rx.queue)) return (PORT_SUCCESS); in PORT_ReadData()
1161 p_buf = (BT_HDR*)fixed_queue_try_peek_first(p_port->rx.queue); in PORT_ReadData()
1192 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
1248 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue); in PORT_Read()
1293 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
1311 fixed_queue_enqueue(p_port->tx.queue, p_buf); in port_write()
1440 p_buf = (BT_HDR*)fixed_queue_try_peek_last(p_port->tx.queue); in PORT_WriteDataCO()
[all …]
|
| /system/core/adb/ |
| D | adb_utils.h | 68 std::vector<T> queue; variable
74 queue.push_back(t); in Push()
85 cv.wait(lock, [this]() { return !queue.empty(); }); in PopAll()
86 popped = std::move(queue); in PopAll()
87 queue.clear(); in PopAll()
|
| /system/core/init/ |
| D | action_manager.h | 51 std::queue<std::variant<EventTrigger, PropertyChange, BuiltinAction>> event_queue_;
52 std::queue<const Action*> current_executing_actions_;
|
| D | mount_handler.cpp | 83 auto queue = "/sys/block/" + value + "/queue"; in SetMountProperty() local
85 if (stat(queue.c_str(), &sb) || !S_ISDIR(sb.st_mode)) value = ""; in SetMountProperty()
|
| /system/bt/btif/avrcp/ |
| D | avrcp_service.h | 64 bool queue) override;
66 bool queue) override;
|
| /system/libfmq/tests/ |
| D | msgq_test_client.cpp | 150 MessageQueueUnsync* queue = nullptr; in TEST_F() local
151 getQueue(&queue, &testService, true /* setupQueue */); in TEST_F()
154 ASSERT_NE(queue, nullptr); in TEST_F()
155 ASSERT_TRUE(queue->isValid()); in TEST_F()
157 size_t numMessagesMax = queue->getQuantumCount(); in TEST_F()
170 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax)); in TEST_F()
182 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
185 delete queue; in TEST_F()
198 MessageQueueUnsync* queue = nullptr; in TEST_F() local
200 getQueue(&queue, &testService, false /* setupQueue */); in TEST_F()
[all …]
|
| /system/core/storaged/include/ |
| D | storaged_diskstats.h | 110 uint32_t queue; // I/Os in queue member
113 write_perf == 0 && write_ios == 0 && queue == 0; in is_zero()
152 std::queue<struct disk_perf> mBuffer;
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
40 CHECK_NE(queue, nullptr); in pthread_callback_batch()
41 fixed_queue_dequeue(queue); in pthread_callback_batch()
50 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue() argument
51 CHECK_NE(queue, nullptr); in callback_sequential_queue()
52 fixed_queue_dequeue(queue); in callback_sequential_queue()
56 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch() argument
57 CHECK_NE(queue, nullptr); in callback_batch()
58 fixed_queue_dequeue(queue); in callback_batch()
|
| /system/core/debuggerd/tombstoned/ |
| D | tombstoned.cpp | 102 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
105 return &queue; in for_tombstones()
109 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
112 return &queue; in for_anrs()
399 CrashQueue* queue = CrashQueue::for_crash(crash); in crash_completed_cb()
403 queue->maybe_dequeue_crashes(perform_request); in crash_completed_cb()
|
| /system/chre/platform/linux/include/chre/target_platform/ |
| D | platform_log_base.h | 50 std::queue<char *> mLogQueue;
|
| /system/bt/gd/os/ |
| D | handler.h | 50 std::queue<Closure> tasks_;
|
| /system/bt/vendor_libs/test_vendor_lib/scripts/ |
| D | link_layer_socket.py | 65 import queue
86 self.packets_ = queue.Queue()
|
| /system/core/fastboot/ |
| D | socket_mock.h | 95 std::queue<Event> events_;
|
| /system/bt/gd/os/linux_generic/ |
| D | handler.cc | 64 std::queue<Closure> empty; in Clear()
|
| /system/libhidl/base/ |
| D | SynchronizedQueue.h | 62 std::queue<T> mQueue;
|