Lines Matching refs:peerEndpoint
403 UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
404 peerReference.SetTo(peerEndpoint);
407 UnixFifo* peerFifo = peerEndpoint->fReceiveFifo;
432 bool peerLocked = (fPeerEndpoint == peerEndpoint
437 gSocketModule->notify(peerEndpoint->socket, B_SELECT_READ, readable);
443 if (fPeerEndpoint == peerEndpoint
495 UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
496 BReference<UnixStreamEndpoint> peerReference(peerEndpoint);
532 bool peerLocked = (peerEndpoint != NULL && fPeerEndpoint == peerEndpoint
539 gSocketModule->notify(peerEndpoint->socket, B_SELECT_WRITE, writable);
761 UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
766 peerLocker.SetTo(peerEndpoint, false);
771 if (fState != unix_stream_endpoint_state::Connected || peerEndpoint != fPeerEndpoint)
774 peerLocker.SetTo(peerEndpoint, false);