Lines Matching refs:peer
49 ** these have no peer anymore, but still packets to
55 // If |peer_id| is not 0, also check that it is connected to a peer
65 if (peer_id == 0 || (s->peer && s->peer->id == peer_id)) {
102 if (s->transport == t || (s->peer && s->peer->transport == t)) {
178 if (avail != max_payload && s->peer) {
181 // s->peer->enqueue() may call s->close() and free s,
185 r = s->peer->enqueue(s->peer, std::move(data));
186 D("LS(%u): fd=%d post peer->enqueue(). r=%d", saved_id, saved_fd, r);
265 if (s->peer) {
266 D("LS(%d): closing peer. peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);
268 * the peer, this ensures that remote sockets can still get the id
271 if (s->peer->shutdown) {
272 s->peer->shutdown(s->peer);
274 s->peer->peer = nullptr;
275 s->peer->close(s->peer);
276 s->peer = nullptr;
316 s->peer->ready(s->peer);
398 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);
402 p->msg.arg0 = s->peer->id;
418 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);
421 p->msg.arg0 = s->peer->id;
427 D("entered remote_socket_shutdown RS(%d) CLOSE fd=%d peer->fd=%d", s->id, s->fd,
428 s->peer ? s->peer->fd : -1);
431 if (s->peer) {
432 p->msg.arg0 = s->peer->id;
439 if (s->peer) {
440 s->peer->peer = 0;
441 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);
442 s->peer->close(s->peer);
444 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d", s->id, s->fd,
445 s->peer ? s->peer->fd : -1);
695 if (handle_host_request(service, type, serial, transport_id, s->peer->fd, s) == 0) {
713 SendFail(s->peer->fd, "unknown host service");
718 ** so we make our peer back into a regular
724 SendOkay(s->peer->fd);
726 s->peer->ready = local_socket_ready;
727 s->peer->shutdown = nullptr;
728 s->peer->close = local_socket_close;
729 s->peer->peer = s2;
730 s2->peer = s->peer;
731 s->peer = 0;
744 SendFail(s->peer->fd, error_msg);
751 SendFail(s->peer->fd, "device offline (no transport)");
757 SendFail(s->peer->fd, "device offline (transport offline)");
761 /* instrument our peer to pass the success or fail
766 s->peer->ready = local_socket_ready_notify;
767 s->peer->shutdown = nullptr;
768 s->peer->close = local_socket_close_notify;
769 s->peer->peer = 0;
771 s->peer->transport = s->transport;
773 connect_to_remote(s->peer, s->smart_socket_data.data() + 4);
774 s->peer = 0;
779 /* we're going to close our peer as a side-effect, so
793 if (s->peer) {
794 s->peer->peer = 0;
795 s->peer->close(s->peer);
796 s->peer = 0;
816 s->peer = ss;
817 ss->peer = s;
826 if (peer && peer->transport) {
827 max_payload = std::min(max_payload, peer->transport->get_max_payload());
