Home
last modified time | relevance | path

Searched refs:Enqueue (Results 1 – 22 of 22) sorted by relevance

/system/bt/common/
Dleaky_bonded_queue_unittest.cc57 queue->Enqueue(item1); in TEST()
59 queue->Enqueue(item2); in TEST()
61 queue->Enqueue(item3); in TEST()
64 queue->Enqueue(item4); in TEST()
93 queue->Enqueue(item1); in TEST()
98 queue->Enqueue(item2); in TEST()
100 queue->Enqueue(item3); in TEST()
103 queue->Enqueue(item4); in TEST()
106 queue->Enqueue(item1); in TEST()
127 queue->Enqueue(item1); in TEST()
[all …]
Dleaky_bonded_queue.h55 void Enqueue(T* new_item);
103 void LeakyBondedQueue<T>::Enqueue(T* new_item) { in Enqueue() function
Dmetrics.cc304 pimpl_->pair_event_queue_->Enqueue(event); in LogPairEvent()
321 pimpl_->wake_event_queue_->Enqueue(event); in LogWakeEvent()
343 pimpl_->scan_event_queue_->Enqueue(event); in LogScanEvent()
381 pimpl_->bt_session_queue_->Enqueue(pimpl_->bluetooth_session_); in LogBluetoothSessionEnd()
/system/bt/gd/l2cap/le/internal/
Dsignalling_manager.cc104 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendConnectionParameterUpdateResponse()
110 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendCredit()
146 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
154 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
316 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnDisconnectionRequest()
485 enqueue_buffer_->Enqueue(std::move(builder), handler_); in on_incoming_packet()
495 enqueue_buffer_->Enqueue(std::move(builder), handler_); in send_connection_response()
529 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
536 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
547 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
/system/bt/gd/common/testing/
Dwired_pair_of_bidi_queues.h41 down_buffer_b_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_a()
48 down_buffer_a_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_b()
/system/bt/gd/security/test/
Dfake_l2cap_test.cc99 enqueue_buffer.Enqueue(std::move(test_packet), handler_); in TEST_F()
116 …up_end_enqueue_buffer.Enqueue(std::make_unique<PacketView<kLittleEndian>>(GetPacketView(std::move(… in TEST_F()
Dpairing_handler_le_pair_test.cc434 up_buffer_b_->Enqueue(std::move(view_to_packet), handler_); in TEST_F()
/system/bt/gd/os/fuzz/
Dfuzz_inject_queue.h36 buffer_->Enqueue(std::move(data), handler_); in Inject()
/system/bt/gd/l2cap/classic/internal/
Dsignalling_manager.cc352 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnConfigurationRequest()
383 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnConfigurationRequest()
598 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnDisconnectionRequest()
641 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnEchoRequest()
661 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
668 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
674 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
876 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_one_command()
885 enqueue_buffer_->Enqueue(std::move(builder), handler_); in send_connection_response()
939 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
[all …]
/system/bt/gd/l2cap/internal/
Dbasic_mode_channel_data_controller.cc46 …enqueue_buffer_.Enqueue(std::make_unique<PacketView<kLittleEndian>>(basic_frame_view.GetPayload())… in OnPdu()
Dle_credit_based_channel_data_controller.cc93 … enqueue_buffer_.Enqueue(std::make_unique<PacketView<kLittleEndian>>(reassembly_stage_), handler_); in OnPdu()
Denhanced_retransmission_mode_channel_data_controller.cc978 … enqueue_buffer_.Enqueue(std::make_unique<packet::PacketView<kLittleEndian>>(payload), handler_); in stage_for_reassembly()
1021 …enqueue_buffer_.Enqueue(std::make_unique<packet::PacketView<kLittleEndian>>(reassembly_stage_), ha… in stage_for_reassembly()
/system/bt/gd/os/
Dqueue.h116 void Enqueue(std::unique_ptr<T> t, os::Handler* handler) { in Enqueue() function
/system/bt/gd/os/linux_generic/
Dqueue.tpp22 ASSERT_LOG(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");
Dqueue_unittest.cc891 enqueue_buffer_.Enqueue(std::make_unique<int>(i), handler_); in TEST_F()
905 enqueue_buffer_.Enqueue(std::make_unique<int>(i), handler_); in TEST_F()
917 enqueue_buffer->Enqueue(std::make_unique<int>(i), handler_); in TEST_F()
/system/bt/gd/iso/internal/
Diso_manager_impl.cc261 iso_enqueue_buffer_->Enqueue(std::move(builder), iso_handler_); in SendIsoPacket()
/system/bt/gd/hci/
Dhci_layer.cc370 module_.impl_->incoming_acl_buffer_.Enqueue(move(acl), module_.GetHandler()); in aclDataReceived()
380 module_.impl_->incoming_iso_buffer_.Enqueue(move(iso), module_.GetHandler()); in isoDataReceived()
/system/bt/btif/src/
Dbtif_bqr.cc429 kpBqrEventQueue->Enqueue(p_bqr_event.release()); in AddLinkQualityEventToQueue()
/system/bt/main/shim/
Dl2c_api.cc252 buffer->second->Enqueue(std::move(packet), GetGdShimHandler()); in send()
940 buffer->second->Enqueue(std::move(packet), GetGdShimHandler()); in send()
1439 buffer->second->Enqueue(std::move(packet), GetGdShimHandler()); in send()
Dhci_layer.cc426 pending_data->Enqueue(std::move(acl_packet), in transmit_fragment()
/system/bt/gd/security/
Dpairing_handler_le.h133 i.proper_l2cap_interface->Enqueue(std::move(command), i.l2cap_handler); in SendL2capPacket()
/system/bt/gd/l2cap/classic/
Dfacade.cc384 enqueue_buffer_->Enqueue(std::move(packet_one), handler_); in SendPacket()