2006-05-01 00:53:25 +02:00
|
|
|
/* headers to use the BSD sockets */
|
|
|
|
#ifndef QEMU_SOCKET_H
|
|
|
|
#define QEMU_SOCKET_H
|
|
|
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
#include <windows.h>
|
|
|
|
#include <winsock2.h>
|
|
|
|
#include <ws2tcpip.h>
|
|
|
|
|
|
|
|
#define socket_error() WSAGetLastError()
|
|
|
|
|
2008-09-15 17:51:35 +02:00
|
|
|
int inet_aton(const char *cp, struct in_addr *ia);
|
|
|
|
|
2006-05-01 00:53:25 +02:00
|
|
|
#else
|
|
|
|
|
2010-09-22 18:51:33 +02:00
|
|
|
#include <sys/types.h>
|
2006-05-01 00:53:25 +02:00
|
|
|
#include <sys/socket.h>
|
|
|
|
#include <netinet/in.h>
|
|
|
|
#include <netinet/tcp.h>
|
2008-09-15 17:51:35 +02:00
|
|
|
#include <arpa/inet.h>
|
|
|
|
#include <netdb.h>
|
2006-12-21 20:46:43 +01:00
|
|
|
#include <sys/un.h>
|
2006-05-01 00:53:25 +02:00
|
|
|
|
|
|
|
#define socket_error() errno
|
|
|
|
#define closesocket(s) close(s)
|
|
|
|
|
|
|
|
#endif /* !_WIN32 */
|
|
|
|
|
2012-12-17 18:20:00 +01:00
|
|
|
#include "qemu/option.h"
|
2012-12-17 18:19:43 +01:00
|
|
|
#include "qapi/error.h"
|
|
|
|
#include "qapi/qmp/qerror.h"
|
2014-06-18 08:43:30 +02:00
|
|
|
#include "qapi-types.h"
|
2009-09-10 10:58:37 +02:00
|
|
|
|
2013-03-15 17:14:24 +01:00
|
|
|
extern QemuOptsList socket_optslist;
|
|
|
|
|
2008-11-11 21:46:40 +01:00
|
|
|
/* misc helpers */
|
2009-12-02 12:24:42 +01:00
|
|
|
int qemu_socket(int domain, int type, int protocol);
|
|
|
|
int qemu_accept(int s, struct sockaddr *addr, socklen_t *addrlen);
|
2011-09-21 12:36:48 +02:00
|
|
|
int socket_set_cork(int fd, int v);
|
2013-02-22 04:39:50 +01:00
|
|
|
int socket_set_nodelay(int fd);
|
2013-03-27 10:10:43 +01:00
|
|
|
void qemu_set_block(int fd);
|
|
|
|
void qemu_set_nonblock(int fd);
|
2013-10-02 12:23:12 +02:00
|
|
|
int socket_set_fast_reuse(int fd);
|
2008-11-11 21:46:40 +01:00
|
|
|
int send_all(int fd, const void *buf, int len1);
|
2013-02-27 18:47:53 +01:00
|
|
|
int recv_all(int fd, void *buf, int len1, bool single_read);
|
2008-11-11 21:46:40 +01:00
|
|
|
|
2015-01-08 12:11:30 +01:00
|
|
|
#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
|
|
|
|
|
2012-09-24 13:11:09 +02:00
|
|
|
/* callback function for nonblocking connect
|
|
|
|
* valid fd on success, negative error code on failure
|
|
|
|
*/
|
2014-10-08 14:11:56 +02:00
|
|
|
typedef void NonBlockingConnectHandler(int fd, Error *errp, void *opaque);
|
2012-09-24 13:11:09 +02:00
|
|
|
|
2013-03-15 11:55:29 +01:00
|
|
|
InetSocketAddress *inet_parse(const char *str, Error **errp);
|
2012-05-10 18:28:26 +02:00
|
|
|
int inet_listen_opts(QemuOpts *opts, int port_offset, Error **errp);
|
2008-11-11 21:46:40 +01:00
|
|
|
int inet_listen(const char *str, char *ostr, int olen,
|
2012-05-10 18:28:26 +02:00
|
|
|
int socktype, int port_offset, Error **errp);
|
2012-09-24 13:11:09 +02:00
|
|
|
int inet_connect_opts(QemuOpts *opts, Error **errp,
|
|
|
|
NonBlockingConnectHandler *callback, void *opaque);
|
2012-09-24 13:11:08 +02:00
|
|
|
int inet_connect(const char *str, Error **errp);
|
2012-09-24 13:11:09 +02:00
|
|
|
int inet_nonblocking_connect(const char *str,
|
|
|
|
NonBlockingConnectHandler *callback,
|
|
|
|
void *opaque, Error **errp);
|
|
|
|
|
2012-10-02 09:35:32 +02:00
|
|
|
int inet_dgram_opts(QemuOpts *opts, Error **errp);
|
2014-06-18 08:43:30 +02:00
|
|
|
NetworkAddressFamily inet_netfamily(int family);
|
2008-11-11 21:46:40 +01:00
|
|
|
|
2012-10-02 09:35:32 +02:00
|
|
|
int unix_listen_opts(QemuOpts *opts, Error **errp);
|
|
|
|
int unix_listen(const char *path, char *ostr, int olen, Error **errp);
|
2012-10-03 13:37:46 +02:00
|
|
|
int unix_connect_opts(QemuOpts *opts, Error **errp,
|
|
|
|
NonBlockingConnectHandler *callback, void *opaque);
|
2012-10-02 09:35:32 +02:00
|
|
|
int unix_connect(const char *path, Error **errp);
|
2012-10-03 13:37:46 +02:00
|
|
|
int unix_nonblocking_connect(const char *str,
|
|
|
|
NonBlockingConnectHandler *callback,
|
|
|
|
void *opaque, Error **errp);
|
2008-11-11 21:46:40 +01:00
|
|
|
|
2012-10-23 21:31:53 +02:00
|
|
|
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);
|
2013-02-27 14:10:47 +01:00
|
|
|
int socket_dgram(SocketAddress *remote, SocketAddress *local, Error **errp);
|
2012-10-23 21:31:53 +02:00
|
|
|
|
2008-11-11 21:46:40 +01:00
|
|
|
/* Old, ipv4 only bits. Don't use for new code. */
|
2008-10-13 05:12:02 +02:00
|
|
|
int parse_host_port(struct sockaddr_in *saddr, const char *str);
|
2010-04-01 19:57:08 +02:00
|
|
|
int socket_init(void);
|
2006-05-01 00:53:25 +02:00
|
|
|
|
|
|
|
#endif /* QEMU_SOCKET_H */
|