X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=select.h;fp=select.h;h=c4e141825dd1de3c3de87d5efd9b3004e33bd81e;hp=0000000000000000000000000000000000000000;hb=b0bd74e35e935aa976b68c594def4e8d2c22ef95;hpb=473d6569efcad130f9a5044b182b75a1c07a1eee

diff --git a/select.h b/select.h
new file mode 100644
index 0000000..c4e1418
--- /dev/null
+++ b/select.h
@@ -0,0 +1,62 @@
+
+#define LCR_FD_READ	1
+#define LCR_FD_WRITE	2
+#define LCR_FD_EXCEPT	4
+
+#define MICRO_SECONDS  1000000LL
+
+#define TIME_SMALLER(left, right) \
+        (((left)->tv_sec*MICRO_SECONDS+(left)->tv_usec) <= ((right)->tv_sec*MICRO_SECONDS+(right)->tv_usec))
+
+struct lcr_fd {
+	struct lcr_fd	*next;	/* pointer to next element in list */
+	int		inuse;	/* if in use */
+	int		fd;	/* file descriptior if in use */
+	int		when;	/* select on what event */
+	int		(*cb)(struct lcr_fd *fd, unsigned int what, void *instance, int index); /* callback */
+	void		*cb_instance;
+	int		cb_index;
+};
+
+#define register_fd(a, b, c, d, e) _register_fd(a, b, c, d, e, __func__);
+int _register_fd(struct lcr_fd *fd, int when, int (*cb)(struct lcr_fd *fd, unsigned int what, void *instance, int index), void *instance, int index, const char *func);
+#define unregister_fd(a) _unregister_fd(a, __func__);
+void _unregister_fd(struct lcr_fd *fd, const char *func);
+int select_main(int polling, int *global_change, void (*lock)(void), void (*unlock)(void));
+
+
+struct lcr_timer {
+	struct lcr_timer *next;	/* pointer to next element in list */
+	int		inuse;	/* if in use */
+	int		active;	/* if timer is currently active */
+	struct timeval	timeout; /* timestamp when to timeout */
+	int		(*cb)(struct lcr_timer *timer, void *instance, int index); /* callback */
+	void		*cb_instance;
+	int		cb_index;
+};
+
+#define add_timer(a, b, c, d) _add_timer(a, b, c, d, __func__);
+int _add_timer(struct lcr_timer *timer, int (*cb)(struct lcr_timer *timer, void *instance, int index), void *instance, int index, const char *func);
+#define del_timer(a) _del_timer(a, __func__);
+void _del_timer(struct lcr_timer *timer, const char *func);
+void schedule_timer(struct lcr_timer *timer, int seconds, int microseconds);
+void unsched_timer(struct lcr_timer *timer);
+
+
+struct lcr_work {
+	struct lcr_work *next;	/* pointer to next element in list */
+	struct lcr_work *prev_event, *next_event; /* pointer to previous/next event, if triggered */
+	int		inuse;	/* if in use */
+	int		active;	/* if timer is currently active */
+	int		(*cb)(struct lcr_work *work, void *instance, int index); /* callback */
+	void		*cb_instance;
+	int		cb_index;
+};
+
+#define add_work(a, b, c, d) _add_work(a, b, c, d, __func__);
+int _add_work(struct lcr_work *work, int (*cb)(struct lcr_work *work, void *instance, int index), void *instance, int index, const char *func);
+#define del_work(a) _del_work(a, __func__);
+void _del_work(struct lcr_work *work, const char *func);
+void trigger_work(struct lcr_work *work);
+
+