| /system/core/adb/ |
| D | transport_benchmark.cpp | 41 std::unique_ptr<Connection> MakeConnection(unique_fd fd);
44 std::unique_ptr<Connection> MakeConnection<FdConnection>(unique_fd fd) { in MakeConnection()
50 std::unique_ptr<Connection> MakeConnection<NonblockingFdConnection>(unique_fd fd) { in MakeConnection()
51 return Connection::FromFd(std::move(fd)); in MakeConnection()
66 client->SetReadCallback([](Connection*, std::unique_ptr<apacket>) -> bool { return true; }); in BM_Connection_Unidirectional() argument
67 … server->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Unidirectional() argument
73 [](Connection*, const std::string& error) { LOG(INFO) << "client closed: " << error; }); in BM_Connection_Unidirectional() argument
75 [](Connection*, const std::string& error) { LOG(INFO) << "server closed: " << error; }); in BM_Connection_Unidirectional() argument
124 … client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo() argument
129 static const auto handle_packet = [](Connection* connection, std::unique_ptr<apacket> packet) { in BM_Connection_Echo()
[all …]
|
| D | transport.h | 104 struct Connection { struct
105 Connection() = default;
106 virtual ~Connection() = default;
112 using ReadCallback = std::function<bool(Connection*, std::unique_ptr<apacket>)>; argument
119 using ErrorCallback = std::function<void(Connection*, const std::string&)>; argument
139 static std::unique_ptr<Connection> FromFd(unique_fd fd); argument
167 struct BlockingConnectionAdapter : public Connection {
291 void SetConnection(std::unique_ptr<Connection> connection);
292 std::shared_ptr<Connection> connection() { in connection()
409 std::shared_ptr<Connection> connection_ GUARDED_BY(mutex_);
|
| D | transport_fd.cpp | 46 struct NonblockingFdConnection : public Connection {
239 std::unique_ptr<Connection> Connection::FromFd(unique_fd fd) { in FromFd()
|
| D | transport.cpp | 274 void Connection::Reset() { in Reset()
796 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func() argument
809 t->connection()->SetErrorCallback([t](Connection*, const std::string& error) { in transport_registration_func() argument
1124 void atransport::SetConnection(std::unique_ptr<Connection> connection) { in SetConnection()
1126 connection_ = std::shared_ptr<Connection>(std::move(connection)); in SetConnection()
|
| D | adb.cpp | 324 ADB_LOG(Connection) << "received CNXN: version=" << p->msg.arg0 << ", maxdata = " << p->msg.arg1 in handle_new_connection()
|
| /system/bt/service/ |
| D | gatt_server.h | 171 struct Connection { struct
172 Connection(int conn_id, const RawAddress& bdaddr) in Connection() function
174 Connection() : conn_id(-1) { memset(&bdaddr, 0, sizeof(bdaddr)); } in Connection() function
236 std::shared_ptr<Connection> GetConnection(int conn_id, const RawAddress& bda,
251 std::unordered_map<int, std::shared_ptr<Connection>> conn_id_map_;
252 std::unordered_map<std::string, std::vector<std::shared_ptr<Connection>>>
|
| D | gatt_server.cc | 140 std::shared_ptr<Connection> connection; in SendResponse()
289 std::shared_ptr<Connection> connection(new Connection(conn_id, bda)); in ConnectionCallback()
545 std::shared_ptr<GattServer::Connection> GattServer::GetConnection( in GetConnection()
|
| /system/core/adb/daemon/ |
| D | logging.cpp | 50 result[adb::LogType::Connection] = true; in ParseLogStatus()
56 result[adb::LogType::Connection] = true; in ParseLogStatus()
|
| D | logging.h | 23 Connection, enumerator
|
| D | usb.cpp | 172 struct UsbFfsConnection : public Connection {
|
| /system/bt/vendor_libs/test_vendor_lib/scripts/ |
| D | simple_stack.py | 107 class Connection(object): class
136 self._connection = Connection(port)
|
| D | simple_link_layer_socket.py | 73 class Connection(object): class
103 self._connection = Connection(port)
|
| D | send_simple_commands.py | 87 class Connection(object): class
117 self._connection = Connection(port)
|
| D | test_channel.py | 62 class Connection(object): class
92 self._connection = Connection(port)
|
| /system/bt/gd/hci/facade/ |
| D | le_acl_manager_facade.cc | 107 std::map<uint16_t, Connection>::iterator connection; \
261 class Connection : public LeConnectionManagementCallbacks { class in bluetooth::hci::facade::LeAclManagerFacadeService
263 Connection( in Connection() function in bluetooth::hci::facade::LeAclManagerFacadeService::Connection
301 std::map<uint16_t, Connection> acl_connections_;
|
| D | acl_manager_facade.cc | 101 std::map<uint16_t, Connection>::iterator connection; \
368 class Connection : public ConnectionManagementCallbacks { class in bluetooth::hci::facade::AclManagerFacadeService
370 Connection( in Connection() function in bluetooth::hci::facade::AclManagerFacadeService::Connection
508 std::map<uint16_t, Connection> acl_connections_;
|
| /system/bt/doc/ |
| D | pts_guide.md | 36 - `PTS_DisableConnUpdates` disables LE Connection updates.
|