Lines Matching refs:atransport

70 static void remove_transport(atransport* transport);
71 static void transport_destroy(atransport* transport);
74 static auto& transport_list = *new std::list<atransport*>();
75 static auto& pending_list = *new std::list<atransport*>();
121 void TrackTransport(atransport* transport);
132 atransport* transport;
182 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport()
560 void send_packet(apacket* p, atransport* t) { in send_packet()
581 void kick_transport(atransport* t, bool reset) { in kick_transport()
693 bool iterate_transports(std::function<bool(const atransport*)> fn) { in iterate_transports()
738 static void fdevent_unregister_transport(atransport* t) { in fdevent_unregister_transport()
751 static void fdevent_register_transport(atransport* t) { in fdevent_register_transport()
820 void register_transport(atransport* transport) { in register_transport()
825 static void remove_transport(atransport* transport) { in remove_transport()
830 static void transport_destroy(atransport* t) { in transport_destroy()
905 atransport* acquire_one_transport(TransportType type, const char* serial, TransportId transport_id, in acquire_one_transport()
908 atransport* result = nullptr; in acquire_one_transport()
1039 atransport::~atransport() { in ~atransport()
1046 int atransport::Write(apacket* p) { in Write()
1050 void atransport::Reset() { in Reset()
1057 void atransport::Kick() { in Kick()
1064 ConnectionState atransport::GetConnectionState() const { in GetConnectionState()
1068 void atransport::SetConnectionState(ConnectionState state) { in SetConnectionState()
1075 bool atransport::Attach(std::string* error) { in Attach()
1102 bool atransport::Detach(std::string* error) { in Detach()
1130 void atransport::SetConnection(std::shared_ptr<Connection> connection) { in SetConnection()
1135 bool atransport::HandleRead(std::unique_ptr<apacket> p) { in HandleRead()
1151 void atransport::HandleError(const std::string& error) { in HandleError()
1159 void atransport::update_version(int version, size_t payload) { in update_version()
1164 int atransport::get_protocol_version() const { in get_protocol_version()
1168 int atransport::get_tls_version() const { in get_tls_version()
1172 size_t atransport::get_max_payload() const { in get_max_payload()
1250 bool atransport::has_feature(const std::string& feature) const { in has_feature()
1254 void atransport::SetFeatures(const std::string& features_string) { in SetFeatures()
1259 void atransport::AddDisconnect(adisconnect* disconnect) { in AddDisconnect()
1263 void atransport::RemoveDisconnect(adisconnect* disconnect) { in RemoveDisconnect()
1267 void atransport::RunDisconnects() { in RunDisconnects()
1275 bool atransport::MatchesTarget(const std::string& target) const { in MatchesTarget()
1311 void atransport::SetConnectionEstablished(bool success) { in SetConnectionEstablished()
1315 ReconnectResult atransport::Reconnect() { in Reconnect()
1358 static std::string transportListToProto(const std::list<atransport*>& sorted_transport_list, in transportListToProto()
1396 static void append_transport(const atransport* t, std::string* result, bool long_listing) { in append_transport()
1423 static std::string transportListToText(const std::list<atransport*>& sorted_transport_list, in transportListToText()
1436 sorted_transport_list.sort([](atransport*& x, atransport*& y) { in list_transports()
1455 void close_usb_devices(std::function<bool(const atransport*)> predicate, bool reset) { in close_usb_devices()
1470 close_usb_devices([](const atransport*) { return true; }, reset); in close_usb_devices() argument
1474 bool validate_transport_list(const std::list<atransport*>& list, const std::string& serial, in validate_transport_list()
1475 atransport* t, int* error) { in validate_transport_list()
1490 atransport::ReconnectCallback reconnect, bool use_tls, int* error) { in register_socket_transport()
1491 atransport* t = new atransport(std::move(reconnect), kCsOffline); in register_socket_transport()
1541 atransport* find_transport(const char* serial) { in find_transport()
1542 atransport* result = nullptr; in find_transport()
1572 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport()
1593 atransport* t = new atransport(writeable ? kCsOffline : kCsNoPerm); in register_usb_transport()
1616 transport_list.remove_if([usb](atransport* t) { in unregister_usb_transport()
1628 void atransport::UpdateReverseConfig(std::string_view service_addr) { in UpdateReverseConfig()
1668 bool atransport::IsReverseConfigured(const std::string& local_addr) { in IsReverseConfigured()
1680 bool check_header(apacket* p, atransport* t) { in check_header()
1697 std::shared_ptr<RSA> atransport::Key() { in Key()
1706 std::shared_ptr<RSA> atransport::NextKey() { in NextKey()
1720 void atransport::ResetKeys() { in ResetKeys()