| /system/bt/stack/btm/ |
| D | btm_ble_bgconn.cc | 75 BackgroundConnection* connection = &map_iter->second; in background_connection_add() local
76 if (addr_type != connection->addr_type) { in background_connection_add()
79 connection->addr_type_in_wl, connection->address, in background_connection_add()
81 connection->addr_type = addr_type; in background_connection_add()
82 connection->in_controller_wl = false; in background_connection_add()
84 connection->pending_removal = false; in background_connection_add()
103 BackgroundConnection* connection = &map_el.second; in background_connections_pending() local
104 if (connection->pending_removal) continue; in background_connections_pending()
106 BTM_IsAclConnectionUp(connection->address, BT_TRANSPORT_LE); in background_connections_pending()
165 BackgroundConnection* connection = &map_it->second; in btm_ble_bgconn_cancel_if_disconnected() local
[all …]
|
| /system/bt/gd/hci/facade/ |
| D | acl_manager_facade.cc | 54 for (auto& connection : acl_connections_) { in ~AclManagerFacadeService() local
55 connection.second.connection_->GetAclQueueEnd()->UnregisterDequeue(); in ~AclManagerFacadeService()
77 auto connection = acl_connections_.find(request->handle()); in Disconnect() local
78 if (connection == acl_connections_.end()) { in Disconnect()
82 … connection->second.connection_->Disconnect(DisconnectReason::REMOTE_USER_TERMINATED_CONNECTION); in Disconnect()
90 auto connection = acl_connections_.find(request->handle()); in AuthenticationRequested() local
91 if (connection == acl_connections_.end()) { in AuthenticationRequested()
95 connection->second.connection_->AuthenticationRequested(); in AuthenticationRequested()
101 std::map<uint16_t, Connection>::iterator connection; \
107 connection = acl_connections_.find(view.GetConnectionHandle()); \
[all …]
|
| D | le_acl_manager_facade.cc | 96 auto connection = acl_connections_.find(request->handle()); in Disconnect() local
97 if (connection == acl_connections_.end()) { in Disconnect()
101 … connection->second.connection_->Disconnect(DisconnectReason::REMOTE_USER_TERMINATED_CONNECTION); in Disconnect()
107 std::map<uint16_t, Connection>::iterator connection; \
113 connection = acl_connections_.find(view.GetConnectionHandle()); \
114 if (connection == acl_connections_.end()) { \
132 connection->second.connection_->Disconnect(view.GetReason()); in ConnectionCommand()
159 auto connection = acl_connections_.find(request->handle()); in SendAclData() local
160 if (connection == acl_connections_.end()) { in SendAclData()
163 connection->second.connection_->GetAclQueueEnd()->RegisterEnqueue( in SendAclData()
[all …]
|
| /system/bt/gd/cert/ |
| D | py_le_acl_manager.py | 85 for connection in self.active_connections:
86 safeClose(connection)
119 …connection = PyLeAclManagerAclConnection(self.le_acl_manager, address, remote, handle, event_strea…
120 self.active_connections.append(connection)
121 return connection
|
| /system/bt/gd/shim/ |
| D | l2cap.cc | 240 …nnectionClosed(ConnectionInterfaceDescriptor cid, std::unique_ptr<ConnectionInterface> connection);
276 ConnectionInterfaceDescriptor cid, std::unique_ptr<ConnectionInterface> connection) { in ConnectionClosed() argument
289 auto connection = std::move(cid_to_interface_map_.at(cid)); in AddConnection() local
291 …nnectionInterfaceManager::ConnectionClosed, common::Unretained(this), cid, std::move(connection))); in AddConnection()
434 std::unique_ptr<PendingConnection> connection,
438 std::unique_ptr<PendingConnection> connection,
533 std::unique_ptr<PendingConnection> connection, in PendingConnectionOpen() argument
536 connection_interface_manager_.AddConnection(connection->cid_, std::move(channel)); in PendingConnectionOpen()
538 std::move(connection->on_complete_), connection->psm_, connection->cid_, remote_cid); in PendingConnectionOpen()
544 std::unique_ptr<PendingConnection> connection, in PendingConnectionFail() argument
[all …]
|
| /system/core/adb/ |
| D | transport_benchmark.cpp | 129 static const auto handle_packet = [](Connection* connection, std::unique_ptr<apacket> packet) { in BM_Connection_Echo() argument
130 connection->Write(std::move(packet)); in BM_Connection_Echo()
133 server->SetReadCallback([](Connection* connection, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo() argument
136 fdevent_run_on_main_thread([connection, raw_packet]() { in BM_Connection_Echo()
138 handle_packet(connection, std::move(packet)); in BM_Connection_Echo()
141 handle_packet(connection, std::move(packet)); in BM_Connection_Echo()
|
| D | protocol.txt | 42 connection. The protocol depends on shared state and any break in the
70 Both sides send a CONNECT message when the connection between them is
75 large maxdata value, the connection with the other side must be closed.
86 The TLS message informs the recipient that the connection will be encrypted
120 the connection has been established (and identifying the other end) or
150 is used to establish the connection). Nonetheless, the local-id MUST
169 the connection.
176 The CLOSE message informs recipient that the connection between the
197 outbound messages are discarded when the connection to the remote side
201 * when the connection to the remote side goes offline, the io pump
[all …]
|
| D | SERVICES.TXT | 21 the connection is closed
25 connection. Instead, a new device list description is sent
42 Ask to switch the connection to the device/emulator identified by
48 Ask to switch the connection to one device connected through USB
53 Ask to switch the connection to one emulator connected through TCP.
58 Another host:transport variant. Ask to switch the connection to
105 tcp:<port> -> TCP connection on localhost:<port>
118 fail it there is already a forward connection from <local>.
123 Remove any existing forward local connection from <local>.
217 the framebuffer device, the connection is simply closed immediately.
|
| D | SOCKET-ACTIVATION.txt | 32 automatically on any connection to 127.0.0.1:5037 (the default adb
42 serve socket, not the accepted connection socket.
|
| D | OVERVIEW.TXT | 72 its role is to initiate the connection, then of being a pass-through
106 Note that the connection is still alive after an OKAY, which allows the
108 change the state of the connection.
120 An ADB transport models a connection between the ADB server and one device
129 a connection between an ADB server and a device/emulator connected to/
|
| D | transport.cpp | 279 BlockingConnectionAdapter::BlockingConnectionAdapter(std::unique_ptr<BlockingConnection> connection) in BlockingConnectionAdapter() argument
280 : underlying_(std::move(connection)) {} in BlockingConnectionAdapter()
795 t->connection()->SetTransportName(t->serial_name()); in transport_registration_func()
796 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func()
809 t->connection()->SetErrorCallback([t](Connection*, const std::string& error) { in transport_registration_func()
817 t->connection()->Start(); in transport_registration_func()
915 t->connection()->Stop(); in transport_destroy()
1098 return this->connection()->Write(std::unique_ptr<apacket>(p)) ? 0 : -1; in Write()
1104 this->connection()->Reset(); in Reset()
1111 this->connection()->Stop(); in Kick()
[all …]
|
| /system/bt/gd/hci/acl_manager/ |
| D | le_impl.h | 94 auto& connection = le_acl_connections_.find(handle)->second; in on_le_disconnect() local
96 connection.le_connection_management_callbacks_->OnDisconnection(reason); in on_le_disconnect()
154 …std::unique_ptr<LeAclConnection> connection(new LeAclConnection(std::move(queue), le_acl_connectio… in on_le_connection_complete()
157 connection_proxy.le_connection_management_callbacks_ = connection->GetEventCallbacks(); in on_le_connection_complete()
160 std::move(connection))); in on_le_connection_complete()
208 …std::unique_ptr<LeAclConnection> connection(new LeAclConnection(std::move(queue), le_acl_connectio… in on_le_enhanced_connection_complete()
211 connection_proxy.le_connection_management_callbacks_ = connection->GetEventCallbacks(); in on_le_enhanced_connection_complete()
214 std::move(connection))); in on_le_enhanced_connection_complete()
233 auto& connection = le_acl_connections_.find(handle)->second; in on_le_connection_update_complete() local
234 connection.le_connection_management_callbacks_->OnConnectionUpdate( in on_le_connection_update_complete()
[all …]
|
| D | classic_impl.h | 114 auto& connection = acl_connections_.find(handle)->second; in on_classic_disconnect() local
116 connection.connection_management_callbacks_->OnDisconnection(reason); in on_classic_disconnect()
156 for (const auto& connection : acl_connections_) { in is_classic_link_already_connected() local
157 if (connection.second.address_with_type_.GetAddress() == address) { in is_classic_link_already_connected()
216 std::unique_ptr<ClassicAclConnection> connection( in on_connection_complete()
219 connection_proxy.connection_management_callbacks_ = connection->GetEventCallbacks(); in on_connection_complete()
222 … common::Unretained(client_callbacks_), std::move(connection))); in on_connection_complete()
489 auto connection = acl_connections_.find(handle); in check_and_get_connection() local
490 ASSERT(connection != acl_connections_.end()); in check_and_get_connection()
491 return connection->second; in check_and_get_connection()
|
| /system/bt/vendor_libs/test_vendor_lib/model/controller/ |
| D | acl_connection_handler.cc | 78 auto connection = std::get<AclConnection>(pair); in CreatePendingLeConnection() local
79 if (connection.GetAddress() == addr) { in CreatePendingLeConnection()
188 auto connection = acl_connections_.at(handle); in SetAddress() local
189 connection.SetAddress(address); in SetAddress()
|
| /system/bt/service/ |
| D | gatt_server.cc | 140 std::shared_ptr<Connection> connection; in SendResponse() local
146 connection = tmp; in SendResponse()
149 if (!connection) { in SendResponse()
160 int handle = connection->request_id_to_handle[request_id]; in SendResponse()
172 ->send_response(connection->conn_id, request_id, error, response); in SendResponse()
178 connection->request_id_to_handle.erase(request_id); in SendResponse()
289 std::shared_ptr<Connection> connection(new Connection(conn_id, bda)); in ConnectionCallback() local
290 conn_id_map_[conn_id] = connection; in ConnectionCallback()
291 conn_addr_map_[device_address].push_back(connection); in ConnectionCallback()
|
| D | low_energy_client.cc | 181 for (auto& connection : connection_ids_) { in MtuChangedCallback() local
182 if (connection.second == conn_id) { in MtuChangedCallback()
183 bda = &connection.first; in MtuChangedCallback()
|
| /system/core/adb/client/pairing/tests/ |
| D | pairing_server.cpp | 318 auto [ufd, connection] = std::move(*p); in connectionEventsWorker()
320 bool started = connection->start( in connectionEventsWorker()
344 connections_[fd] = std::move(connection); in connectionEventsWorker()
382 auto connection = PairingConnection::create(PairingConnection::Role::Server, pswd_, peer_info_, in handleNewClientConnection() local
384 if (connection == nullptr) { in handleNewClientConnection()
389 NewConnectionEvent event = std::make_tuple(std::move(ufd), std::move(connection)); in handleNewClientConnection()
|
| /system/core/adb/pairing_connection/ |
| D | pairing_server.cpp | 362 auto [ufd, connection] = std::move(*p); in ConnectionEventsWorker()
364 bool started = pairing_connection_start(connection.get(), fd, in ConnectionEventsWorker()
370 connections_[fd] = std::move(connection); in ConnectionEventsWorker()
413 auto connection = CreatePairingConnection(pswd_, peer_info_, cert_, priv_key_); in HandleNewClientConnection() local
414 if (connection == nullptr) { in HandleNewClientConnection()
419 NewConnectionEvent event = std::make_tuple(std::move(ufd), std::move(connection)); in HandleNewClientConnection()
|
| /system/core/adb/client/ |
| D | transport_usb.cpp | 195 auto connection = std::make_unique<UsbConnection>(h); in init_usb_transport() local
196 t->SetConnection(std::make_unique<BlockingConnectionAdapter>(std::move(connection))); in init_usb_transport()
|
| /system/sepolicy/prebuilts/api/26.0/private/ |
| D | incident.te | 12 # connection.
|
| /system/sepolicy/prebuilts/api/27.0/public/ |
| D | vr_hwc.te | 25 # Allow connection to VR DisplayClient to get the primary display metadata
|
| /system/sepolicy/prebuilts/api/26.0/public/ |
| D | vr_hwc.te | 25 # Allow connection to VR DisplayClient to get the primary display metadata
|
| /system/sepolicy/prebuilts/api/27.0/private/ |
| D | incident.te | 12 # connection.
|
| /system/sepolicy/prebuilts/api/28.0/public/ |
| D | vr_hwc.te | 25 # Allow connection to VR DisplayClient to get the primary display metadata
|
| /system/sepolicy/prebuilts/api/30.0/public/ |
| D | vr_hwc.te | 25 # Allow connection to VR DisplayClient to get the primary display metadata
|