Home
last modified time | relevance | path

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

12345

/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 …]
/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.cc99 fixed_queue_t* queue; // The processing queue to add this alarm to member
138 fixed_queue_t* queue, bool for_msg_loop);
143 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
151 static void alarm_register_processing_queue(fixed_queue_t* queue,
226 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal() argument
235 alarm->queue = queue; in alarm_set_internal()
272 alarm->queue = NULL; in alarm_cancel_internal()
408 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) { in remove_pending_alarm()
546 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue() argument
548 CHECK(queue != NULL); in alarm_register_processing_queue()
[all …]
/system/bt/common/
Dleaky_bonded_queue_unittest.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/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 …]
/system/bt/gd/os/linux_generic/
Dqueue_unittest.cc67 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd() argument
68 : count(0), handler_(handler), queue_(queue), delay_(0) {} in TestEnqueueEnd()
111 std::queue<std::unique_ptr<std::string>> buffer_;
132 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd() argument
133 : count(0), handler_(handler), queue_(queue), capacity_(capacity), delay_(0) {} in TestDequeueEnd()
175 std::queue<std::unique_ptr<std::string>> buffer_;
204 Queue<std::string> queue(kQueueSize); in TEST_F() local
205 TestEnqueueEnd test_enqueue_end(&queue, enqueue_handler_); in TEST_F()
228 Queue<std::string> queue(kQueueSize); in TEST_F() local
229 TestDequeueEnd test_dequeue_end(&queue, dequeue_handler_, kQueueSize); in TEST_F()
[all …]
/system/bt/gd/os/
Dqueue_benchmark.cc59 …explicit TestEnqueueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestEnqueueEnd() argument
60 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestEnqueueEnd()
93 std::queue<std::string> buffer_;
109 …explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestDequeueEnd() argument
110 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestDequeueEnd()
127 std::queue<std::string> buffer_;
143 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
148 TestDequeueEnd test_dequeue_end(num_data_to_send_, &queue, enqueue_handler_, &dequeue_promise); in BENCHMARK_DEFINE_F()
153 TestEnqueueEnd test_enqueue_end(num_data_to_send_, &queue, enqueue_handler_, &enqueue_promise); in BENCHMARK_DEFINE_F()
177 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
[all …]
Dqueue.h86 std::queue<std::unique_ptr<T>> queue_;
108 EnqueueBuffer(IQueueEnqueue<T>* queue) : queue_(queue) {} in EnqueueBuffer() argument
128 std::queue<std::unique_ptr<T>> empty; in Clear()
160 std::queue<std::unique_ptr<T>> buffer_;
/system/bt/gd/l2cap/fuzz/
Dchannel_fuzz_controller.cc27 EnqueueType* queue = reinterpret_cast<EnqueueType*>(chan->GetQueueUpEnd()); in ChannelFuzzController() local
28 channelInject_ = std::make_shared<ChannelFuzzQueueType>(queue, l2cap_handler); in ChannelFuzzController()
32 EnqueueType* queue = reinterpret_cast<EnqueueType*>(chan->GetQueueUpEnd()); in ChannelFuzzController() local
33 channelInject_ = std::make_shared<ChannelFuzzQueueType>(queue, l2cap_handler); in ChannelFuzzController()
/system/core/storaged/
Dstoraged_diskstats.cpp47 << " 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/bt/stack/rfcomm/
Dport_utils.cc126 p_port->tx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
127 p_port->rx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
211 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
217 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
239 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
240 p_port->tx.queue = nullptr; in port_release_port()
241 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
242 p_port->rx.queue = nullptr; in port_release_port()
393 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
489 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
/system/extras/simpleperf/
Dcallchain.h89 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; in SortByPeriod() local
90 queue.push(&children); in SortByPeriod()
91 while (!queue.empty()) { in SortByPeriod()
92 std::vector<std::unique_ptr<NodeT>>* v = queue.front(); in SortByPeriod()
93 queue.pop(); in SortByPeriod()
97 queue.push(&node->children); in SortByPeriod()
/system/bt/test/stub/
Dosi.cc304 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty() argument
308 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue() argument
316 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd() argument
320 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd() argument
324 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list() argument
328 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity() argument
332 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() argument
336 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue() argument
339 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush() argument
342 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free() argument
[all …]
/system/bt/gd/storage/
Dmutation.h37 std::queue<MutationEntry> normal_config_entries_;
38 std::queue<MutationEntry> memory_only_config_entries_;
/system/core/debuggerd/tombstoned/
Dtombstoned.cpp129 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
132 return &queue; in for_tombstones()
136 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
139 return &queue; in for_anrs()
433 CrashQueue* queue = CrashQueue::for_crash(crash); in crash_completed() local
456 CrashArtifactPaths paths = queue->get_next_artifact_paths(); in crash_completed()
458 if (rename_tombstone_fd(crash->output.text.fd, queue->dir_fd(), paths.text)) { in crash_completed()
473 rename_tombstone_fd(crash->output.proto->fd, queue->dir_fd(), *paths.proto); in crash_completed()
479 rc = unlinkat(queue->dir_fd().get(), crash->output.text.temporary_path->c_str(), 0); in crash_completed()
485 rc = unlinkat(queue->dir_fd().get(), crash->output.proto->temporary_path->c_str(), 0); in crash_completed()
[all …]
/system/bt/gd/dumpsys/
Dfilter_test.cc67 std::queue<TableAddFunction> queue; in PopulateTestSchema() local
69 queue.push(test_data_class->GetTable(fb_builder)); in PopulateTestSchema()
84 while (!queue.empty()) { in PopulateTestSchema()
85 queue.front()(&builder); in PopulateTestSchema()
86 queue.pop(); in PopulateTestSchema()
/system/bt/gd/
Dmodule.cc146 std::queue<DumpsysDataFinisher> queue; in DumpState() local
150 queue.push(instance->second->GetDumpsysData(&builder)); in DumpState()
158 while (!queue.empty()) { in DumpState()
159 queue.front()(&data_builder); in DumpState()
160 queue.pop(); in DumpState()
/system/bt/gd/os/fuzz/
Dfuzz_inject_queue.h28 FuzzInjectQueue(IQueueEnqueue<T>* queue, Handler* handler) : handler_(handler) { in FuzzInjectQueue() argument
29 buffer_ = new EnqueueBuffer<T>(queue); in FuzzInjectQueue()
Ddev_null_queue.h29 DevNullQueue(IQueueDequeue<T>* queue, Handler* handler) : queue_(queue), handler_(handler) {} in DevNullQueue() argument
/system/libfmq/tests/
Dmsgq_test_client.cpp159 AidlMessageQueueUnsync** queue) { in getFmqUnsyncWrite() argument
163 *queue = new (std::nothrow) AidlMessageQueueUnsync(desc); in getFmqUnsyncWrite()
208 MessageQueueUnsync** queue) { in getFmqUnsyncWrite() argument
213 [queue](bool ret, const MQDescriptorUnsync<int32_t>& in) { in getFmqUnsyncWrite()
215 *queue = new (std::nothrow) MessageQueueUnsync(in); in getFmqUnsyncWrite()
329 typename TypeParam::MQType* queue = nullptr; in TYPED_TEST() local
331 this->getQueue(&queue, true /* setupQueue */, TypeParam::UserFd /* userFd */); in TYPED_TEST()
334 ASSERT_NE(queue, nullptr); in TYPED_TEST()
335 ASSERT_TRUE(queue->isValid()); in TYPED_TEST()
337 size_t numMessagesMax = queue->getQuantumCount(); in TYPED_TEST()
[all …]
/system/core/init/
Daction_manager.h54 std::queue<std::variant<EventTrigger, PropertyChange, BuiltinAction>> event_queue_
57 std::queue<const Action*> current_executing_actions_;
/system/bt/gd/hci/acl_manager/
Dle_acl_connection.cc86 …impl(LeAclConnectionInterface* le_acl_connection_interface, std::shared_ptr<Queue> queue, uint16_t… in impl()
87 : queue_(std::move(queue)), tracker(le_acl_connection_interface, connection_handle) {} in impl()
104 std::shared_ptr<Queue> queue, in LeAclConnection() argument
110 : AclConnection(queue->GetUpEnd(), handle), in LeAclConnection()
114 pimpl_ = new LeAclConnection::impl(le_acl_connection_interface, std::move(queue), handle); in LeAclConnection()
/system/bt/hci/test/
Dpacket_fragmenter_host_test.cc76 std::queue<std::unique_ptr<BT_HDR, decltype(&FreeBuffer)>> queue; member
91 test_state_.reassembled.queue.push( in OnReassembled()
141 while (!test_state_.reassembled.queue.empty()) { in TearDown()
142 test_state_.reassembled.queue.pop(); in TearDown()
308 auto packet = std::move(test_state_.reassembled.queue.front()); in TEST_F()
309 test_state_.reassembled.queue.pop(); in TEST_F()
354 auto packet = std::move(test_state_.reassembled.queue.front()); in TEST_F()
355 test_state_.reassembled.queue.pop(); in TEST_F()
383 auto packet = std::move(test_state_.reassembled.queue.front()); in TEST_F()
/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/bt/common/benchmark/
Dthread_performance_benchmark.cc40 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch() local
41 CHECK_NE(queue, nullptr); in pthread_callback_batch()
42 fixed_queue_dequeue(queue); in pthread_callback_batch()
51 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue() argument
52 CHECK_NE(queue, nullptr); in callback_sequential_queue()
53 fixed_queue_dequeue(queue); in callback_sequential_queue()
57 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch() argument
58 CHECK_NE(queue, nullptr); in callback_batch()
59 fixed_queue_dequeue(queue); in callback_batch()

12345