Hash :
309fc7c4
        
        Author :
  
        
        Date :
2009-01-21T07:51:25
        
      
New functions to provide sane threading callbacks with pthreads and win32 threading implementations. svn:r1031
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#ifdef WIN32
#include <winsock2.h>
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
#undef WIN32_LEAN_AND_MEAN
#endif
struct event_base;
#include <event2/thread.h>
static void *
evthread_win32_lock_create(void)
{
	CRITICAL_SECTION *lock = mm_malloc(sizeof(CRITICAL_SECTION));
	if (!lock)
		return NULL;
	InitializeCriticalSection(lock);
	return lock;
}
static void
evthread_win32_lock_free(void *_lock)
{
	CRITICAL_SECTION *lock = _lock;
	DeleteCriticalSection(lock);
}
static void
evthread_win32_lock(int mode, void *_lock)
{
	CRITICAL_SECTION *lock = _lock;
	if (0 != (mode & EVTHREAD_LOCK))
		EnterCriticalSection(lock);
	else
		LeaveCriticalSection(lock);
}
static unsigned long
evthread_win32_get_id(void)
{
	return (unsigned long) GetCurrentThreadId();
}
int
evthread_use_windows_threads(struct event_base *base)
{
	evthread_set_lock_create_callbacks(base,
									   evthread_win32_lock_create,
									   evthread_win32_lock_free);
	evthread_set_locking_callback(base, evthread_win32_lock);
	evthread_set_id_callback(base, evthread_win32_get_id);
	return 0;
}