X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.c;h=ab738a608523b318d1ae8f1f12dd68df6635b127;hb=7c05c7abdb8633dea7e5120d10f01bef55da66db;hp=6b8f52facd694e382cc241179ed96edeb508ddc4;hpb=b9c889efbc310cfe669c497c8c5636ef9ad24934;p=pazpar2-moved-to-github.git

diff --git a/src/eventl.c b/src/eventl.c
index 6b8f52f..ab738a6 100644
--- a/src/eventl.c
+++ b/src/eventl.c
@@ -1,5 +1,5 @@
 /* This file is part of Pazpar2.
- Copyright (C) 2006-2010 Index Data
+ Copyright (C) 2006-2011 Index Data
 
  Pazpar2 is free software; you can redistribute it and/or modify it under
  the terms of the GNU General Public License as published by the Free
@@ -20,7 +20,7 @@
 /*
  * Based on  ParaZ - a simple tool for harvesting performance data for
  * parallel operations using Z39.50.
- * Copyright (C) 2006-2010 Index Data ApS
+ * Copyright (C) 2006-2011 Index Data ApS
  * See LICENSE file for details.
  */
 
@@ -67,12 +67,6 @@ struct iochan_man_s {
     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) {
     iochan_man_t man = xmalloc(sizeof(*man));
     man->channel_list = 0;
@@ -91,13 +85,17 @@ void iochan_man_destroy(iochan_man_t *mp) {
         if ((*mp)->sel_thread)
             sel_thread_destroy((*mp)->sel_thread);
 
+        yaz_mutex_enter((*mp)->iochan_mutex);
         c = (*mp)->channel_list;
+        (*mp)->channel_list = NULL;
+        yaz_mutex_leave((*mp)->iochan_mutex);
         while (c) {
             IOCHAN c_next = c->next;
             xfree(c->name);
             xfree(c);
             c = c_next;
         }
+        yaz_mutex_destroy(&(*mp)->iochan_mutex);
         xfree(*mp);
         *mp = 0;
     }
@@ -162,45 +160,16 @@ 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 */
     {
         IOCHAN p, *nextp;
         IOCHAN start;
+        IOCHAN inv_start;
         fd_set in, out, except;
         int res, max;
         static struct timeval to;
         struct timeval *timeout;
-        static struct iochan_man_iter iter;
 
 //        struct yaz_poll_fd *fds;
         int no_fds = 0;
@@ -211,11 +180,13 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) {
         to.tv_sec = 300;
         to.tv_usec = 0;
 
-        // INV: Start must no change through the loop
+        // INV: start must no change through the loop
 
-        start = iochan_man_get_first(&iter, man);
-        IOCHAN inv_start = start;
-        for (p = start; p; p = iochan_man_get_next(&iter)) {
+        yaz_mutex_enter(man->iochan_mutex);
+        start = man->channel_list;
+        yaz_mutex_leave(man->iochan_mutex);
+        inv_start = start;
+        for (p = start; p; p = p->next) {
             no_fds++;
         }
 //        fds = (struct yaz_poll_fd *) xmalloc(no_fds * sizeof(*fds));
@@ -237,7 +208,7 @@ 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);
+        yaz_log(man->log_level, "max=%d sel_fd=%d", max, man->sel_fd);
 
         if (man->sel_fd != -1) {
             if (man->sel_fd > max)
@@ -271,8 +242,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) {
         }
         if (man->log_level) {
             int no = 0;
-            for (p = iochan_man_get_first(&iter, man); p; p
-                    = iochan_man_get_next(&iter)) {
+            for (p = start; p; p = p->next) {
                 no++;
             }
             yaz_log(man->log_level, "%d channels", no);