Searched refs:Connection (Results 1 – 13 of 13) sorted by relevance
/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 | 76 struct Connection { struct 77 Connection() = default; 78 virtual ~Connection() = default; 84 using ReadCallback = std::function<bool(Connection*, std::unique_ptr<apacket>)>; argument 91 using ErrorCallback = std::function<void(Connection*, const std::string&)>; argument 109 static std::unique_ptr<Connection> FromFd(unique_fd fd); argument 135 struct BlockingConnectionAdapter : public Connection { 256 void SetConnection(std::unique_ptr<Connection> connection); 257 std::shared_ptr<Connection> connection() { in connection() 357 std::shared_ptr<Connection> connection_ GUARDED_BY(mutex_);
|
D | transport_fd.cpp | 46 struct NonblockingFdConnection : public Connection { 235 std::unique_ptr<Connection> Connection::FromFd(unique_fd fd) { in FromFd()
|
D | transport.cpp | 260 void Connection::Reset() { in Reset() 684 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func() argument 697 t->connection()->SetErrorCallback([t](Connection*, const std::string& error) { in transport_registration_func() argument 997 void atransport::SetConnection(std::unique_ptr<Connection> connection) { in SetConnection() 999 connection_ = std::shared_ptr<Connection>(std::move(connection)); in SetConnection()
|
/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() argument 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 | 138 std::shared_ptr<Connection> connection; in SendResponse() 287 std::shared_ptr<Connection> connection(new Connection(conn_id, bda)); in ConnectionCallback() 543 std::shared_ptr<GattServer::Connection> GattServer::GetConnection( in GetConnection()
|
/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 | 61 class Connection(object): class 91 self._connection = Connection(port)
|
/system/bt/doc/ |
D | pts_guide.md | 36 - `PTS_DisableConnUpdates` disables LE Connection updates.
|
/system/bt/vendor_libs/test_vendor_lib/model/controller/ |
D | link_layer_controller.cc | 487 std::shared_ptr<Connection> new_connection = in IncomingLeAdvertisementPacket() 488 std::make_shared<Connection>(remote_devices_[dev], handle); in IncomingLeAdvertisementPacket() 508 std::shared_ptr<Connection> new_connection = in IncomingLeAdvertisementPacket() 509 std::make_shared<Connection>(remote_devices_[dev], handle); in IncomingLeAdvertisementPacket()
|
/system/core/adb/daemon/ |
D | usb.cpp | 171 struct UsbFfsConnection : public Connection {
|