Lines Matching refs:transport
57 static void remove_transport(atransport* transport);
58 static void transport_unref(atransport* transport);
93 void TrackTransport(atransport* transport);
104 atransport* transport; member
110 return reinterpret_cast<uintptr_t>(transport) < in operator <()
111 reinterpret_cast<uintptr_t>(rhs.transport); in operator <()
150 remove_transport(attempt.transport); in Stop()
154 void ReconnectHandler::TrackTransport(atransport* transport) { in TrackTransport() argument
162 ReconnectAttempt{transport, reconnect_time, ReconnectHandler::kMaxAttempts}); in TrackTransport()
194 if (it->transport->kicked()) { in Run()
195 D("transport %s was kicked. giving up on it.", it->transport->serial.c_str()); in Run()
196 remove_transport(it->transport); in Run()
216 D("attempting to reconnect %s", attempt.transport->serial.c_str()); in Run()
218 switch (attempt.transport->Reconnect()) { in Run()
220 D("attempting to reconnect %s failed.", attempt.transport->serial.c_str()); in Run()
223 attempt.transport->serial.c_str()); in Run()
224 remove_transport(attempt.transport); in Run()
230 attempt.transport, in Run()
237 D("reconnection to %s succeeded.", attempt.transport->serial.c_str()); in Run()
238 register_transport(attempt.transport); in Run()
242 D("cancelling reconnection attempt to %s.", attempt.transport->serial.c_str()); in Run()
243 remove_transport(attempt.transport); in Run()
610 atransport* transport; member
662 t = m.transport; in transport_registration_func()
757 void register_transport(atransport* transport) { in register_transport() argument
759 m.transport = transport; in register_transport()
761 D("transport: %s registered", transport->serial.c_str()); in register_transport()
767 static void remove_transport(atransport* transport) { in remove_transport() argument
769 m.transport = transport; in remove_transport()
771 D("transport: %s removed", transport->serial.c_str()); in remove_transport()
1245 for (const auto& transport : pending_list) { in register_socket_transport() local
1246 if (serial == transport->serial) { in register_socket_transport()
1247 VLOG(TRANSPORT) << "socket transport " << transport->serial in register_socket_transport()
1255 for (const auto& transport : transport_list) { in register_socket_transport() local
1256 if (serial == transport->serial) { in register_socket_transport()
1257 VLOG(TRANSPORT) << "socket transport " << transport->serial in register_socket_transport()