*nix emulation of Win32 *Event() functions (untested).

src/xpdev/GNUmakefile

@@ -4,6 +4,7 @@ include $(SRC_ROOT)/build/Common.gmake
 ifdef XP_SEM
 	MTOBJS	+=	$(MTOBJODIR)$(DIRSEP)xpsem$(OFILE)
 endif
+MTOBJS	+=	$(MTOBJODIR)$(DIRSEP)xpevent$(OFILE)
 
 MT_CFLAGS += -DLINK_LIST_THREADSAFE
 

src/xpdev/xpevent.c

+/* xpevent.c */
+
+/* *nix emulation of Win32 *Event API */
+
+/* $Id$ */
+
+/****************************************************************************
+ * @format.tab-size 4		(Plain Text/Source Code File Header)			*
+ * @format.use-tabs true	(see http://www.synchro.net/ptsc_hdr.html)		*
+ *																			*
+ * Copyright 2005 Rob Swindell - http://www.synchro.net/copyright.html		*
+ *																			*
+ * This library is free software; you can redistribute it and/or			*
+ * modify it under the terms of the GNU Lesser General Public License		*
+ * as published by the Free Software Foundation; either version 2			*
+ * of the License, or (at your option) any later version.					*
+ * See the GNU Lesser General Public License for more details: lgpl.txt or	*
+ * http://www.fsf.org/copyleft/lesser.html									*
+ *																			*
+ * Anonymous FTP access to the most recent released source is available at	*
+ * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net	*
+ *																			*
+ * Anonymous CVS access to the development source and modification history	*
+ * is available at cvs.synchro.net:/cvsroot/sbbs, example:					*
+ * cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs login			*
+ *     (just hit return, no password is necessary)							*
+ * cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs checkout src		*
+ *																			*
+ * For Synchronet coding style and modification guidelines, see				*
+ * http://www.synchro.net/source.html										*
+ *																			*
+ * You are encouraged to submit any modifications (preferably in Unix diff	*
+ * format) via e-mail to mods@synchro.net									*
+ *																			*
+ * Note: If this box doesn't appear square, then you need to fix your tabs.	*
+ ****************************************************************************/
+
+#include <stdio.h>		/* NULL */
+#include "xpevent.h"
+
+#define _EVENT_CHECK_VALIDITY(event)		\
+	if (event==NULL || (*(event))->magic != EVENT_MAGIC) {	\
+		errno = EINVAL;			\
+		retval = FALSE;			\
+		goto RETURN;			\
+	}
+
+xpevent_t
+CreateEvent(void *sec, BOOL bManualReset, BOOL bInitialState, void *name)
+{
+	xpevent_t	event;
+
+	event = (xpevent_t)malloc(sizeof(struct xpevent));
+	if (event == NULL) {
+		errno = ENOSPC;
+		goto RETURN;
+	}
+
+	/*
+	 * Initialize
+	 */
+	if (pthread_mutex_init(&event->lock, NULL) != 0) {
+		free(event);
+		event=NULL;
+		errno = ENOSPC;
+		goto RETURN;
+	}
+
+	if (pthread_cond_init(&event->gtzero, NULL) != 0) {
+		pthread_mutex_destroy(&event->lock);
+		free(event);
+		event=NULL;
+		errno = ENOSPC;
+		goto RETURN;
+	}
+
+	event->mreset=bManualReset;
+	event->value=bInitialState;
+	event->nwaiters = 0;
+	event->magic=EVENT_MAGIC;
+
+  RETURN:
+	return event;
+}
+
+BOOL
+SetEvent(xpevent_t *event)
+{
+	BOOL	retval;
+
+	_EVENT_CHECK_VALIDITY(event);
+
+	pthread_mutex_lock(&(*event)->lock);
+
+	(*event)->value=TRUE;
+	if ((*event)->nwaiters > 0) {
+		/*
+		 * We must use pthread_cond_broadcast() rather than
+		 * pthread_cond_signal() in order to assure that the highest
+		 * priority thread is run by the scheduler, since
+		 * pthread_cond_signal() signals waiting threads in FIFO order.
+		 */
+		pthread_cond_broadcast(&(*event)->gtzero);
+	}
+
+	pthread_mutex_unlock(&(*event)->lock);
+
+	retval = TRUE;
+  RETURN:
+	return retval;
+}
+
+BOOL
+ResetEvent(xpevent_t *event)
+{
+	BOOL	retval=FALSE;
+
+	_EVENT_CHECK_VALIDITY(event);
+
+	pthread_mutex_lock(&(*event)->lock);
+
+	(*event)->value=FALSE;
+
+	pthread_mutex_unlock(&(*event)->lock);
+
+	retval = TRUE;
+  RETURN:
+	return retval;
+}
+
+BOOL
+CloseEvent(xpevent_t *event)
+{
+	BOOL retval=FALSE;
+
+	_EVENT_CHECK_VALIDITY(event);
+
+	/* Make sure there are no waiters. */
+	pthread_mutex_lock(&(*event)->lock);
+	if ((*event)->nwaiters > 0) {
+		pthread_mutex_unlock(&(*event)->lock);
+		errno = EBUSY;
+		retval = FALSE;
+		goto RETURN;
+	}
+	pthread_mutex_unlock(&(*event)->lock);
+	
+	pthread_mutex_destroy(&(*event)->lock);
+	pthread_cond_destroy(&(*event)->gtzero);
+	(*event)->magic = 0;
+
+	free(*event);
+
+	retval = 0;
+  RETURN:
+	return retval;
+}
+
+DWORD
+WaitEvent(xpevent_t *event, DWORD ms)
+{
+	DWORD	retval=WAIT_FAILED;
+	struct timespec abstime;
+	struct timeval currtime;
+
+	if (event==NULL || (*(event))->magic != EVENT_MAGIC) {
+		errno = EINVAL;
+		retval = WAIT_FAILED;
+		goto RETURN;
+	}
+
+	if(ms && ms!=INFINITE) {
+		gettimeofday(&currtime,NULL);
+		abstime.tv_sec=currtime.tv_sec + (currtime.tv_usec/1000 + ms)/1000;
+		abstime.tv_nsec=(currtime.tv_usec*1000 + ms*1000000)%1000000000;
+	}
+	
+	pthread_mutex_lock(&(*event)->lock);
+
+	while (!((*event)->value)) {
+		(*event)->nwaiters++;
+		switch(ms) {
+			case 0:
+				if((*event)->value)
+					retval=0;
+				else
+					retval=WAIT_TIMEOUT;
+				goto DONE;
+				break;
+			case INFINITE:
+				retval=pthread_cond_wait(&(*event)->gtzero, &(*event)->lock);
+				break;
+			default:
+				retval=pthread_cond_timedwait(&(*event)->gtzero, &(*event)->lock, &abstime);
+				if(retval)  {
+					if(retval==ETIMEDOUT)
+						retval=WAIT_TIMEOUT;
+					else {
+						errno=retval;
+						retval=WAIT_FAILED;
+					}
+					goto DONE;
+				}
+		}
+		(*event)->nwaiters--;
+	}
+
+  DONE:
+
+	if(retval==0) {
+		retval=WAIT_OBJECT_0;
+		if(!(&(*event)->mreset))
+			(*event)->value=FALSE;
+	}
+
+	pthread_mutex_unlock(&(*event)->lock);
+
+  RETURN:
+
+	pthread_testcancel();
+	return retval;
+}

