From 469bbcf0701e1eb8a6670c23145b0da87357e178 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Sun, 25 Mar 2012 20:00:08 +0000
Subject: Code is all reorganized.  We're about ready to release.  I should
 write up a little explenation of the arrangement.

---
 src/synchroheap.h | 151 ------------------------------------------------------
 1 file changed, 151 deletions(-)
 delete mode 100644 src/synchroheap.h

(limited to 'src/synchroheap.h')

diff --git a/src/synchroheap.h b/src/synchroheap.h
deleted file mode 100644
index 4dd898d..0000000
--- a/src/synchroheap.h
+++ /dev/null
@@ -1,151 +0,0 @@
-/*
- * Copyright (C) 2007-2011 Xagasoft, All rights reserved.
- *
- * This file is part of the libbu++ library and is released under the
- * terms of the license contained in the file LICENSE.
- */
-
-#ifndef BU_SYNCHRO_HEAP_H
-#define BU_SYNCHRO_HEAP_H
-
-#include "bu/heap.h"
-#include "bu/mutex.h"
-#include "bu/condition.h"
-
-namespace Bu
-{
-	template<typename item, typename cmpfunc=__basicLTCmp<item>,
-		typename itemalloc=std::allocator<item> >
-	class SynchroHeap
-	{
-	public:
-		SynchroHeap()
-		{
-		}
-
-		virtual ~SynchroHeap()
-		{
-		}
-
-		void enqueue( item i )
-		{
-			imData.lock();
-			hData.enqueue( i );
-			icBlock.signal();
-			imData.unlock();
-		}
-
-		item dequeue( bool bBlock=false )
-		{
-			imData.lock();
-			if( hData.isEmpty() )
-			{
-				imData.unlock();
-
-				if( bBlock )
-				{
-					icBlock.lock();
-
-					while( hData.isEmpty() )
-						icBlock.wait();
-
-					imData.lock();
-					try
-					{
-						item iRet = hData.dequeue();
-						imData.unlock();
-						icBlock.unlock();
-						return iRet;
-					}
-					catch(...)
-					{
-						imData.unlock();
-						icBlock.unlock();
-						throw;
-					}
-				}
-				throw HeapException("Heap empty.");
-			}
-			else
-			{
-				try
-				{
-					item iRet = hData.dequeue();
-					imData.unlock();
-					return iRet;
-				}
-				catch(...)
-				{
-					imData.unlock();
-					throw;
-				}
-			}
-		}
-
-		item dequeue( int iSec, int iUSec )
-		{
-			imData.lock();
-			if( hData.isEmpty() )
-			{
-				imData.unlock();
-
-				icBlock.lock();
-
-				icBlock.wait( iSec, iUSec );
-
-				imData.lock();
-				try
-				{
-					item iRet = hData.dequeue();
-					imData.unlock();
-					icBlock.unlock();
-					return iRet;
-				}
-				catch(...)
-				{
-					imData.unlock();
-					icBlock.unlock();
-					throw;
-				}
-			}
-			else
-			{
-				try
-				{
-					item iRet = hData.dequeue();
-					imData.unlock();
-					return iRet;
-				}
-				catch(...)
-				{
-					imData.unlock();
-					throw;
-				}
-			}
-		}
-		
-		bool isEmpty()
-		{
-			imData.lock();
-			bool bRet = hData.isEmpty();
-			imData.unlock();
-			return bRet;
-		}
-
-		int getSize()
-		{
-			imData.lock();
-			int iRet = hData.getSize();
-			imData.unlock();
-			return iRet;
-		}
-
-	private:
-		Heap< item, cmpfunc, itemalloc > hData;
-		Mutex imData;
-		Condition icBlock;
-	};
-};
-
-#endif
-
-- 
cgit v1.2.3