Home
last modified time | relevance | path

Searched refs:Enqueue (Results 1 – 21 of 21) 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()
139 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
147 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
312 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnDisconnectionRequest()
447 enqueue_buffer_->Enqueue(std::move(builder), handler_); in on_incoming_packet()
457 enqueue_buffer_->Enqueue(std::move(builder), handler_); in send_connection_response()
491 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
498 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
506 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/l2cap/classic/internal/
Dsignalling_manager.cc338 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnConfigurationRequest()
371 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnConfigurationRequest()
590 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnDisconnectionRequest()
633 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnEchoRequest()
653 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
660 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
666 enqueue_buffer_->Enqueue(std::move(response), handler_); in OnInformationRequest()
832 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_one_command()
841 enqueue_buffer_->Enqueue(std::move(builder), handler_); in send_connection_response()
895 enqueue_buffer_->Enqueue(std::move(builder), handler_); in handle_send_next_command()
[all …]
/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.cc401 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/core/adb/daemon/
Dservices.cpp168 return static_cast<ServiceSocket*>(self)->Enqueue(std::move(data)); in ServiceSocket()
175 virtual int Enqueue(apacket::payload_type data) { return -1; } in Enqueue() function
199 virtual int Enqueue(apacket::payload_type data) override final { in Enqueue() function
234 int Enqueue(apacket::payload_type data) { return -1; } in Enqueue() function
/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/l2cap/classic/
Dfacade.cc255 enqueue_buffer_->Enqueue(std::move(packet_one), handler_); in SendPacket()
/system/bt/gd/security/
Dpairing_handler_le.h133 i.proper_l2cap_interface->Enqueue(std::move(command), i.l2cap_handler); in SendL2capPacket()
/system/bt/btif/src/
Dbtif_bqr.cc411 kpBqrEventQueue->Enqueue(p_bqr_event.release()); in AddLinkQualityEventToQueue()
/system/bt/gd/hci/
Dhci_layer.cc239 module_.impl_->incoming_acl_buffer_.Enqueue(move(acl), module_.GetHandler()); in aclDataReceived()
/system/bt/main/shim/
Dl2c_api.cc318 buffer->second->Enqueue(std::move(packet), in send()