X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fsocket-util.h;h=5bf8529776a7dab6e7b2352d267ce5fa83bf3768;hb=485e2766d816a18e1a51ddf5e12e55f38aeedf89;hp=07c9327c4d7113d06eb0bc44ee894cf5da128c21;hpb=ef8a3d14976080fc5e29ce04bea8bd88f8b631f2;p=sliver-openvswitch.git diff --git a/lib/socket-util.h b/lib/socket-util.h index 07c9327c4..5bf852977 100644 --- a/lib/socket-util.h +++ b/lib/socket-util.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks. + * Copyright (c) 2008, 2009, 2010, 2011, 2012 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -26,6 +26,9 @@ #include int set_nonblocking(int fd); +void xset_nonblocking(int fd); +int set_dscp(int fd, uint8_t dscp); + int get_max_fds(void); int lookup_ip(const char *host_name, struct in_addr *address); @@ -33,12 +36,11 @@ 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); void drain_fd(int fd, size_t n_packets); -int make_unix_socket(int style, bool nonblock, bool passcred, +int make_unix_socket(int style, bool nonblock, const char *bind_path, const char *connect_path); int get_unix_name_len(socklen_t sun_len); ovs_be32 guess_netmask(ovs_be32 ip); @@ -61,12 +63,37 @@ 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); /* Default value of dscp bits for connection between controller and manager. * Value of IPTOS_PREC_INTERNETCONTROL = 0xc0 which is defined - * in is used. */ -#define DSCP_DEFAULT IPTOS_PREC_INTERNETCONTROL + * 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 */