Home
last modified time | relevance | path

Searched refs:enqueue_buffer_ (Results 1 – 14 of 14) sorted by relevance

/system/bt/gd/l2cap/internal/
Dbasic_mode_channel_data_controller.cc27 …: cid_(cid), remote_cid_(remote_cid), enqueue_buffer_(channel_queue_end), handler_(handler), sched… in BasicModeDataController()
31 enqueue_buffer_.Clear(); in ~BasicModeDataController()
46enqueue_buffer_.Enqueue(std::make_unique<PacketView<kLittleEndian>>(basic_frame_view.GetPayload())… in OnPdu()
Dle_credit_based_channel_data_controller.cc31 …: cid_(cid), remote_cid_(remote_cid), enqueue_buffer_(channel_queue_end), handler_(handler), sched… in LeCreditBasedDataController()
93enqueue_buffer_.Enqueue(std::make_unique<PacketView<kLittleEndian>>(reassembly_stage_), handler_); in OnPdu()
Dbasic_mode_channel_data_controller.h61 os::EnqueueBuffer<UpperEnqueue> enqueue_buffer_; variable
Dle_credit_based_channel_data_controller.h64 os::EnqueueBuffer<UpperEnqueue> enqueue_buffer_; variable
Denhanced_retransmission_mode_channel_data_controller.cc34 …: link_(link), cid_(cid), remote_cid_(remote_cid), enqueue_buffer_(channel_queue_end), handler_(ha… in ErtmController()
38 enqueue_buffer_.Clear(); in ~ErtmController()
978enqueue_buffer_.Enqueue(std::make_unique<packet::PacketView<kLittleEndian>>(payload), handler_); in stage_for_reassembly()
979 if (enqueue_buffer_.Size() == kEnqueueBufferBusyThreshold) { in stage_for_reassembly()
981enqueue_buffer_.NotifyOnEmpty(common::BindOnce(&impl::local_busy_clear, common::Unretained(pimpl_.… in stage_for_reassembly()
1021enqueue_buffer_.Enqueue(std::make_unique<packet::PacketView<kLittleEndian>>(reassembly_stage_), ha… in stage_for_reassembly()
1022 if (enqueue_buffer_.Size() == kEnqueueBufferBusyThreshold) { in stage_for_reassembly()
1024enqueue_buffer_.NotifyOnEmpty(common::BindOnce(&impl::local_busy_clear, common::Unretained(pimpl_.… in stage_for_reassembly()
Denhanced_retransmission_mode_channel_data_controller.h60 os::EnqueueBuffer<UpperEnqueue> enqueue_buffer_; variable
/system/bt/gd/l2cap/le/internal/
Dsignalling_manager.cc49 enqueue_buffer_ = in LeSignallingManager()
54 enqueue_buffer_.reset(); in ~LeSignallingManager()
104 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()
[all …]
Dsignalling_manager.h157 std::unique_ptr<os::EnqueueBuffer<packet::BasePacketBuilder>> enqueue_buffer_; variable
/system/bt/gd/l2cap/classic/internal/
Dsignalling_manager.cc64 enqueue_buffer_ = in ClassicSignallingManager()
72 enqueue_buffer_->Clear(); in ~ClassicSignallingManager()
73 enqueue_buffer_.reset(); in ~ClassicSignallingManager()
99 if (enqueue_buffer_.get() == nullptr) { in on_security_result_for_outgoing()
199 if (enqueue_buffer_.get() == nullptr) { in on_security_result_for_incoming()
338 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()
[all …]
Dsignalling_manager.h124 std::unique_ptr<os::EnqueueBuffer<packet::BasePacketBuilder>> enqueue_buffer_; variable
/system/bt/gd/l2cap/classic/
Dfacade.cc153 enqueue_buffer_.reset(); in ~L2capDynamicChannelHelper()
194enqueue_buffer_ = std::make_unique<os::EnqueueBuffer<BasePacketBuilder>>(channel_->GetQueueUpEnd()… in on_connection_open()
217 enqueue_buffer_.reset(); in on_close_callback()
255 enqueue_buffer_->Enqueue(std::move(packet_one), handler_); in SendPacket()
264 std::unique_ptr<os::EnqueueBuffer<BasePacketBuilder>> enqueue_buffer_ = nullptr; member in bluetooth::l2cap::classic::L2capClassicModuleFacadeService::L2capDynamicChannelHelper
/system/bt/gd/security/internal/
Dsecurity_manager_impl.h49 std::unique_ptr<os::EnqueueBuffer<packet::BasePacketBuilder>> enqueue_buffer_; member
67 stored_chan.enqueue_buffer_.reset(); in ~SecurityManagerImpl()
Dsecurity_manager_impl.cc441 auto& enqueue_buffer = stored_chan->enqueue_buffer_; in OnSmpCommandLe()
510 auto& enqueue_buffer = stored_channel->enqueue_buffer_; in ConnectionIsReadyStartPairing()
562 stored_chan->enqueue_buffer_.reset(); in OnConnectionClosedLe()
/system/bt/gd/os/linux_generic/
Dqueue_unittest.cc883 EnqueueBuffer<int> enqueue_buffer_{&enqueue_}; member in bluetooth::os::__anon494e39b60111::EnqueueBufferTest
891 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()
908 enqueue_buffer_.Clear(); in TEST_F()