Lines Matching refs:peer
58 ** these have no peer anymore, but still packets to
67 // If |peer_id| is not 0, also check that it is connected to a peer
78 if (peer_id == 0 || (s->peer && s->peer->id == peer_id)) {
136 if(s->transport == t || (s->peer && s->peer->transport == t)) {
244 if(s->peer) {
245 D("LS(%d): closing peer. peer->id=%d peer->fd=%d\n",
246 s->id, s->peer->id, s->peer->fd);
248 * the peer, this ensures that remote sockets can still get the id
251 if (s->peer->shutdown)
252 s->peer->shutdown(s->peer);
253 s->peer->peer = 0;
255 if (s->peer->close == local_socket_close) {
256 local_socket_close_locked(s->peer);
258 s->peer->close(s->peer);
260 s->peer = 0;
332 ** writable events again and tell our peer
336 s->peer->ready(s->peer);
366 if((avail == MAX_PAYLOAD) || (s->peer == 0)) {
371 r = s->peer->enqueue(s->peer, p);
372 D("LS(%d): fd=%d post peer->enqueue(). r=%d\n", s->id, s->fd, r);
495 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d\n",
496 s->id, s->fd, s->peer->fd);
498 p->msg.arg0 = s->peer->id;
507 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d\n",
508 s->id, s->fd, s->peer->fd);
511 p->msg.arg0 = s->peer->id;
518 D("entered remote_socket_shutdown RS(%d) CLOSE fd=%d peer->fd=%d\n",
519 s->id, s->fd, s->peer?s->peer->fd:-1);
522 if(s->peer) {
523 p->msg.arg0 = s->peer->id;
531 if (s->peer) {
532 s->peer->peer = 0;
533 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d\n",
534 s->id, s->peer->id, s->peer->fd);
535 s->peer->close(s->peer);
537 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d\n",
538 s->id, s->fd, s->peer?s->peer->fd:-1);
547 asocket* peer = s->peer;
550 if (peer) {
551 peer->peer = NULL;
552 peer->close(peer);
785 if(handle_host_request(service, ttype, serial, s->peer->fd, s) == 0) {
803 sendfailmsg(s->peer->fd, "unknown host service");
808 ** so we make our peer back into a regular
814 adb_write(s->peer->fd, "OKAY", 4);
816 s->peer->ready = local_socket_ready;
817 s->peer->shutdown = NULL;
818 s->peer->close = local_socket_close;
819 s->peer->peer = s2;
820 s2->peer = s->peer;
821 s->peer = 0;
836 sendfailmsg(s->peer->fd, error_string);
846 sendfailmsg(s->peer->fd, "device offline (x)");
851 /* instrument our peer to pass the success or fail
856 s->peer->ready = local_socket_ready_notify;
857 s->peer->shutdown = NULL;
858 s->peer->close = local_socket_close_notify;
859 s->peer->peer = 0;
861 s->peer->transport = s->transport;
863 connect_to_remote(s->peer, (char*) (p->data + 4));
864 s->peer = 0;
869 /* we're going to close our peer as a side-effect, so
888 if(s->peer) {
889 s->peer->peer = 0;
890 s->peer->close(s->peer);
891 s->peer = 0;
914 s->peer = ss;
915 ss->peer = s;
