X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=server%2Fstatserv.c;h=11a7b5471946e323eadce661efd26db0ad7b5648;hb=eaf27c9dc97e048dcd9a90dc05aa8133b3020c5b;hp=c5228f546fe01f20da10521786f0bc71998b6eba;hpb=7acd51b7cdffca5ad92a777d2c6e8e9bae1f9fd3;p=yaz-moved-to-github.git

diff --git a/server/statserv.c b/server/statserv.c
index c5228f5..11a7b54 100644
--- a/server/statserv.c
+++ b/server/statserv.c
@@ -7,7 +7,13 @@
  *   Chas Woodfield, Fretwell Downing Informatics.
  *
  * $Log: statserv.c,v $
- * Revision 1.64  2000-04-05 07:39:55  adam
+ * Revision 1.66  2000-10-06 12:00:28  adam
+ * Fixed Handle leak for WIN32.
+ *
+ * Revision 1.65  2000/09/04 08:58:15  adam
+ * Added prefix yaz_ for most logging utility functions.
+ *
+ * Revision 1.64  2000/04/05 07:39:55  adam
  * Added shared library support (libtool).
  *
  * Revision 1.63  2000/03/20 19:06:25  adam
@@ -449,9 +455,9 @@ void statserv_closedown()
     }
 }
 
-int __stdcall event_loop_thread (IOCHAN iochan)
+void event_loop_thread (IOCHAN iochan)
 {
-    return event_loop (&iochan);
+    event_loop (&iochan);
 }
 
 static void listener(IOCHAN h, int event)
@@ -459,7 +465,7 @@ static void listener(IOCHAN h, int event)
     COMSTACK line = (COMSTACK) iochan_getdata(h);
     association *newas;
     int res;
-    HANDLE NewHandle;
+    HANDLE newHandle;
 
     if (event == EVENT_INPUT)
     {
@@ -479,7 +485,6 @@ static void listener(IOCHAN h, int event)
     	COMSTACK new_line;
     	IOCHAN new_chan;
 	char *a = NULL;
-        DWORD ThreadId;
 
 	if (!(new_line = cs_accept(line)))
 	{
@@ -507,20 +512,11 @@ static void listener(IOCHAN h, int event)
 	yaz_log(LOG_DEBUG, "Setting timeout %d", control_block.idle_timeout);
 	iochan_setdata(new_chan, newas);
 	iochan_settimeout(new_chan, control_block.idle_timeout * 60);
-#ifndef WIN32
-	yaz_log(LOG_DEBUG, "Determining client address");
-	a = cs_addrstr(new_line);
-	yaz_log(LOG_LOG, "Accepted connection from %s", a ? a : "[Unknown]");
-#endif
+
 	/* Now what we need todo is create a new thread with this iochan as
 	   the parameter */
-	/* if (CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)event_loop_thread,
-	   new_chan, 0, &ThreadId) == NULL) */
-	/* Somehow, somewhere we need to store this thread id, otherwise we
-	   won't be able to close cleanly */
-        NewHandle = (HANDLE)_beginthreadex(NULL, 0, event_loop_thread,
-					   new_chan, 0, &ThreadId);
-        if (NewHandle == (HANDLE)-1)
+        newHandle = (HANDLE) _beginthread(event_loop_thread, 0, new_chan);
+        if (newHandle == (HANDLE) -1)
 	{
 	    
 	    yaz_log(LOG_FATAL|LOG_ERRNO, "Failed to create new thread.");
@@ -528,9 +524,9 @@ static void listener(IOCHAN h, int event)
             return;
 	}
         /* We successfully created the thread, so add it to the list */
-        statserv_add(NewHandle, new_chan);
+        statserv_add(newHandle, new_chan);
 
-        yaz_log(LOG_DEBUG, "Created new thread, iochan %p", new_chan);
+        yaz_log(LOG_DEBUG, "Created new thread, id = %ld iochan %p",(long) newHandle, new_chan);
         iochan_setflags(h, EVENT_INPUT | EVENT_EXCEPT); /* reset listener */
     }
     else
@@ -541,7 +537,7 @@ static void listener(IOCHAN h, int event)
     }
 }
 
-#else /* WIN32 */
+#else /* ! WIN32 */
 
 /* To save having an #ifdef in event_loop we need to define this empty function */
 void statserv_remove(IOCHAN pIOChannel)
@@ -609,7 +605,7 @@ static void listener(IOCHAN h, int event)
 		    }
 		}
 		sprintf(nbuf, "%s(%d)", me, getpid());
-		log_init(control_block.loglevel, nbuf, 0);
+		yaz_log_init(control_block.loglevel, nbuf, 0);
 	    }
 	    else /* parent */
 	    {
@@ -971,11 +967,11 @@ int check_options(int argc, char **argv)
 	    break;
 	case 'l':
 	    strcpy(control_block.logfile, arg ? arg : "");
-	    log_init(control_block.loglevel, me, control_block.logfile);
+	    yaz_log_init(control_block.loglevel, me, control_block.logfile);
 	    break;
 	case 'v':
-	    control_block.loglevel = log_mask_str(arg);
-	    log_init(control_block.loglevel, me, control_block.logfile);
+	    control_block.loglevel = yaz_log_mask_str(arg);
+	    yaz_log_init(control_block.loglevel, me, control_block.logfile);
 	    break;
 	case 'a':
 	    strcpy(control_block.apdufile, arg ? arg : "");