Searched refs:peer (Results 1 – 6 of 6) sorted by relevance
119 if(s->transport == t || (s->peer && s->peer->transport == t)) { in close_all_sockets()218 if(s->peer) { in local_socket_close_locked()219 s->peer->peer = 0; in local_socket_close_locked()221 if (s->peer->close == local_socket_close) in local_socket_close_locked()222 local_socket_close_locked(s->peer); in local_socket_close_locked()224 s->peer->close(s->peer); in local_socket_close_locked()295 s->peer->ready(s->peer); in local_socket_event_func()323 if((avail == MAX_PAYLOAD) || (s->peer == 0)) { in local_socket_event_func()328 r = s->peer->enqueue(s->peer, p); in local_socket_event_func()432 p->msg.arg0 = s->peer->id; in remote_socket_enqueue()[all …]
533 asocket* peer = s->peer; in jdwp_socket_close() local537 if (peer) { in jdwp_socket_close()538 peer->peer = NULL; in jdwp_socket_close()539 peer->close(peer); in jdwp_socket_close()549 s->peer->close(s->peer); in jdwp_socket_enqueue()558 asocket* peer = jdwp->socket.peer; in jdwp_socket_ready() local566 peer->enqueue(peer, p); in jdwp_socket_ready()570 peer->close(peer); in jdwp_socket_ready()620 asocket* peer = t->socket.peer; in jdwp_process_list_updated() local623 peer->enqueue( peer, p ); in jdwp_process_list_updated()[all …]
392 asocket* peer = socket->peer; in device_tracker_close() local395 if (peer) { in device_tracker_close()396 peer->peer = NULL; in device_tracker_close()397 peer->close(peer); in device_tracker_close()418 asocket* peer = tracker->socket.peer; in device_tracker_send() local422 return peer->enqueue( peer, p ); in device_tracker_send()
340 s->peer = create_remote_socket(p->msg.arg0, t); in handle_packet()341 s->peer->peer = s; in handle_packet()342 send_ready(s->id, s->peer->id, t); in handle_packet()351 if(s->peer == 0) { in handle_packet()352 s->peer = create_remote_socket(p->msg.arg0, t); in handle_packet()353 s->peer->peer = s; in handle_packet()
90 asocket *peer; member
191 Peer* peer; member208 static PeerProxy* peerProxyCreate(Peer* peer, Credentials credentials);255 static void peerLock(Peer* peer) { in peerLock() argument256 pthread_mutex_lock(&peer->mutex); in peerLock()260 static void peerUnlock(Peer* peer) { in peerUnlock() argument261 pthread_mutex_unlock(&peer->mutex); in peerUnlock()304 Peer* peer = peerProxy->peer; in peerProxyLockAndEnqueueOutgoingPacket() local305 peerLock(peer); in peerProxyLockAndEnqueueOutgoingPacket()307 peerUnlock(peer); in peerProxyLockAndEnqueueOutgoingPacket()315 Peer* peer = peerProxy->peer; in peerProxyNextPacket() local[all …]