X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fsocket-util.h;h=5bf8529776a7dab6e7b2352d267ce5fa83bf3768;hb=d978fa4832bbc5176e05edd05bcdf2452a8dded2;hp=e2e0d9a24a02a034f71f235b61b7b46d6dff1810;hpb=a0505c49dd98b393f4c47a423f325008443eb1ee;p=sliver-openvswitch.git diff --git a/lib/socket-util.h b/lib/socket-util.h index e2e0d9a24..5bf852977 100644 --- a/lib/socket-util.h +++ b/lib/socket-util.h @@ -27,6 +27,7 @@ int set_nonblocking(int fd); void xset_nonblocking(int fd); +int set_dscp(int fd, uint8_t dscp); int get_max_fds(void); @@ -35,7 +36,6 @@ int lookup_ipv6(const char *host_name, struct in6_addr *address); int lookup_hostname(const char *host_name, struct in_addr *); -int get_socket_error(int sock); int get_socket_rcvbuf(int sock); int check_connection_completion(int fd); int drain_rcvbuf(int fd); @@ -63,6 +63,7 @@ int fsync_parent_dir(const char *file_name); int get_mtime(const char *file_name, struct timespec *mtime); void xpipe(int fds[2]); +void xpipe_nonblocking(int fds[2]); char *describe_fd(int fd); @@ -71,4 +72,28 @@ char *describe_fd(int fd); * in is used. */ #define DSCP_DEFAULT (IPTOS_PREC_INTERNETCONTROL >> 2) +/* Maximum number of fds that we support sending or receiving at one time + * across a Unix domain socket. */ +#define SOUTIL_MAX_FDS 8 + +/* Iovecs. */ +size_t iovec_len(const struct iovec *iovs, size_t n_iovs); +bool iovec_is_empty(const struct iovec *iovs, size_t n_iovs); + +/* Functions particularly useful for Unix domain sockets. */ +void xsocketpair(int domain, int type, int protocol, int fds[2]); +int send_iovec_and_fds(int sock, + const struct iovec *iovs, size_t n_iovs, + const int fds[], size_t n_fds); +int send_iovec_and_fds_fully(int sock, + const struct iovec *iovs, size_t n_iovs, + const int fds[], size_t n_fds, + size_t skip_bytes, size_t *bytes_sent); +int send_iovec_and_fds_fully_block(int sock, + const struct iovec *iovs, size_t n_iovs, + const int fds[], size_t n_fds); +int recv_data_and_fds(int sock, + void *data, size_t size, + int fds[SOUTIL_MAX_FDS], size_t *n_fdsp); + #endif /* socket-util.h */