Home
last modified time | relevance | path

Searched refs:TryDequeue (Results 1 – 25 of 34) sorted by relevance

12

/system/bt/gd/common/
Dbidi_queue.h52 std::unique_ptr<TDEQUEUE> TryDequeue() override { in TryDequeue() function
53 return rx_->TryDequeue(); in TryDequeue()
Dbidi_queue_unittest.cc111 promise->set_value(end_->TryDequeue().get()); in handle_register_dequeue()
/system/bt/gd/common/testing/
Dwired_pair_of_bidi_queues.h38 auto down_thing = queue_a_.GetDownEnd()->TryDequeue(); in dequeue_callback_a()
45 auto down_thing = queue_b_.GetDownEnd()->TryDequeue(); in dequeue_callback_b()
/system/bt/gd/security/test/
Dfake_l2cap_test.cc105 auto test_packet_from_other_end = bidi_queue.GetUpEnd()->TryDequeue(); in TEST_F()
121 auto other_end_packet = bidi_queue.GetDownEnd()->TryDequeue(); in TEST_F()
Dpairing_handler_le_pair_test.cc120 auto packet_bytes_view = l2cap_->GetQueueAUpEnd()->TryDequeue(); in dequeue_callback_master()
136 auto packet_bytes_view = l2cap_->GetQueueBUpEnd()->TryDequeue(); in dequeue_callback_slave()
/system/bt/gd/os/fuzz/
Ddev_null_queue.h41 queue_->TryDequeue(); in Dump()
/system/bt/gd/l2cap/internal/
Dreceiver.cc43 auto packet = link_queue_up_end_->TryDequeue(); in link_queue_dequeue_callback()
Denhanced_retransmission_mode_channel_data_controller_test.cc108 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
134 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
161 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
201 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
Dle_credit_based_channel_data_controller_test.cc135 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
157 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
178 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
Dscheduler_fifo_test.cc107 auto packet = link_queue_.GetDownEnd()->TryDequeue(); in TEST_F()
Dbasic_mode_channel_data_controller_test.cc95 auto packet_view = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F()
Dsender.cc84 auto packet = queue_end_->TryDequeue(); in dequeue_callback()
/system/bt/gd/os/
Dqueue.h54 virtual std::unique_ptr<T> TryDequeue() = 0;
81 std::unique_ptr<T> TryDequeue() override;
Dqueue_benchmark.cc117 std::string data = *(queue_->TryDequeue()); in DequeueCallbackForTest()
/system/bt/gd/l2cap/classic/internal/
Dlink_test.cc58 …d::unique_ptr<BasePacketBuilder> data = raw_acl_connection_->acl_queue_.GetDownEnd()->TryDequeue(); in OnDequeueCallbackForTest()
/system/bt/gd/os/linux_generic/
Dqueue.tpp89 std::unique_ptr<T> Queue<T>::TryDequeue() {
Dqueue_unittest.cc157 std::unique_ptr<std::string> data = queue_->TryDequeue(); in DequeueCallbackForTest()
709 auto answer = *queue->TryDequeue(); in TEST_F()
821 … common::Bind([](Queue<std::string>* queue) { queue->TryDequeue(); }, common::Unretained(queue))); in RegisterDequeueAndDelete()
/system/bt/gd/hci/acl_manager/
Dround_robin_scheduler.cc116 auto packet = acl_queue_handler->second.queue_->GetDownEnd()->TryDequeue(); in buffer_packet()
/system/bt/gd/l2cap/le/
Dfacade.cc201 auto packet = channel_->GetQueueUpEnd()->TryDequeue(); in on_incoming_packet()
351 auto packet = channel_->GetQueueUpEnd()->TryDequeue(); in on_incoming_packet()
/system/bt/gd/hci/
Dacl_manager.cc82 auto packet = hci_queue_end_->TryDequeue(); in dequeue_and_route_acl_packet_to_connection()
Dacl_manager_test.cc248 EXPECT_EQ(queue_end->TryDequeue(), nullptr); in AssertNoOutgoingAclData()
269 received = queue_end->TryDequeue(); in OutgoingAclData()
725 received = queue_end->TryDequeue(); in TEST_F()
811 received = queue_end->TryDequeue(); in TEST_F()
/system/bt/gd/hci/facade/
Dfacade.cc178 auto acl_ptr = hci_layer_->GetAclQueueEnd()->TryDequeue(); in on_acl_ready()
Dle_acl_manager_facade.cc209 auto packet = connection->GetAclQueueEnd()->TryDequeue(); in on_incoming_acl()
/system/bt/gd/l2cap/classic/
Dfacade.cc237 auto packet = channel_->GetQueueUpEnd()->TryDequeue(); in on_incoming_packet()
/system/bt/gd/security/
Dpairing_handler_le_unittest.cc96 std::unique_ptr<packet::BasePacketBuilder> builder = bidi_queue_->GetDownEnd()->TryDequeue(); in L2CAP_SendSmp()

12