69         if (peer_id == 0 || (s->peer && s->peer->id == peer_id)) {  in find_local_socket()
106         if (s->transport == t || (s->peer && s->peer->transport == t)) {  in close_all_sockets()
181     if (avail != max_payload && s->peer) {  in local_socket_flush_outgoing()
188         r = s->peer->enqueue(s->peer, std::move(data));  in local_socket_flush_outgoing()
315     if (s->peer) {  in local_socket_close()
316         D("LS(%d): closing peer. peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);  in local_socket_close()
321         if (s->peer->shutdown) {  in local_socket_close()
322             s->peer->shutdown(s->peer);  in local_socket_close()
324         s->peer->peer = nullptr;  in local_socket_close()
325         s->peer->close(s->peer);  in local_socket_close()
326         s->peer = nullptr;  in local_socket_close()
366                 s->peer->ready(s->peer);  in local_socket_event_func()
430     D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);  in remote_socket_enqueue()
434     p->msg.arg0 = s->peer->id;  in remote_socket_enqueue()
450     D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);  in remote_socket_ready()
453     p->msg.arg0 = s->peer->id;  in remote_socket_ready()
460       s->peer ? s->peer->fd : -1);  in remote_socket_shutdown()
463     if (s->peer) {  in remote_socket_shutdown()
464         p->msg.arg0 = s->peer->id;  in remote_socket_shutdown()
471     if (s->peer) {  in remote_socket_close()
472         s->peer->peer = nullptr;  in remote_socket_close()
473         D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);  in remote_socket_close()
474         s->peer->close(s->peer);  in remote_socket_close()
477       s->peer ? s->peer->fd : -1);  in remote_socket_close()
790                 s->peer->fd, s);  in smart_socket_enqueue()
814             SendFail(s->peer->fd, "unknown host service");  in smart_socket_enqueue()
825         SendOkay(s->peer->fd);  in smart_socket_enqueue()
827         s->peer->ready = local_socket_ready;  in smart_socket_enqueue()
828         s->peer->shutdown = nullptr;  in smart_socket_enqueue()
829         s->peer->close = local_socket_close;  in smart_socket_enqueue()
830         s->peer->peer = s2;  in smart_socket_enqueue()
831         s2->peer = s->peer;  in smart_socket_enqueue()
832         s->peer = nullptr;  in smart_socket_enqueue()
845             SendFail(s->peer->fd, error_msg);  in smart_socket_enqueue()
852         SendFail(s->peer->fd, "device offline (no transport)");  in smart_socket_enqueue()
858         SendFail(s->peer->fd, "device offline (transport offline)");  in smart_socket_enqueue()
867     s->peer->ready = local_socket_ready_notify;  in smart_socket_enqueue()
868     s->peer->shutdown = nullptr;  in smart_socket_enqueue()
869     s->peer->close = local_socket_close_notify;  in smart_socket_enqueue()
870     s->peer->peer = nullptr;  in smart_socket_enqueue()
872     s->peer->transport = s->transport;  in smart_socket_enqueue()
874     connect_to_remote(s->peer, std::string_view(s->smart_socket_data).substr(4));  in smart_socket_enqueue()
875     s->peer = nullptr;  in smart_socket_enqueue()
894     if (s->peer) {  in smart_socket_close()
895         s->peer->peer = nullptr;  in smart_socket_close()
896         s->peer->close(s->peer);  in smart_socket_close()
897         s->peer = nullptr;  in smart_socket_close()
917     s->peer = ss;  in connect_to_smartsocket()
918     ss->peer = s;  in connect_to_smartsocket()
927     if (peer && peer->transport) {  in get_max_payload()
928         max_payload = std::min(max_payload, peer->transport->get_max_payload());  in get_max_payload()