PostgreSQL/libpqxx Class Generator

/***************************************************************************
 SyncObject.h - Declaration of a synchroniser - similar to Java's
                object synchronisation functionality.

 begin     : August 2006
 copyright : (C) 2006 by Phil Cairns
 email     : oti169@hotmail.com
 $Id: SyncObject.h 2080 2006-08-18 01:53:19Z phil $

 This code may be used in compiled form in any way you desire (including
 commercial use). The code may be redistributed unmodified by any means
 providing it is not sold for profit without the authors written consent,
 and providing that this notice and the authors name and all copyright
 notices remains intact.

 This software is provided "as is" without express or implied warranty. Use
 it at your own risk!
 ***************************************************************************/

#pragma once

namespace Pagaros
{
	class SyncObject
	{
	public:
		SyncObject(void)
		{
			_mutex = CreateMutex(0, FALSE, 0);
			_eventOne = CreateEvent(0, FALSE, FALSE, 0);
			_eventAll = CreateEvent(0, TRUE, FALSE, 0);
		}

		~SyncObject(void)
		{
			CloseHandle(_eventOne);
			CloseHandle(_eventAll);
			CloseHandle(_mutex);
		}

		bool lock(void)
		{
			//ATLTRACE("Locking ... ");
			return (WAIT_OBJECT_0 == WaitForSingleObject(_mutex, INFINITE));
		}

		bool unlock(void)
		{
			//ATLTRACE("unlocked\n");
			return (TRUE == ReleaseMutex(_mutex));
		}

		virtual bool wait(DWORD millis = INFINITE)
		{
			HANDLE	handles[2] = { _eventOne, _eventAll };
			DWORD dwRet = WaitForMultipleObjects(2, handles, FALSE, millis);
			return ((WAIT_OBJECT_0 == dwRet) || (WAIT_OBJECT_0 + 1 == dwRet));
		}

		bool notify(void)
		{
			return (TRUE == SetEvent(_eventOne));
		}

		bool notifyAll(void)
		{
			return (TRUE == SetEvent(_eventAll));
		}

		bool resetAll(void)
		{
			return (TRUE == ResetEvent(_eventAll));
		}

	protected:
		HANDLE getEventOne() const { return _eventOne; }
		HANDLE getEventAll() const { return _eventAll; }
		HANDLE getMutex() const { return _mutex; }

	private:
		HANDLE	_mutex;
		HANDLE	_eventOne;
		HANDLE	_eventAll;
	};

	class SyncLock
	{
	public:
		SyncLock(SyncObject* so) : _so(so) { _so->lock(); }
		SyncLock(SyncObject& so) : _so(&so) { _so->lock(); }
		~SyncLock() { _so->unlock(); }
		bool wait(DWORD millis = INFINITE)
		{
			bool ret = false;
			_so->unlock();
			ret = _so->wait(millis);
			_so->lock();
			return ret;
		}
		void notify()
		{
			_so->notify();
		}
		void notifyAll()
		{
			_so->notifyAll();
		}
		void resetAll()
		{
			_so->resetAll();
		}
	private:
		SyncObject* _so;
	};
};