src/xpdev/xpevent.h

+/* xpevent.h */
+
+/* *nix emulation of Win32 *Event API */
+
+/* $Id$ */
+
+/****************************************************************************
+ * @format.tab-size 4		(Plain Text/Source Code File Header)			*
+ * @format.use-tabs true	(see http://www.synchro.net/ptsc_hdr.html)		*
+ *																			*
+ * Copyright 2005 Rob Swindell - http://www.synchro.net/copyright.html		*
+ *																			*
+ * This library is free software; you can redistribute it and/or			*
+ * modify it under the terms of the GNU Lesser General Public License		*
+ * as published by the Free Software Foundation; either version 2			*
+ * of the License, or (at your option) any later version.					*
+ * See the GNU Lesser General Public License for more details: lgpl.txt or	*
+ * http://www.fsf.org/copyleft/lesser.html									*
+ *																			*
+ * Anonymous FTP access to the most recent released source is available at	*
+ * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net	*
+ *																			*
+ * Anonymous CVS access to the development source and modification history	*
+ * is available at cvs.synchro.net:/cvsroot/sbbs, example:					*
+ * cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs login			*
+ *     (just hit return, no password is necessary)							*
+ * cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs checkout src		*
+ *																			*
+ * For Synchronet coding style and modification guidelines, see				*
+ * http://www.synchro.net/source.html										*
+ *																			*
+ * You are encouraged to submit any modifications (preferably in Unix diff	*
+ * format) via e-mail to mods@synchro.net									*
+ *																			*
+ * Note: If this box doesn't appear square, then you need to fix your tabs.	*
+ ****************************************************************************/
+
+#ifndef _XPEVENT_H_
+#define _XPEVENT_H_
+
+#include <pthread.h>
+#include "gen_defs.h"
+
+/* Opaque type definition. */
+struct xpevent;
+typedef struct xpevent *xpevent_t;
+
+#if defined(__cplusplus)
+extern "C" {
+#endif
+xpevent_t	CreateEvent(void *sec, BOOL bManualReset, BOOL bInitialState, void *name);
+BOOL		SetEvent(xpevent_t *event);
+BOOL		ResetEvent(xpevent_t *event);
+BOOL		CloseEvent(xpevent_t *event);
+DWORD		WaitEvent(xpevent_t *event, DWORD ms);
+#if defined(__cplusplus)
+}
+#endif
+
+struct xpevent {
+#define EVENT_MAGIC       ((u_int32_t) 0x09fa4014)
+        u_int32_t       magic;
+        pthread_mutex_t lock;
+        pthread_cond_t  gtzero;
+        BOOL			value;
+		BOOL			mreset;
+        DWORD			nwaiters;
+};
+
+#define INFINITE 	((DWORD)(-1))
+enum {
+	 WAIT_OBJECT_0
+	,WAIT_TIMEOUT
+	,WAIT_FAILED
+};
+
+#endif