Lines Matching refs:connection
265 BlockingConnectionAdapter::BlockingConnectionAdapter(std::unique_ptr<BlockingConnection> connection) in BlockingConnectionAdapter() argument
266 : underlying_(std::move(connection)) {} in BlockingConnectionAdapter()
683 t->connection()->SetTransportName(t->serial_name()); in transport_registration_func()
684 t->connection()->SetReadCallback([t](Connection*, std::unique_ptr<apacket> p) { in transport_registration_func()
697 t->connection()->SetErrorCallback([t](Connection*, const std::string& error) { in transport_registration_func()
705 t->connection()->Start(); in transport_registration_func()
786 t->connection()->Stop(); in transport_unref()
971 return this->connection()->Write(std::unique_ptr<apacket>(p)) ? 0 : -1; in Write()
977 this->connection()->Reset(); in Reset()
984 this->connection()->Stop(); in Kick()
997 void atransport::SetConnection(std::unique_ptr<Connection> connection) { in SetConnection() argument
999 connection_ = std::shared_ptr<Connection>(std::move(connection)); in SetConnection()