Lines Matching refs:peer
50 ** these have no peer anymore, but still packets to
58 // If |peer_id| is not 0, also check that it is connected to a peer
69 if (peer_id == 0 || (s->peer && s->peer->id == peer_id)) {
118 if (s->transport == t || (s->peer && s->peer->transport == t)) {
215 if (s->peer) {
216 D("LS(%d): closing peer. peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);
218 * the peer, this ensures that remote sockets can still get the id
221 if (s->peer->shutdown) {
222 s->peer->shutdown(s->peer);
224 s->peer->peer = nullptr;
225 s->peer->close(s->peer);
226 s->peer = nullptr;
300 ** writable events again and tell our peer
304 s->peer->ready(s->peer);
335 if ((avail == max_payload) || (s->peer == 0)) {
340 // s->peer->enqueue() may call s->close() and free s,
344 r = s->peer->enqueue(s->peer, p);
345 D("LS(%u): fd=%d post peer->enqueue(). r=%d", saved_id, saved_fd, r);
449 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);
451 p->msg.arg0 = s->peer->id;
459 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d", s->id, s->fd, s->peer->fd);
462 p->msg.arg0 = s->peer->id;
468 D("entered remote_socket_shutdown RS(%d) CLOSE fd=%d peer->fd=%d", s->id, s->fd,
469 s->peer ? s->peer->fd : -1);
472 if (s->peer) {
473 p->msg.arg0 = s->peer->id;
480 if (s->peer) {
481 s->peer->peer = 0;
482 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d", s->id, s->peer->id, s->peer->fd);
483 s->peer->close(s->peer);
485 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d", s->id, s->fd,
486 s->peer ? s->peer->fd : -1);
749 if (handle_host_request(service, type, serial, transport_id, s->peer->fd, s) == 0) {
767 SendFail(s->peer->fd, "unknown host service");
772 ** so we make our peer back into a regular
778 SendOkay(s->peer->fd);
780 s->peer->ready = local_socket_ready;
781 s->peer->shutdown = nullptr;
782 s->peer->close = local_socket_close;
783 s->peer->peer = s2;
784 s2->peer = s->peer;
785 s->peer = 0;
798 SendFail(s->peer->fd, error_msg);
805 SendFail(s->peer->fd, "device offline (no transport)");
811 SendFail(s->peer->fd, "device offline (transport offline)");
815 /* instrument our peer to pass the success or fail
820 s->peer->ready = local_socket_ready_notify;
821 s->peer->shutdown = nullptr;
822 s->peer->close = local_socket_close_notify;
823 s->peer->peer = 0;
825 s->peer->transport = s->transport;
827 connect_to_remote(s->peer, (char*)(p->data + 4));
828 s->peer = 0;
833 /* we're going to close our peer as a side-effect, so
850 if (s->peer) {
851 s->peer->peer = 0;
852 s->peer->close(s->peer);
853 s->peer = 0;
874 s->peer = ss;
875 ss->peer = s;
884 if (peer && peer->transport) {
885 max_payload = std::min(max_payload, peer->transport->get_max_payload());
