30 #include <arpa/inet.h> 31 #include <netinet/in.h> 32 #include <netinet/tcp.h> 33 #include <sys/socket.h> 37 #define FOLLY_HAVE_MSG_ERRQUEUE 1 39 #include <linux/errqueue.h> 42 #ifndef SO_EE_ORIGIN_ZEROCOPY 43 #define SO_EE_ORIGIN_ZEROCOPY 5 46 #ifndef SO_EE_CODE_ZEROCOPY_COPIED 47 #define SO_EE_CODE_ZEROCOPY_COPIED 1 51 #define SO_ZEROCOPY 60 55 #define MSG_ZEROCOPY 0x4000000 63 #define ETH_MAX_MTU 0xFFFFU 67 #define UDP_SEGMENT 103 70 #ifndef UDP_MAX_SEGMENTS 71 #define UDP_MAX_SEGMENTS (1 << 6UL) 78 using sa_family_t = ADDRESS_FAMILY;
81 #define SO_EE_ORIGIN_ZEROCOPY 0 83 #define MSG_ZEROCOPY 0x0 85 #define UDP_SEGMENT 0x0 89 #define MSG_DONTWAIT 0x1000 93 socklen_t msg_namelen;
94 struct iovec* msg_iov;
97 size_t msg_controllen;
102 sa_family_t sun_family;
106 #define SHUT_RD SD_RECEIVE 107 #define SHUT_WR SD_SEND 108 #define SHUT_RDWR SD_BOTH 112 #define AF_LOCAL PF_UNIX 113 #define PF_LOCAL PF_UNIX 117 #define SO_REUSEPORT 0x7001 146 int inet_aton(
const char* cp, in_addr* inp);
ssize_t recvfrom(NetworkSocket s, void *buf, size_t len, int flags, sockaddr *from, socklen_t *fromlen)
int connect(NetworkSocket s, const sockaddr *name, socklen_t namelen)
ssize_t sendmsg(NetworkSocket socket, const msghdr *message, int flags)
int inet_aton(const char *cp, in_addr *inp)
int setsockopt(NetworkSocket s, int level, int optname, const void *optval, socklen_t optlen)
—— Concurrent Priority Queue Implementation ——
int getsockname(NetworkSocket s, sockaddr *name, socklen_t *namelen)
ssize_t sendto(NetworkSocket s, const void *buf, size_t len, int flags, const sockaddr *to, socklen_t tolen)
std::enable_if< detail::is_chrono_conversion< Tgt, Src >::value, Tgt >::type to(const Src &value)
int getsockopt(NetworkSocket s, int level, int optname, void *optval, socklen_t *optlen)
ssize_t send(NetworkSocket s, const void *buf, size_t len, int flags)
NetworkSocket socket(int af, int type, int protocol)
int listen(NetworkSocket s, int backlog)
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::from_fn from
ssize_t recvmsg(NetworkSocket s, msghdr *message, int flags)
int set_socket_non_blocking(NetworkSocket s)
int poll(PollDescriptor fds[], nfds_t nfds, int timeout)
int bind(NetworkSocket s, const sockaddr *name, socklen_t namelen)
int getpeername(NetworkSocket s, sockaddr *name, socklen_t *namelen)
int set_socket_close_on_exec(NetworkSocket s)
ssize_t recv(NetworkSocket s, void *buf, size_t len, int flags)
int close(NetworkSocket s)
ThreadPoolListHook * addr
int socketpair(int domain, int type, int protocol, NetworkSocket sv[2])
NetworkSocket accept(NetworkSocket s, sockaddr *addr, socklen_t *addrlen)