Lines Matching full:peer
54 ** these have no peer anymore, but still packets to
122 if(s->transport == t || (s->peer && s->peer->transport == t)) {
223 if(s->peer) {
224 D("LS(%d): closing peer. peer->id=%d peer->fd=%d\n",
225 s->id, s->peer->id, s->peer->fd);
226 s->peer->peer = 0;
228 if (s->peer->close == local_socket_close) {
229 local_socket_close_locked(s->peer);
231 s->peer->close(s->peer);
233 s->peer = 0;
305 ** writable events again and tell our peer
309 s->peer->ready(s->peer);
339 if((avail == MAX_PAYLOAD) || (s->peer == 0)) {
344 r = s->peer->enqueue(s->peer, p);
345 D("LS(%d): fd=%d post peer->enqueue(). r=%d\n", s->id, s->fd, r);
450 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d\n",
451 s->id, s->fd, s->peer->fd);
453 p->msg.arg0 = s->peer->id;
462 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d\n",
463 s->id, s->fd, s->peer->fd);
466 p->msg.arg0 = s->peer->id;
473 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d\n",
474 s->id, s->fd, s->peer?s->peer->fd:-1);
477 if(s->peer) {
478 p->msg.arg0 = s->peer->id;
479 s->peer->peer = 0;
480 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d\n",
481 s->id, s->peer->id, s->peer->fd);
482 s->peer->close(s->peer);
494 asocket* peer = s->peer;
497 if (peer) {
498 peer->peer = NULL;
499 peer->close(peer);
703 if(handle_host_request(service, ttype, serial, s->peer->fd, s) == 0) {
721 sendfailmsg(s->peer->fd, "unknown host service");
726 ** so we make our peer back into a regular
732 adb_write(s->peer->fd, "OKAY", 4);
734 s->peer->ready = local_socket_ready;
735 s->peer->close = local_socket_close;
736 s->peer->peer = s2;
737 s2->peer = s->peer;
738 s->peer = 0;
753 sendfailmsg(s->peer->fd, error_string);
763 sendfailmsg(s->peer->fd, "device offline (x)");
768 /* instrument our peer to pass the success or fail
773 s->peer->ready = local_socket_ready_notify;
774 s->peer->close = local_socket_close_notify;
775 s->peer->peer = 0;
777 s->peer->transport = s->transport;
779 connect_to_remote(s->peer, (char*) (p->data + 4));
780 s->peer = 0;
785 /* we're going to close our peer as a side-effect, so
804 if(s->peer) {
805 s->peer->peer = 0;
806 s->peer->close(s->peer);
807 s->peer = 0;
835 s->peer = ss;
836 ss->peer = s;
