eckit::net::EphemeralTCPServer class

Base classes

class TCPServer

Public static functions

static auto addrToHost(in_addr) -> std::string
static auto hostToAddr(const std::string&) -> in_addr
static auto hostName(const std::string& h, bool full = false) -> std::string
static void register_ignore_sigpipe()

Constructors, destructors, conversion operators

EphemeralTCPServer(const SocketOptions& = SocketOptions::data())
EphemeralTCPServer(int port, const SocketOptions& = SocketOptions::data()) explicit

Public functions

void willFork(bool)
auto accept(const std::string& message = "Waiting for connection", int timeout = 0, bool* connected = nullptr) -> TCPSocket& virtual
void closeExec(bool on)
auto socket() -> int override
void close() override
auto write(const void* buf, long length) -> long
auto read(void* buf, long length) -> long
auto rawRead(void*, long) -> long
auto isConnected() const -> bool
auto stillConnected() const -> bool
auto remoteAddr() const -> in_addr
auto remoteHost() const -> const std::string&
auto remotePort() const -> int
auto localAddr() const -> in_addr
auto localHost() const -> const std::string&
auto localPort() const -> int
void bufferSize(int n)
void receiveBufferSize(int n)
void sendBufferSize(int n)
void closeOutput()
void closeInput()
void debug(bool on)

Function documentation

static std::string eckit::net::EphemeralTCPServer::addrToHost(in_addr)

static in_addr eckit::net::EphemeralTCPServer::hostToAddr(const std::string&)

static std::string eckit::net::EphemeralTCPServer::hostName(const std::string& h, bool full = false)

static void eckit::net::EphemeralTCPServer::register_ignore_sigpipe()

long eckit::net::EphemeralTCPServer::write(const void* buf, long length)

long eckit::net::EphemeralTCPServer::read(void* buf, long length)

Parameters
buf The buffer to read into
length The maximum number of bytes to read

Read from a TCP socket

Configuration flags

  • useSelectOnTCPSocket (bool): use select for improved resilience on flaky connections
  • socketSelectTimeout (long): timeout in seconds for the select (only if useSelectOnTCPSocket is enabled)

long eckit::net::EphemeralTCPServer::rawRead(void*, long)

bool eckit::net::EphemeralTCPServer::isConnected() const

bool eckit::net::EphemeralTCPServer::stillConnected() const

in_addr eckit::net::EphemeralTCPServer::remoteAddr() const

const std::string& eckit::net::EphemeralTCPServer::remoteHost() const

int eckit::net::EphemeralTCPServer::remotePort() const

in_addr eckit::net::EphemeralTCPServer::localAddr() const

const std::string& eckit::net::EphemeralTCPServer::localHost() const

int eckit::net::EphemeralTCPServer::localPort() const

void eckit::net::EphemeralTCPServer::bufferSize(int n)

void eckit::net::EphemeralTCPServer::receiveBufferSize(int n)

void eckit::net::EphemeralTCPServer::sendBufferSize(int n)

void eckit::net::EphemeralTCPServer::closeOutput()

void eckit::net::EphemeralTCPServer::closeInput()

void eckit::net::EphemeralTCPServer::debug(bool on)