Lines Matching refs:peer
54 ** these have no peer anymore, but still packets to
122 if(s->transport == t || (s->peer && s->peer->transport == t)) {
230 if(s->peer) {
231 D("LS(%d): closing peer. peer->id=%d peer->fd=%d\n",
232 s->id, s->peer->id, s->peer->fd);
233 s->peer->peer = 0;
235 if (s->peer->close == local_socket_close) {
236 local_socket_close_locked(s->peer);
238 s->peer->close(s->peer);
240 s->peer = 0;
312 ** writable events again and tell our peer
316 s->peer->ready(s->peer);
346 if((avail == MAX_PAYLOAD) || (s->peer == 0)) {
351 r = s->peer->enqueue(s->peer, p);
352 D("LS(%d): fd=%d post peer->enqueue(). r=%d\n", s->id, s->fd, r);
467 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d\n",
468 s->id, s->fd, s->peer->fd);
470 p->msg.arg0 = s->peer->id;
479 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d\n",
480 s->id, s->fd, s->peer->fd);
483 p->msg.arg0 = s->peer->id;
490 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d\n",
491 s->id, s->fd, s->peer?s->peer->fd:-1);
494 if(s->peer) {
495 p->msg.arg0 = s->peer->id;
496 s->peer->peer = 0;
497 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d\n",
498 s->id, s->peer->id, s->peer->fd);
499 s->peer->close(s->peer);
511 asocket* peer = s->peer;
514 if (peer) {
515 peer->peer = NULL;
516 peer->close(peer);
738 if(handle_host_request(service, ttype, serial, s->peer->fd, s) == 0) {
756 sendfailmsg(s->peer->fd, "unknown host service");
761 ** so we make our peer back into a regular
767 adb_write(s->peer->fd, "OKAY", 4);
769 s->peer->ready = local_socket_ready;
770 s->peer->close = local_socket_close;
771 s->peer->peer = s2;
772 s2->peer = s->peer;
773 s->peer = 0;
788 sendfailmsg(s->peer->fd, error_string);
798 sendfailmsg(s->peer->fd, "device offline (x)");
803 /* instrument our peer to pass the success or fail
808 s->peer->ready = local_socket_ready_notify;
809 s->peer->close = local_socket_close_notify;
810 s->peer->peer = 0;
812 s->peer->transport = s->transport;
814 connect_to_remote(s->peer, (char*) (p->data + 4));
815 s->peer = 0;
820 /* we're going to close our peer as a side-effect, so
839 if(s->peer) {
840 s->peer->peer = 0;
841 s->peer->close(s->peer);
842 s->peer = 0;
870 s->peer = ss;
871 ss->peer = s;
