Lines Matching refs:atransport
66 static void remove_transport(atransport* transport);
67 static void transport_destroy(atransport* transport);
70 static auto& transport_list = *new std::list<atransport*>();
71 static auto& pending_list = *new std::list<atransport*>();
113 void TrackTransport(atransport* transport);
124 atransport* transport;
174 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
552 void send_packet(apacket* p, atransport* t) { in send_packet()
573 void kick_transport(atransport* t, bool reset) { in kick_transport()
689 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
727 atransport* transport;
779 atransport* t; in transport_registration_func()
885 void register_transport(atransport* transport) { in register_transport()
895 static void remove_transport(atransport* transport) { in remove_transport()
905 static void transport_destroy(atransport* t) { in transport_destroy()
980 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id, in acquire_one_transport()
983 atransport* result = nullptr; in acquire_one_transport()
1114 atransport::~atransport() { in ~atransport()
1121 int atransport::Write(apacket* p) { in Write()
1125 void atransport::Reset() { in Reset()
1132 void atransport::Kick() { in Kick()
1139 ConnectionState atransport::GetConnectionState() const { in GetConnectionState()
1143 void atransport::SetConnectionState(ConnectionState state) { in SetConnectionState()
1150 bool atransport::Attach(std::string* error) { in Attach()
1177 bool atransport::Detach(std::string* error) { in Detach()
1205 void atransport::SetConnection(std::shared_ptr<Connection> connection) { in SetConnection()
1210 bool atransport::HandleRead(std::unique_ptr<apacket> p) { in HandleRead()
1224 void atransport::HandleError(const std::string& error) { in HandleError()
1232 void atransport::update_version(int version, size_t payload) { in update_version()
1237 int atransport::get_protocol_version() const { in get_protocol_version()
1241 int atransport::get_tls_version() const { in get_tls_version()
1245 size_t atransport::get_max_payload() const { in get_max_payload()
1300 bool atransport::has_feature(const std::string& feature) const { in has_feature()
1304 void atransport::SetFeatures(const std::string& features_string) { in SetFeatures()
1308 void atransport::AddDisconnect(adisconnect* disconnect) { in AddDisconnect()
1312 void atransport::RemoveDisconnect(adisconnect* disconnect) { in RemoveDisconnect()
1316 void atransport::RunDisconnects() { in RunDisconnects()
1324 bool atransport::MatchesTarget(const std::string& target) const { in MatchesTarget()
1360 void atransport::SetConnectionEstablished(bool success) { in SetConnectionEstablished()
1364 ReconnectResult atransport::Reconnect() { in Reconnect()
1387 static void append_transport(const atransport* t, std::string* result, bool long_listing) { in append_transport()
1418 sorted_transport_list.sort([](atransport*& x, atransport*& y) { in list_transports()
1432 void close_usb_devices(std::function<bool(const atransport*)> predicate, bool reset) { in close_usb_devices()
1447 close_usb_devices([](const atransport*) { return true; }, reset); in close_usb_devices() argument
1452 atransport::ReconnectCallback reconnect, bool use_tls, int* error) { in register_socket_transport()
1453 atransport* t = new atransport(std::move(reconnect), kCsOffline); in register_socket_transport()
1515 atransport* find_transport(const char* serial) { in find_transport()
1516 atransport* result = nullptr; in find_transport()
1545 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport()
1566 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport()
1589 transport_list.remove_if([usb](atransport* t) { in unregister_usb_transport()
1595 bool check_header(apacket* p, atransport* t) { in check_header()
1612 std::shared_ptr<RSA> atransport::Key() { in Key()
1621 std::shared_ptr<RSA> atransport::NextKey() { in NextKey()
1635 void atransport::ResetKeys() { in ResetKeys()