2006-05-01 00:53:25 +02:00
|
|
|
/* headers to use the BSD sockets */
|
2016-06-29 10:12:57 +02:00
|
|
|
|
|
|
|
#ifndef QEMU_SOCKETS_H
|
|
|
|
#define QEMU_SOCKETS_H
|
2006-05-01 00:53:25 +02:00
|
|
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
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
|
|
|
#endif /* !_WIN32 */
|
|
|
|
|
2018-02-11 10:36:01 +01:00
|
|
|
#include "qapi/qapi-types-sockets.h"
|
2009-09-10 10:58:37 +02:00
|
|
|
|
2008-11-11 21:46:40 +01:00
|
|
|
/* misc helpers */
|
2017-12-21 13:55:20 +01:00
|
|
|
bool fd_is_socket(int fd);
|
2009-12-02 12:24:42 +01:00
|
|
|
int qemu_socket(int domain, int type, int protocol);
|
2022-08-23 09:50:39 +02:00
|
|
|
|
|
|
|
/**
|
|
|
|
* qemu_socketpair:
|
|
|
|
* @domain: specifies a communication domain, such as PF_UNIX
|
|
|
|
* @type: specifies the socket type.
|
|
|
|
* @protocol: specifies a particular protocol to be used with the socket
|
|
|
|
* @sv: an array to store the pair of socket created
|
|
|
|
*
|
|
|
|
* Creates an unnamed pair of connected sockets in the specified domain,
|
|
|
|
* of the specified type, and using the optionally specified protocol.
|
|
|
|
* And automatically set the close-on-exec flags on the returned sockets
|
|
|
|
*
|
|
|
|
* Return 0 on success.
|
|
|
|
*/
|
|
|
|
int qemu_socketpair(int domain, int type, int protocol, int sv[2]);
|
|
|
|
|
2009-12-02 12:24:42 +01:00
|
|
|
int qemu_accept(int s, struct sockaddr *addr, socklen_t *addrlen);
|
2022-10-28 06:57:27 +02:00
|
|
|
/*
|
|
|
|
* A variant of send(2) which handles partial send.
|
|
|
|
*
|
|
|
|
* Return the number of bytes transferred over the socket.
|
|
|
|
* Set errno if fewer than `count' bytes are sent.
|
|
|
|
*
|
|
|
|
* This function don't work with non-blocking socket's.
|
|
|
|
* Any of the possibilities with non-blocking socket's is bad:
|
|
|
|
* - return a short write (then name is wrong)
|
|
|
|
* - busy wait adding (errno == EAGAIN) to the loop
|
|
|
|
*/
|
|
|
|
ssize_t qemu_send_full(int s, const void *buf, size_t count)
|
|
|
|
G_GNUC_WARN_UNUSED_RESULT;
|
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);
|
2022-04-25 15:33:47 +02:00
|
|
|
void qemu_socket_set_block(int fd);
|
|
|
|
int qemu_socket_try_set_nonblock(int fd);
|
|
|
|
void qemu_socket_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
|
|
|
|
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
|
|
|
|
|
2016-07-19 13:54:47 +02:00
|
|
|
int inet_ai_family_from_address(InetSocketAddress *addr,
|
|
|
|
Error **errp);
|
2017-04-26 09:36:37 +02:00
|
|
|
int inet_parse(InetSocketAddress *addr, const char *str, Error **errp);
|
2012-09-24 13:11:08 +02:00
|
|
|
int inet_connect(const char *str, Error **errp);
|
2017-06-16 10:54:45 +02:00
|
|
|
int inet_connect_saddr(InetSocketAddress *saddr, Error **errp);
|
2012-09-24 13:11:09 +02:00
|
|
|
|
2014-06-18 08:43:30 +02:00
|
|
|
NetworkAddressFamily inet_netfamily(int family);
|
2008-11-11 21:46:40 +01:00
|
|
|
|
2017-12-12 12:12:19 +01:00
|
|
|
int unix_listen(const char *path, Error **errp);
|
2012-10-02 09:35:32 +02:00
|
|
|
int unix_connect(const char *path, Error **errp);
|
2008-11-11 21:46:40 +01:00
|
|
|
|
2022-10-21 11:09:18 +02:00
|
|
|
char *socket_uri(SocketAddress *addr);
|
2017-04-26 09:36:41 +02:00
|
|
|
SocketAddress *socket_parse(const char *str, Error **errp);
|
2017-06-16 10:54:45 +02:00
|
|
|
int socket_connect(SocketAddress *addr, Error **errp);
|
2019-08-19 14:48:21 +02:00
|
|
|
int socket_listen(SocketAddress *addr, int num, Error **errp);
|
2016-06-16 21:28:52 +02:00
|
|
|
void socket_listen_cleanup(int fd, Error **errp);
|
2017-04-26 09:36:41 +02: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. */
|
2022-10-21 11:09:06 +02:00
|
|
|
int convert_host_port(struct sockaddr_in *saddr, const char *host,
|
|
|
|
const char *port, Error **errp);
|
2017-09-04 16:35:39 +02:00
|
|
|
int parse_host_port(struct sockaddr_in *saddr, const char *str,
|
|
|
|
Error **errp);
|
2010-04-01 19:57:08 +02:00
|
|
|
int socket_init(void);
|
2006-05-01 00:53:25 +02:00
|
|
|
|
2015-02-27 17:19:33 +01:00
|
|
|
/**
|
|
|
|
* 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
|
2017-04-26 09:36:41 +02:00
|
|
|
* release with a call qapi_free_SocketAddress() when no
|
2015-02-27 17:19:33 +01:00
|
|
|
* longer required.
|
|
|
|
*
|
|
|
|
* Returns: the socket address struct, or NULL on error
|
|
|
|
*/
|
2017-04-26 09:36:41 +02:00
|
|
|
SocketAddress *
|
2015-02-27 17:19:33 +01:00
|
|
|
socket_sockaddr_to_address(struct sockaddr_storage *sa,
|
|
|
|
socklen_t salen,
|
|
|
|
Error **errp);
|
|
|
|
|
2015-05-01 18:36:20 +02:00
|
|
|
/**
|
|
|
|
* 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
|
2017-04-26 09:36:41 +02:00
|
|
|
* release with a call qapi_free_SocketAddress() when no
|
2015-05-01 18:36:20 +02:00
|
|
|
* longer required.
|
|
|
|
*
|
|
|
|
* Returns: the socket address struct, or NULL on error
|
|
|
|
*/
|
2017-04-26 09:36:41 +02:00
|
|
|
SocketAddress *socket_local_address(int fd, Error **errp);
|
2015-05-01 18:36:20 +02:00
|
|
|
|
|
|
|
/**
|
|
|
|
* 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
|
2017-04-26 09:36:41 +02:00
|
|
|
* release with a call qapi_free_SocketAddress() when no
|
2015-05-01 18:36:20 +02:00
|
|
|
* longer required.
|
|
|
|
*
|
|
|
|
* Returns: the socket address struct, or NULL on error
|
|
|
|
*/
|
2017-04-26 09:36:41 +02:00
|
|
|
SocketAddress *socket_remote_address(int fd, Error **errp);
|
2015-05-01 18:36:20 +02:00
|
|
|
|
2017-04-26 09:36:41 +02:00
|
|
|
/**
|
|
|
|
* socket_address_flatten:
|
|
|
|
* @addr: the socket address to flatten
|
|
|
|
*
|
|
|
|
* Convert SocketAddressLegacy to SocketAddress. Caller is responsible
|
|
|
|
* for freeing with qapi_free_SocketAddress().
|
|
|
|
*
|
|
|
|
* Returns: the argument converted to SocketAddress.
|
|
|
|
*/
|
|
|
|
SocketAddress *socket_address_flatten(SocketAddressLegacy *addr);
|
|
|
|
|
2021-06-10 12:07:35 +02:00
|
|
|
/**
|
|
|
|
* socket_address_parse_named_fd:
|
|
|
|
*
|
|
|
|
* Modify @addr, replacing a named fd by its corresponding number.
|
|
|
|
* Needed for callers that plan to pass @addr to a context where the
|
|
|
|
* current monitor is not available.
|
|
|
|
*
|
|
|
|
* Return 0 on success.
|
|
|
|
*/
|
|
|
|
int socket_address_parse_named_fd(SocketAddress *addr, Error **errp);
|
2016-06-29 10:12:57 +02:00
|
|
|
#endif /* QEMU_SOCKETS_H */
|