Lines Matching refs:connection
56 for (auto& connection : acl_connections_) { in ~AclManagerFacadeService() local
57 connection.second.connection_->GetAclQueueEnd()->UnregisterDequeue(); in ~AclManagerFacadeService()
79 auto connection = acl_connections_.find(request->handle()); in Disconnect() local
80 if (connection == acl_connections_.end()) { in Disconnect()
84 … connection->second.connection_->Disconnect(DisconnectReason::REMOTE_USER_TERMINATED_CONNECTION); in Disconnect()
92 auto connection = acl_connections_.find(request->handle()); in AuthenticationRequested() local
93 if (connection == acl_connections_.end()) { in AuthenticationRequested()
97 connection->second.connection_->AuthenticationRequested(); in AuthenticationRequested()
103 std::map<uint16_t, Connection>::iterator connection; \
109 connection = acl_connections_.find(view.GetConnectionHandle()); \
110 if (connection == acl_connections_.end()) { \
128 connection->second.connection_->AuthenticationRequested(); in ConnectionCommand()
134 connection->second.connection_->Disconnect(view.GetReason()); in ConnectionCommand()
140 connection->second.connection_->ChangeConnectionPacketType(view.GetPacketType()); in ConnectionCommand()
146 connection->second.connection_->SetConnectionEncryption(view.GetEncryptionEnable()); in ConnectionCommand()
151 connection->second.connection_->ChangeConnectionLinkKey(); in ConnectionCommand()
156 connection->second.connection_->ReadClockOffset(); in ConnectionCommand()
162 …connection->second.connection_->HoldMode(view.GetHoldModeMaxInterval(), view.GetHoldModeMinInterva… in ConnectionCommand()
168 connection->second.connection_->SniffMode( in ConnectionCommand()
174 connection->second.connection_->ExitSniffMode(); in ConnectionCommand()
179 connection->second.connection_->Flush(); in ConnectionCommand()
184 connection->second.connection_->ReadAutomaticFlushTimeout(); in ConnectionCommand()
190 connection->second.connection_->WriteAutomaticFlushTimeout(view.GetFlushTimeout()); in ConnectionCommand()
196 connection->second.connection_->ReadTransmitPowerLevel(view.GetTransmitPowerLevelType()); in ConnectionCommand()
201 connection->second.connection_->ReadLinkSupervisionTimeout(); in ConnectionCommand()
207 … connection->second.connection_->WriteLinkSupervisionTimeout(view.GetLinkSupervisionTimeout()); in ConnectionCommand()
212 connection->second.connection_->ReadFailedContactCounter(); in ConnectionCommand()
217 connection->second.connection_->ResetFailedContactCounter(); in ConnectionCommand()
222 connection->second.connection_->ReadLinkQuality(); in ConnectionCommand()
227 connection->second.connection_->ReadAfhChannelMap(); in ConnectionCommand()
232 connection->second.connection_->ReadRssi(); in ConnectionCommand()
238 connection->second.connection_->ReadClock(view.GetWhichClock()); in ConnectionCommand()
243 connection->second.connection_->ReadRemoteVersionInformation(); in ConnectionCommand()
248 connection->second.connection_->ReadRemoteSupportedFeatures(); in ConnectionCommand()
254 connection->second.connection_->ReadRemoteExtendedFeatures(page_number); in ConnectionCommand()
281 auto connection = acl_connections_.find(request->handle()); in SendAclData() local
282 if (connection == acl_connections_.end()) { in SendAclData()
286 connection->second.connection_->GetAclQueueEnd()->RegisterEnqueue( in SendAclData()
302 auto connection = acl_connections_.find(request->handle()); in enqueue_packet() local
303 ASSERT_LOG(connection != acl_connections_.end(), "handle %d", request->handle()); in enqueue_packet()
304 connection->second.connection_->GetAclQueueEnd()->UnregisterEnqueue(); in enqueue_packet()
313 auto connection = acl_connections_.find(request->handle()); in FetchAclData() local
314 if (connection == acl_connections_.end()) { in FetchAclData()
317 return connection->second.pending_acl_data_.RunLoop(context, writer); in FetchAclData()
331 void on_incoming_acl(std::shared_ptr<ClassicAclConnection> connection, uint16_t handle) { in on_incoming_acl() argument
332 auto packet = connection->GetAclQueueEnd()->TryDequeue(); in on_incoming_acl()
341 void OnConnectSuccess(std::unique_ptr<ClassicAclConnection> connection) override { in OnConnectSuccess() argument
343 std::shared_ptr<ClassicAclConnection> shared_connection = std::move(connection); in OnConnectSuccess()
384 std::shared_ptr<ClassicAclConnection> connection, in Connection() argument
386 … : handle_(handle), connection_(std::move(connection)), event_stream_(std::move(event_stream)) {} in Connection()