a2d96af4bb
The windows socket functions look identical to the normal POSIX sockets functions, but instead of setting errno, the caller needs to call WSAGetLastError(). QEMU has tried to deal with this incompatibility by defining a socket_error() method that callers must use that abstracts the difference between WSAGetLastError() and errno. This approach is somewhat error prone though - many callers of the sockets functions are just using errno directly because it is easy to forget the need use a QEMU specific wrapper. It is not always immediately obvious that a particular function will in fact call into Windows sockets functions, so the dev may not even realize they need to use socket_error(). This introduces an alternative approach to portability inspired by the way GNULIB fixes portability problems. We use a macro to redefine the original socket function names to refer to a QEMU wrapper function. The wrapper function calls the original Win32 sockets method and then sets errno from the WSAGetLastError() value. Thus all code can simply call the normal POSIX sockets APIs are have standard errno reporting on error, even on Windows. This makes the socket_error() method obsolete. We also bring closesocket & ioctlsocket into this approach. Even though they are non-standard Win32 names, we can't wrap the normal close/ioctl methods since there's no reliable way to distinguish between a file descriptor and HANDLE in Win32. Signed-off-by: Daniel P. Berrange <berrange@redhat.com>
114 lines
3.7 KiB
C
114 lines
3.7 KiB
C
/* headers to use the BSD sockets */
|
|
#ifndef QEMU_SOCKET_H
|
|
#define QEMU_SOCKET_H
|
|
|
|
#ifdef _WIN32
|
|
|
|
int inet_aton(const char *cp, struct in_addr *ia);
|
|
|
|
#endif /* !_WIN32 */
|
|
|
|
#include "qapi-types.h"
|
|
|
|
/* 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);
|
|
|
|
#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 *err, void *opaque);
|
|
|
|
InetSocketAddress *inet_parse(const char *str, Error **errp);
|
|
int inet_listen(const char *str, char *ostr, int olen,
|
|
int socktype, int port_offset, Error **errp);
|
|
int inet_connect(const char *str, Error **errp);
|
|
int inet_nonblocking_connect(const char *str,
|
|
NonBlockingConnectHandler *callback,
|
|
void *opaque, Error **errp);
|
|
|
|
NetworkAddressFamily inet_netfamily(int family);
|
|
|
|
int unix_listen(const char *path, char *ostr, int olen, Error **errp);
|
|
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 */
|