Socket
socket_t Socket;
socket_t Socket;
socket_t Socket;
int Socket() const;
int Socket() const;
net_socket* Socket() const { return fSocket; }
kprintf("}> sock %p\n", state->Parent()->Socket());
ipv4_protocol* ipProtocol = state->Parent()->Socket();
if (raw->Socket()->protocol == buffer->protocol) {
ProtocolType *Socket() const { return fParent; }
ipv6_protocol* ipProtocol = state->Parent()->Socket();
if (raw->Socket()->protocol == buffer->protocol)
ProtocolType *Socket() const { return fParent; }
gSocketModule->notify(endpoint->Socket(), B_SELECT_ERROR, error);
gSocketModule->set_connected(endpoint->Socket());
int socketOptions = endpoint->Socket()->options;
if ((otherEndpoint->Socket()->options
&& ((otherEndpoint->Socket()->options & SO_REUSEPORT) == 0
gSocketModule->set_connected(Socket());
gSocketModule->set_connected(Socket());
gSocketModule->set_connected(Socket());
shutdown(fEndpoint->Socket(), SHUT_WR);
__sock = new Socket(url.Host(), port);
Socket *__sock;
class Socket;
fSock = new Socket(fHost.c_str(), LPS_SERVER_PORT, localPort);
class Socket;
Socket* fSock;
void Socket::close()
bool Socket::fail() const
bool Socket::good() const
bool Socket::operator !() const
int Socket::read(char *buffer, int size, int flags)
int Socket::write(const char *buffer, int size, int flags)
Socket::Socket(const char *host, int port)
Socket::Socket(const char *host, int port, int localPort)
Socket::~Socket()
istream &Socket::getInputStream()
ostream &Socket::getOutputStream()
void Socket::open()
class Socket {
Socket(const char *host, int port);
Socket(const char *host, int port, int localPort);
~Socket();
Socket(const Socket &);
Socket &operator = (const Socket &);
inline int Socket::getPort() const
inline const char *Socket::getLastError() const
socketstreambase::socketstreambase(Socket *sock, streamsize n)
isocketstream::isocketstream(Socket *sock, streamsize n)
osocketstream::osocketstream(Socket *sock, streamsize n)
socketstreambuf::socketstreambuf(Socket *sock, streamsize n)
explicit socketstreambuf(Socket *sock, streamsize n);
Socket *__sock;
socketstreambase(Socket *sock, streamsize n);
explicit isocketstream(Socket *sock, streamsize n = 4096);
explicit osocketstream(Socket *sock, streamsize n = 4096);
class Socket;
if (setsockopt(Socket(), SOL_SOCKET, SO_REUSEADDR, &value,
entry.fd = Socket();
if (listen(Socket(), backlog) != 0)
ssize_t bytesReceived = recv(Socket(), buffer, size, 0);
bytesSent = sendto(Socket(), buffer, size, 0, fPeer, fPeer.Length());
bytesSent = send(Socket(), buffer, size, 0);
ssize_t bytesReceived = recv(Socket(), buffer, size, 0);
ssize_t bytesSent = send(Socket(), buffer, size, 0);
auto socket = request.Socket();
auto flags = fcntl(fSocket->Socket(), F_GETFL, 0);
if (fcntl(fSocket->Socket(), F_SETFL, flags | O_NONBLOCK) != 0)
int Socket() const noexcept { return fSocket->Socket(); }
BPrivate::Socket socket;
BPrivate::Socket socket;
BPrivate::Socket socket;