Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 47) sorted by relevance

12

/system/bt/osi/test/
Dfixed_queue_test.cc40 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 …]
Dleaky_bonded_queue_test.cc54 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/src/
Dfixed_queue.cc68 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 …]
Dalarm.cc102 fixed_queue_t* queue; // The processing queue to add this alarm to member
147 fixed_queue_t* queue, bool for_msg_loop);
152 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
160 static void alarm_register_processing_queue(fixed_queue_t* queue,
232 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal() argument
241 alarm->queue = queue; in alarm_set_internal()
276 alarm->queue = NULL; in alarm_cancel_internal()
411 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) { in remove_pending_alarm()
549 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue() argument
551 CHECK(queue != NULL); in alarm_register_processing_queue()
[all …]
Dthread.cc249 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/osi/include/
Dfixed_queue.h31 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 …]
Dleaky_bonded_queue.h83 std::queue<std::unique_ptr<T>> queue_;
/system/core/adb/
Dadb_utils.h64 std::vector<T> queue; variable
70 queue.push_back(t); in Push()
81 cv.wait(lock, [this]() { return !queue.empty(); }); in PopAll()
82 popped = std::move(queue); in PopAll()
83 queue.clear(); in PopAll()
/system/core/toolbox/upstream-netbsd/usr.bin/grep/
Dqueue.c54 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/
Dstoraged_diskstats.cpp47 << " q: " << perf->queue; in log_debug_disk_perf()
178 perf.queue = (stats->io_in_queue + (stats->io_ticks >> 1)) / in get_disk_perf()
226 mMean.queue = (uint32_t)mStats.queue.get_mean(); in update_mean()
236 mStd.queue = (uint32_t)mStats.queue.get_std(); in update_std()
245 mStats.queue.add(perf->queue); in add()
253 mStats.queue.evict(perf->queue); in evict()
258 return ((double)perf->queue >= (double)mMean.queue + mSigma * (double)mStd.queue) && in detect()
/system/extras/simpleperf/
Dcallchain.h91 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/
Dport_utils.cc125 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()
210 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
216 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
238 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
239 p_port->tx.queue = nullptr; in port_release_port()
240 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
241 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 …]
Dport_api.cc1091 count = fixed_queue_length(p_port->rx.queue); in PORT_Purge()
1093 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != NULL) in PORT_Purge()
1107 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != NULL) in PORT_Purge()
1166 if (fixed_queue_is_empty(p_port->rx.queue)) return (PORT_SUCCESS); in PORT_ReadData()
1171 p_buf = (BT_HDR*)fixed_queue_try_peek_first(p_port->rx.queue); in PORT_ReadData()
1202 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
1258 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue); in PORT_Read()
1303 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
1321 fixed_queue_enqueue(p_port->tx.queue, p_buf); in port_write()
1450 p_buf = (BT_HDR*)fixed_queue_try_peek_last(p_port->tx.queue); in PORT_WriteDataCO()
[all …]
/system/core/init/
Daction_manager.h51 std::queue<std::variant<EventTrigger, PropertyChange, BuiltinAction>> event_queue_;
52 std::queue<const Action*> current_executing_actions_;
/system/bt/vendor_libs/test_vendor_lib/include/
Dconnection.h86 std::queue<TaskCallback> actions_;
89 std::queue<std::vector<uint8_t>> messages_;
/system/libfmq/tests/
Dmsgq_test_client.cpp148 MessageQueueUnsync* queue = nullptr; in TEST_F() local
149 getQueue(&queue, &testService, true /* setupQueue */); in TEST_F()
152 ASSERT_NE(queue, nullptr); in TEST_F()
153 ASSERT_TRUE(queue->isValid()); in TEST_F()
155 size_t numMessagesMax = queue->getQuantumCount(); in TEST_F()
168 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax)); in TEST_F()
180 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
183 delete queue; in TEST_F()
196 MessageQueueUnsync* queue = nullptr; in TEST_F() local
198 getQueue(&queue, &testService, false /* setupQueue */); in TEST_F()
[all …]
/system/bt/btif/avrcp/
Davrcp_service.h64 bool queue) override;
66 bool queue) override;
Davrcp_service.cc341 bool queue) { in SendMediaUpdate() argument
345 << " queue=" << queue; in SendMediaUpdate()
352 track_changed, play_state, queue)); in SendMediaUpdate()
/system/bt/test/suite/core/
Dthread_performance_test.cc25 void callback(fixed_queue_t* queue, void* data) { in callback() argument
26 if (queue != nullptr) { in callback()
27 fixed_queue_dequeue(queue); in callback()
/system/core/storaged/include/
Dstoraged_diskstats.h110 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/core/debuggerd/tombstoned/
Dtombstoned.cpp100 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
103 return &queue; in for_tombstones()
107 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
110 return &queue; in for_anrs()
389 CrashQueue* queue = CrashQueue::for_crash(crash); in crash_completed_cb()
393 queue->maybe_dequeue_crashes(perform_request); in crash_completed_cb()
/system/chre/platform/linux/include/chre/target_platform/
Dplatform_log_base.h50 std::queue<std::unique_ptr<char>> mLogQueue;
/system/core/fastboot/
Dsocket_mock.h96 std::queue<Event> events_;
/system/core/storaged/tests/
Dstoraged_test.cpp190 retval.queue = (double)perf.queue * mul; in disk_perf_multiply()
257 .queue = 5 in TEST()
285 test_perf.queue = (double)test_mean.queue + i * test_std.queue; in TEST()
/system/libhidl/base/
DSynchronizedQueue.h62 std::queue<T> mQueue;

12