libtf: major redesign startedHEADmaster

the idea is to make libtf completely multi-threaded. meaning each
fiber can be running concurrently in separate thread. quite a bit
of framework is added for this and some atomic helpers are already
introduced. however, io polling is busy polling now (will be soon
in own thread) and timeouts are still more or less broken. oh, and
the multithreading core is not there yet. basically we are currently
mostly broken ;)

1 files changed, 11 insertions, 18 deletions

diff --git a/include/libtf/io.h b/include/libtf/io.h
index 0d34421..d1098e3 100644
--- a/include/libtf/io.h
+++ b/include/libtf/io.h
@@ -21,10 +21,12 @@
 #include <libtf/defines.h>
 
 /* Flags for tf_open_fd() */
-#define TF_FD_AUTOCLOSE			1
-#define TF_FD_STREAM_ORIENTED		2
-#define TF_FD_SET_CLOEXEC		4
-#define TF_FD_ALREADY_NONBLOCKING	8
+#define TF_FD_READ			TF_BIT(0)
+#define TF_FD_WRITE			TF_BIT(1)
+#define TF_FD_AUTOCLOSE			TF_BIT(2)
+#define TF_FD_STREAM_ORIENTED		TF_BIT(3)
+#define TF_FD_SET_CLOEXEC		TF_BIT(4)
+#define TF_FD_ALREADY_NONBLOCKING	TF_BIT(5)
 
 struct tf_sockaddr {
 	union {
@@ -37,23 +39,14 @@ struct tf_sockaddr {
 struct tf_fd {
 	int fd;
 	unsigned int flags;
-	/* Single waiter -- would be relatively trivial to modify to allow
-	 * multiple waiters, if someone actually needs it */
-	unsigned int events;
-	void *waiting_fiber;
+	struct tf_fiber *fiber;
 };
 
-#define TF_POLL_READ	1
-#define TF_POLL_WRITE	2
-
 struct tf_poll_hooks {
-	void (*init)(void);
-	int  (*poll)(tf_mtime_diff_t timeout);
-	void (*close)(void);
-	int  (*fd_created)(struct tf_fd *fd);
-	int  (*fd_destroyed)(struct tf_fd *fd);
-	void (*fd_monitor)(struct tf_fd *fd, int events);
-	void (*fd_unmonitor)(struct tf_fd *fd);
+	void *	(*create)(void);
+	int	(*fd_created)(void *fiber, struct tf_fd *fd);
+	int	(*fd_destroyed)(void *fiber, struct tf_fd *fd);
+	void	(*fd_rearm)(void *fiber, struct tf_fd *fd);
 };
 
 int tf_open_fd(struct tf_fd *fd, int kfd, int flags);