Add application flags in the reactor fd map

The new app flags allow the code using a reactor to mark and check the existing fds, without interfering with the reactor internals

Author: bogdan-iancu

io_wait.c

@@ -756,3 +756,32 @@ void fix_poll_method( enum poll_types *poll_method )
 }
 
 
+int io_set_app_flag( io_wait_h *h , int type, int app_flag)
+{
+	int i;
+	int res=0;
+
+	for( i=0 ; i<h->fd_no ; i++) {
+			if (h->fd_hash[i].fd<=0 && h->fd_hash[i].type==type) {
+				h->fd_hash[i].app_flags |= app_flag;
+				res = 1;
+			}
+	}
+	return res;
+}
+
+
+int io_check_app_flag( io_wait_h *h , int app_flag)
+{
+	int i;
+
+	for( i=0 ; i<h->fd_no ; i++) {
+			if ( h->fd_hash[i].fd<=0 &&
+			(h->fd_hash[i].app_flags & app_flag) )
+				return 1;
+	}
+	/* nothing found, return false*/
+	return 0;
+
+}
+

io_wait.h

@@ -109,6 +109,8 @@ struct fd_map {
 	int flags;            /* so far used to indicate whether we should 
 	                       * read, write or both ; last 4 are reserved for 
 	                       * internal usage */
+	int app_flags;        /* flags to be used by upper layer apps, not by
+	                       * the reactor */
 };
 
 
@@ -838,5 +840,9 @@ int init_io_wait(io_wait_h* h, char *name, int max_fd,
 /*! \brief destroys everything init_io_wait allocated */
 void destroy_io_wait(io_wait_h* h);
 
+int io_set_app_flag( io_wait_h *h , int type, int app_flag);
+
+int io_check_app_flag( io_wait_h *h , int app_flag);
+
 
 #endif

reactor_defs.h

@@ -101,5 +101,11 @@ int init_reactor_size(void);
 #define reactor_is_empty() \
 	(_worker_io.fd_no==0)
 
+#define reactor_set_app_flag( _type, _app_flag) \
+	io_set_app_flag( &_worker_io , _type, _app_flag)
+
+#define reactor_check_app_flag(_app_flag) \
+	io_check_app_flag( &_worker_io , _app_flag)
+
 #endif