X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fnet%2Fnet.h;h=5e02fc36e7d09a329484ac5bfebf582c8c400cf3;hp=9ad6de56a498b12aab9a5372c9114b5def47b505;hb=158de63fda4e79ce3a632f25d444a1ec66f45d74;hpb=3e9d2361ced4537fd04717f49e153df628ec61bb

diff --git a/ccan/net/net.h b/ccan/net/net.h
index 9ad6de56..5e02fc36 100644
--- a/ccan/net/net.h
+++ b/ccan/net/net.h
@@ -1,6 +1,10 @@
 /* Licensed under BSD-MIT - see LICENSE file for details */
 #ifndef CCAN_NET_H
 #define CCAN_NET_H
+#include <stdbool.h>
+
+struct pollfd;
+
 /**
  * net_client_lookup - look up a network name to connect to.
  * @hostname: the name to look up
@@ -16,6 +20,7 @@
  *	#include <sys/socket.h>
  *	#include <stdio.h>
  *	#include <netdb.h>
+ *	#include <poll.h>
  *	#include <err.h>
  *	...
  *	struct addrinfo *addr;
@@ -48,6 +53,67 @@ struct addrinfo *net_client_lookup(const char *hostname,
  */
 int net_connect(const struct addrinfo *addrinfo);
 
+/**
+ * net_connect_async - initiate connect to a server
+ * @addrinfo: linked list struct addrinfo (usually from net_client_lookup).
+ * @pfds: array of two struct pollfd.
+ *
+ * This begins connecting to a server described by @addrinfo,
+ * and places the one or two file descriptors into pfds[0] and pfds[1].
+ * It returns a valid file descriptor if connect() returned immediately.
+ *
+ * Otherwise it returns -1 and sets errno, most likely EINPROGRESS.
+ * In this case, poll() on pfds and call net_connect_complete().
+ *
+ * Example:
+ *	struct pollfd pfds[2];
+ *	...
+ *	fd = net_connect_async(addr, pfds);
+ *	if (fd < 0 && errno != EINPROGRESS)
+ *		err(1, "Failed to connect to ccan.ozlabs.org");
+ */
+int net_connect_async(const struct addrinfo *addrinfo, struct pollfd *pfds);
+
+/**
+ * net_connect_complete - complete net_connect_async call.
+ * @pfds: array of two struct pollfd handed to net_connect_async.
+ *
+ * When poll() reports some activity, this determines whether a connection
+ * has completed.  If so, it cleans up and returns the connected fd.
+ * Otherwise, it returns -1, and sets errno (usually EINPROGRESS).
+ *
+ * Example:
+ *	// After net_connect_async.
+ *	while (fd < 0 && errno == EINPROGRESS) {
+ *		// Wait for activity...
+ *		poll(pfds, 2, -1);
+ *		fd = net_connect_complete(pfds);
+ *	}
+ *	if (fd < 0)
+ *		err(1, "connecting");
+ *	printf("Connected on fd %i!\n", fd);
+ */
+int net_connect_complete(struct pollfd *pfds);
+
+/**
+ * net_connect_abort - abort a net_connect_async call.
+ * @pfds: array of two struct pollfd handed to net_connect_async.
+ *
+ * Closes the file descriptors.
+ *
+ * Example:
+ *	// After net_connect_async.
+ *	if (poll(pfds, 2, 1000) == 0) { // Timeout.
+ *		net_connect_abort(pfds);
+ *		fd = -1;
+ *	} else {
+ *		fd = net_connect_complete(pfds);
+ *		if (fd < 0)
+ *			err(1, "connecting");
+ *	}
+ */
+void net_connect_abort(struct pollfd *pfds);
+
 /**
  * net_server_lookup - look up a service name to bind to.
  * @service: the service to look up