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);
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);
426 D("entered remote_socket_enqueue RS(%d) WRITE fd=%d peer.fd=%d\n",
427 s->id, s->fd, s->peer->fd);
429 p->msg.arg0 = s->peer->id;
438 D("entered remote_socket_ready RS(%d) OKAY fd=%d peer.fd=%d\n",
439 s->id, s->fd, s->peer->fd);
442 p->msg.arg0 = s->peer->id;
449 D("entered remote_socket_close RS(%d) CLOSE fd=%d peer->fd=%d\n",
450 s->id, s->fd, s->peer?s->peer->fd:-1);
453 if(s->peer) {
454 p->msg.arg0 = s->peer->id;
455 s->peer->peer = 0;
456 D("RS(%d) peer->close()ing peer->id=%d peer->fd=%d\n",
457 s->id, s->peer->id, s->peer->fd);
458 s->peer->close(s->peer);
470 asocket* peer = s->peer;
473 if (peer) {
474 peer->peer = NULL;
475 peer->close(peer);
646 sendfailmsg(s->peer->fd, error_string);
655 sendfailmsg(s->peer->fd, "device offline (x)");
660 /* instrument our peer to pass the success or fail
665 s->peer->ready = local_socket_ready_notify;
666 s->peer->close = local_socket_close_notify;
667 s->peer->peer = 0;
669 s->peer->transport = s->transport;
671 connect_to_remote(s->peer, (char*) (p->data + 4));
672 s->peer = 0;
677 /* we're going to close our peer as a side-effect, so
696 if(s->peer) {
697 s->peer->peer = 0;
698 s->peer->close(s->peer);
699 s->peer = 0;
727 s->peer = ss;
728 ss->peer = s;
