/* headers to use the BSD sockets */ #ifndef QEMU_SOCKET_H #define QEMU_SOCKET_H #ifdef _WIN32 #include #include #include #define socket_error() WSAGetLastError() int inet_aton(const char *cp, struct in_addr *ia); #else #include #include #include #include #include #include #include #define socket_error() errno #define closesocket(s) close(s) #endif /* !_WIN32 */ #include "qemu/option.h" #include "qapi/error.h" #include "qapi-types.h" extern QemuOptsList socket_optslist; /* misc helpers */ int qemu_socket(int domain, int type, int protocol); int qemu_accept(int s, struct sockaddr *addr, socklen_t *addrlen); int socket_set_cork(int fd, int v); int socket_set_nodelay(int fd); void qemu_set_block(int fd); void qemu_set_nonblock(int fd); int socket_set_fast_reuse(int fd); int send_all(int fd, const void *buf, int len1); int recv_all(int fd, void *buf, int len1, bool single_read); #ifdef WIN32 /* Windows has different names for the same constants with the same values */ #define SHUT_RD 0 #define SHUT_WR 1 #define SHUT_RDWR 2 #endif /* callback function for nonblocking connect * valid fd on success, negative error code on failure */ typedef void NonBlockingConnectHandler(int fd, Error *errp, void *opaque); InetSocketAddress *inet_parse(const char *str, Error **errp); int inet_listen_opts(QemuOpts *opts, int port_offset, Error **errp); int inet_listen(const char *str, char *ostr, int olen, int socktype, int port_offset, Error **errp); int inet_connect_opts(QemuOpts *opts, Error **errp, NonBlockingConnectHandler *callback, void *opaque); int inet_connect(const char *str, Error **errp); int inet_nonblocking_connect(const char *str, NonBlockingConnectHandler *callback, void *opaque, Error **errp); int inet_dgram_opts(QemuOpts *opts, Error **errp); NetworkAddressFamily inet_netfamily(int family); int unix_listen_opts(QemuOpts *opts, Error **errp); int unix_listen(const char *path, char *ostr, int olen, Error **errp); int unix_connect_opts(QemuOpts *opts, Error **errp, NonBlockingConnectHandler *callback, void *opaque); int unix_connect(const char *path, Error **errp); int unix_nonblocking_connect(const char *str, NonBlockingConnectHandler *callback, void *opaque, Error **errp); SocketAddress *socket_parse(const char *str, Error **errp); int socket_connect(SocketAddress *addr, Error **errp, NonBlockingConnectHandler *callback, void *opaque); int socket_listen(SocketAddress *addr, Error **errp); int socket_dgram(SocketAddress *remote, SocketAddress *local, Error **errp); /* Old, ipv4 only bits. Don't use for new code. */ int parse_host_port(struct sockaddr_in *saddr, const char *str); int socket_init(void); /** * socket_sockaddr_to_address: * @sa: socket address struct * @salen: size of @sa struct * @errp: pointer to uninitialized error object * * Get the string representation of the socket * address. A pointer to the allocated address information * struct will be returned, which the caller is required to * release with a call qapi_free_SocketAddress when no * longer required. * * Returns: the socket address struct, or NULL on error */ SocketAddress * socket_sockaddr_to_address(struct sockaddr_storage *sa, socklen_t salen, Error **errp); /** * socket_local_address: * @fd: the socket file handle * @errp: pointer to uninitialized error object * * Get the string representation of the local socket * address. A pointer to the allocated address information * struct will be returned, which the caller is required to * release with a call qapi_free_SocketAddress when no * longer required. * * Returns: the socket address struct, or NULL on error */ SocketAddress *socket_local_address(int fd, Error **errp); /** * socket_remote_address: * @fd: the socket file handle * @errp: pointer to uninitialized error object * * Get the string representation of the remote socket * address. A pointer to the allocated address information * struct will be returned, which the caller is required to * release with a call qapi_free_SocketAddress when no * longer required. * * Returns: the socket address struct, or NULL on error */ SocketAddress *socket_remote_address(int fd, Error **errp); void qapi_copy_SocketAddress(SocketAddress **p_dest, SocketAddress *src); #endif /* QEMU_SOCKET_H */