X-Git-Url: http://lists.indexdata.com/cgi-bin?a=blobdiff_plain;f=src%2Feventl.c;h=f178015e980f8633eb4aa85d63e782d090986307;hb=03e77a36926d8db74ac218397ddce9ccf181a4d9;hp=1d72235e67a095a946a7487f8e8d6471dbdd7fd7;hpb=e230ff7e920fc1b9a997e5edc64b8946e41a0d33;p=pazpar2-moved-to-github.git

diff --git a/src/eventl.c b/src/eventl.c
index 1d72235..f178015 100644
--- a/src/eventl.c
+++ b/src/eventl.c
@@ -32,6 +32,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 #include <config.h>
 #endif
 
+#include <math.h>
 #include <stdio.h>
 #include <assert.h>
 
@@ -52,6 +53,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 #include <yaz/log.h>
 #include <yaz/comstack.h>
 #include <yaz/xmalloc.h>
+#include <yaz/mutex.h>
 #include "eventl.h"
 #include "sel_thread.h"
 
@@ -61,6 +63,13 @@ struct iochan_man_s {
     int sel_fd;
     int no_threads;
     int log_level;
+    YAZ_MUTEX iochan_mutex;
+};
+
+struct iochan_man_iter {
+    iochan_man_t man;
+    IOCHAN current; 
+    int first;
 };
 
 iochan_man_t iochan_man_create(int no_threads)
@@ -71,7 +80,8 @@ iochan_man_t iochan_man_create(int no_threads)
     man->sel_fd = -1;
     man->no_threads = no_threads;
     man->log_level = yaz_log_module_level("iochan");
-
+    man->iochan_mutex = 0;
+    yaz_mutex_create(&man->iochan_mutex);
     return man;
 }
 
@@ -99,8 +109,11 @@ void iochan_man_destroy(iochan_man_t *mp)
 void iochan_add(iochan_man_t man, IOCHAN chan)
 {
     chan->man = man;
+    yaz_mutex_enter(man->iochan_mutex);
+    yaz_log(man->log_level, "iochan_add : chan=%p channel list=%p", chan, man->channel_list);
     chan->next = man->channel_list;
     man->channel_list = chan;
+    yaz_mutex_leave(man->iochan_mutex);
 }
 
 IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags,
@@ -160,6 +173,33 @@ static void run_fun(iochan_man_t man, IOCHAN p)
     }
 }
 
+static IOCHAN iochan_man_get_first(struct iochan_man_iter *iter, iochan_man_t man) {
+    iter->man = man;
+    iter->first = 1;
+    yaz_mutex_enter(man->iochan_mutex);
+    iter->current = man->channel_list;
+    yaz_log(man->log_level, "iochan_man_get_first : chan=%p ", iter->current);
+    if (!iter->current)
+        yaz_mutex_leave(man->iochan_mutex);
+    return iter->current;
+}
+
+static IOCHAN iochan_man_get_next(struct iochan_man_iter *iter) {
+    IOCHAN current = NULL, next = NULL;
+    current = iter->current;
+    assert(current);
+    if (current) {
+        next = current->next;
+        iter->current = iter->current->next;
+        if (iter->first) {
+            yaz_log(iter->man->log_level, "iochan_man_get_next : chan=%p next=%p", current, next);
+            iter->first = 0;
+            yaz_mutex_leave(iter->man->iochan_mutex);
+        }
+    }
+    return iter->current;
+}
+
 static int event_loop(iochan_man_t man, IOCHAN *iochans)
 {
     do /* loop as long as there are active associations to process */
@@ -167,8 +207,9 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
     	IOCHAN p, *nextp;
 	fd_set in, out, except;
 	int res, max;
-	static struct timeval nullto = {0, 0}, to;
-	struct timeval *timeout;
+        static struct timeval to;
+        struct timeval *timeout;
+        static struct iochan_man_iter iter; 
 
 	FD_ZERO(&in);
 	FD_ZERO(&out);
@@ -177,7 +218,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
 	to.tv_sec = 300;
 	to.tv_usec = 0;
 	max = 0;
-    	for (p = *iochans; p; p = p->next)
+    	for (p = iochan_man_get_first(&iter, man); p; p = iochan_man_get_next(&iter) )
     	{
             if (p->thread_users > 0)
                 continue;
@@ -198,6 +239,8 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
 	    if (p->fd > max)
 	        max = p->fd;
 	}
+        yaz_log(man->log_level, "max=%d nofds=%d", max, man->sel_fd);
+        
         if (man->sel_fd != -1)
         {
             if (man->sel_fd > max)
@@ -236,11 +279,12 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
         if (man->log_level)
         {
             int no = 0;
-            for (p = *iochans; p; p = p->next)
+            for (p = iochan_man_get_first(&iter, man); p; p = iochan_man_get_next(&iter)) {
                 no++;
+            }
             yaz_log(man->log_level, "%d channels", no);
         }
-        for (p = *iochans; p; p = p->next)
+        for (p = iochan_man_get_first(&iter, man); p; p = iochan_man_get_next(&iter))
         {
             time_t now = time(0);
             
@@ -281,6 +325,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
             }
             run_fun(man, p);
 	}
+        yaz_mutex_enter(man->iochan_mutex);
         for (nextp = iochans; *nextp; )
         {
             IOCHAN p = *nextp;
@@ -293,6 +338,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans)
             else
                 nextp = &p->next;
         }
+        yaz_mutex_leave(man->iochan_mutex);
     }
     while (*iochans);
     return 0;
@@ -310,6 +356,18 @@ void iochan_man_events(iochan_man_t man)
     event_loop(man, &man->channel_list);
 }
 
+void pazpar2_sleep(double d)
+{
+#ifdef WIN32
+    Sleep( (DWORD) (d * 1000));
+#else
+    struct timeval tv;
+    tv.tv_sec = floor(d);
+    tv.tv_usec = (d - floor(d)) * 1000000;
+    select(0, 0, 0, 0, &tv);
+#endif
+}
+
 /*
  * Local variables:
  * c-basic-offset: 4