Lines Matching defs: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);
340 if((avail == MAX_PAYLOAD) || (s->peer == 0)) {
345 r = s->peer->enqueue(s->peer, p);
346 D("LS(%d): fd=%d post peer->enqueue(). r=%d\n", s->id, s->fd, r);
427 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d\n",
428 s->id, s->fd, s->peer->fd);
430 p->msg.arg0 = s->peer->id;
439 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d\n",
440 s->id, s->fd, s->peer->fd);
443 p->msg.arg0 = s->peer->id;
450 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d\n",
451 s->id, s->fd, s->peer?s->peer->fd:-1);
454 if(s->peer) {
455 p->msg.arg0 = s->peer->id;
456 s->peer->peer = 0;
457 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d\n",
458 s->id, s->peer->id, s->peer->fd);
459 s->peer->close(s->peer);
471 asocket* peer = s->peer;
474 if (peer) {
475 peer->peer = NULL;
476 peer->close(peer);
647 sendfailmsg(s->peer->fd, error_string);
656 sendfailmsg(s->peer->fd, "device offline (x)");
661 /* instrument our peer to pass the success or fail
666 s->peer->ready = local_socket_ready_notify;
667 s->peer->close = local_socket_close_notify;
668 s->peer->peer = 0;
670 s->peer->transport = s->transport;
672 connect_to_remote(s->peer, (char*) (p->data + 4));
673 s->peer = 0;
678 /* we're going to close our peer as a side-effect, so
697 if(s->peer) {
698 s->peer->peer = 0;
699 s->peer->close(s->peer);
700 s->peer = 0;
728 s->peer = ss;
729 ss->peer = s;
