UnixStreamEndpoint
*_endpoint = new(std::nothrow) UnixStreamEndpoint(socket, false);
*_endpoint = new(std::nothrow) UnixStreamEndpoint(socket, true);
UnixStreamEndpoint::Close()
BReference<UnixStreamEndpoint> peerReference;
UnixStreamEndpoint::Free()
UnixStreamEndpoint::Bind(const struct sockaddr* _address)
UnixStreamEndpoint::Unbind()
UnixStreamEndpoint::Listen(int backlog)
UnixStreamEndpoint::Connect(const struct sockaddr* _address)
UnixStreamEndpoint* listeningEndpoint
= dynamic_cast<UnixStreamEndpoint*>(listeningUnixEndpoint);
BReference<UnixStreamEndpoint> peerReference(listeningEndpoint);
UnixStreamEndpoint* connectedEndpoint = (UnixStreamEndpoint*)newSocket->first_protocol;
UnixStreamEndpoint::UnixStreamEndpoint(net_socket* socket, bool atomic)
UnixStreamEndpoint::Accept(net_socket** _acceptedSocket)
UnixStreamEndpoint::Send(const iovec* vecs, size_t vecCount,
BReference<UnixStreamEndpoint> peerReference;
UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
UnixStreamEndpoint::~UnixStreamEndpoint()
UnixStreamEndpoint::Receive(const iovec* vecs, size_t vecCount,
UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
BReference<UnixStreamEndpoint> peerReference(peerEndpoint);
UnixStreamEndpoint::Init()
UnixStreamEndpoint::Sendable()
UnixStreamEndpoint::Receivable()
UnixStreamEndpoint::SetReceiveBufferSize(size_t size)
UnixStreamEndpoint::GetPeerCredentials(ucred* credentials)
UnixStreamEndpoint::Uninit()
UnixStreamEndpoint::Shutdown(int direction)
UnixStreamEndpoint::_Spawn(UnixStreamEndpoint* connectingEndpoint,
UnixStreamEndpoint* listeningEndpoint, UnixFifo* fifo)
UnixStreamEndpoint::_Disconnect()
UnixStreamEndpoint::_LockConnectedEndpoints(UnixStreamEndpointLocker& locker,
BReference<UnixStreamEndpoint> peerReference(fPeerEndpoint);
UnixStreamEndpoint* peerEndpoint = fPeerEndpoint;
UnixStreamEndpoint::_Unbind()
UnixStreamEndpoint::_UnsetReceiveFifo()
UnixStreamEndpoint::_StopListening()
UnixStreamEndpoint::Open()
class UnixStreamEndpoint;
typedef AutoLocker<UnixStreamEndpoint> UnixStreamEndpointLocker;
class UnixStreamEndpoint final : public UnixEndpoint, public BReferenceable {
UnixStreamEndpoint(net_socket* socket, bool atomic);
virtual ~UnixStreamEndpoint() override;
void _Spawn(UnixStreamEndpoint* connectingEndpoint,
UnixStreamEndpoint* listeningEndpoint, UnixFifo* fifo);
UnixStreamEndpoint* fPeerEndpoint;