16#define STUB_API "comm.cc"
void CLCB(const CommCloseCbParams ¶ms)
#define STUB
macro to stub a void function.
void schedule()
schedules and forgets all async calls previously stored by delay()
void delay(const AsyncCallPointer &)
stores the given call to schedule it at schedule() or destruction time
void commCallCloseHandlers(int fd)
void commUnsetConnTimeout(const Comm::ConnectionPointer &conn)
int commSetNonBlocking(int fd)
void _comm_close(int fd, char const *file, int line)
AsyncCall::Pointer comm_add_close_handler(int fd, CLCB *handler, void *data)
void comm_remove_close_handler(int fd, CLCB *handler, void *data)
unsigned short comm_local_port(int fd)
void commSetConnTimeout(const Comm::ConnectionPointer &conn, time_t timeout, AsyncCall::Pointer &callback)
void old_comm_reset_close(int fd)
bool comm_has_incomplete_write(int fd)
void commSetCloseOnExec(int fd)
void commUnsetFdTimeout(int fd)
clear a timeout handler by FD number
int ignoreErrno(int ierrno)
int commUnsetNonBlocking(int fd)
int comm_open_uds(int sock_type, int proto, struct sockaddr_un *addr, int flags)
Create a unix-domain socket (UDS) that only supports FD_MSGHDR I/O.
int comm_udp_sendto(int fd, const Ip::Address &to_addr, const void *buf, int len)
void comm_open_listener(int sock_type, int proto, Comm::ConnectionPointer &conn, const char *note)
bool commHasHalfClosedMonitor(int fd)
checks whether we are waiting for possibly half-closed connection to close
void commCloseAllSockets(void)
void comm_import_opened(const Comm::ConnectionPointer &conn, const char *note, struct addrinfo *AI)
update Comm state after getting a comm_open() FD from another process
int comm_udp_recv(int fd, void *buf, size_t len, int flags)
int comm_open(int sock_type, int proto, Ip::Address &addr, int flags, const char *note)
int comm_connect_addr(int sock, const Ip::Address &address)
ssize_t comm_udp_send(int s, const void *buf, size_t len, int flags)
void commStartHalfClosedMonitor(int fd)
Start waiting for a possibly half-closed connection to close.
int comm_udp_recvfrom(int fd, void *buf, size_t len, int flags, Ip::Address &from)
void comm_reset_close(const Comm::ConnectionPointer &conn)
bool comm_iocallbackpending(void)
Abstraction layer for TCP, UDP, TLS, UDS and filedescriptor sockets.
1.9.8