From ec05778d5718a7912e506764d443a78d6a6179e3 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Mon, 5 Nov 2012 22:41:51 +0000
Subject: Converted tabs to spaces with tabconv.

---
 src/tests/synchroqueue.cpp | 198 ++++++++++++++++++++++-----------------------
 1 file changed, 99 insertions(+), 99 deletions(-)

(limited to 'src/tests/synchroqueue.cpp')

diff --git a/src/tests/synchroqueue.cpp b/src/tests/synchroqueue.cpp
index 980a4a3..9e8c787 100644
--- a/src/tests/synchroqueue.cpp
+++ b/src/tests/synchroqueue.cpp
@@ -5,14 +5,14 @@
 class Thing
 {
 public:
-	Thing( int x ) :
-		x( x ),
-		y( 0 )
-	{
-	}
-
-	int x;
-	int y;
+    Thing( int x ) :
+        x( x ),
+        y( 0 )
+    {
+    }
+
+    int x;
+    int y;
 };
 
 typedef Bu::SynchroQueue<Thing *> ThingQueue;
@@ -23,109 +23,109 @@ Bu::Condition cWorkDone;
 
 void workDone()
 {
-	mWorkDone.lock();
-	iWorkDone--;
-	if( iWorkDone == 0 )
-	{
-		mWorkDone.unlock();
-		cWorkDone.lock();
-		cWorkDone.signal();
-		cWorkDone.unlock();
-		return;
-	}
-	mWorkDone.unlock();
+    mWorkDone.lock();
+    iWorkDone--;
+    if( iWorkDone == 0 )
+    {
+        mWorkDone.unlock();
+        cWorkDone.lock();
+        cWorkDone.signal();
+        cWorkDone.unlock();
+        return;
+    }
+    mWorkDone.unlock();
 }
 
 class ThingEater : public Bu::Thread
 {
 public:
-	ThingEater( ThingQueue &qThing ) :
-		qThing( qThing )
-	{
-	}
-
-	bool bRunning;
-
-	void setRunning( bool b )
-	{
-		mRunning.lock();
-		bRunning = b;
-		mRunning.unlock();
-	}
-
-	bool isRunning()
-	{
-		mRunning.lock();
-		bool b = bRunning;
-		mRunning.unlock();
-		return b;
-	}
+    ThingEater( ThingQueue &qThing ) :
+        qThing( qThing )
+    {
+    }
+
+    bool bRunning;
+
+    void setRunning( bool b )
+    {
+        mRunning.lock();
+        bRunning = b;
+        mRunning.unlock();
+    }
+
+    bool isRunning()
+    {
+        mRunning.lock();
+        bool b = bRunning;
+        mRunning.unlock();
+        return b;
+    }
 
 protected:
-	virtual void run()
-	{
-		setRunning( true );
-		while( isRunning() )
-		{
-			Thing *pThing = qThing.dequeue( 0, 250000 );
-			if( pThing == NULL )
-				continue;
-
-			pThing->y = pThing->x*2;
-			usleep( 10000 );
-
-			workDone();
-		}
-	}
-
-	ThingQueue &qThing;
-	Bu::Mutex mRunning;
+    virtual void run()
+    {
+        setRunning( true );
+        while( isRunning() )
+        {
+            Thing *pThing = qThing.dequeue( 0, 250000 );
+            if( pThing == NULL )
+                continue;
+
+            pThing->y = pThing->x*2;
+            usleep( 10000 );
+
+            workDone();
+        }
+    }
+
+    ThingQueue &qThing;
+    Bu::Mutex mRunning;
 };
 
 typedef Bu::List<ThingEater *> ThingEaterList;
 
 int main()
 {
-	ThingQueue qThing;
-	ThingEaterList lEater;
-	
-	mWorkDone.lock();
-	iWorkDone = 1000;
-	mWorkDone.unlock();
-
-	for( int j = 0; j < 5; j++ )
-		lEater.append( new ThingEater( qThing ) );
-
-	for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
-		(*i)->start();
-
-	for( int j = 0; j < 1000; j++ )
-	{
-		qThing.enqueue( new Thing( j ) );
-	}
-
-	mWorkDone.lock();
-	mWorkDone.unlock();
-	cWorkDone.lock();
-	for(;;)
-	{
-		mWorkDone.lock();
-		if( iWorkDone == 0 )
-		{
-			mWorkDone.unlock();
-			break;
-		}
-		mWorkDone.unlock();
-		cWorkDone.wait();
-	}
-	cWorkDone.unlock();
-
-	for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
-		(*i)->setRunning( false );
-
-	for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
-		(*i)->join();
-
-	return 0;
+    ThingQueue qThing;
+    ThingEaterList lEater;
+    
+    mWorkDone.lock();
+    iWorkDone = 1000;
+    mWorkDone.unlock();
+
+    for( int j = 0; j < 5; j++ )
+        lEater.append( new ThingEater( qThing ) );
+
+    for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
+        (*i)->start();
+
+    for( int j = 0; j < 1000; j++ )
+    {
+        qThing.enqueue( new Thing( j ) );
+    }
+
+    mWorkDone.lock();
+    mWorkDone.unlock();
+    cWorkDone.lock();
+    for(;;)
+    {
+        mWorkDone.lock();
+        if( iWorkDone == 0 )
+        {
+            mWorkDone.unlock();
+            break;
+        }
+        mWorkDone.unlock();
+        cWorkDone.wait();
+    }
+    cWorkDone.unlock();
+
+    for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
+        (*i)->setRunning( false );
+
+    for( ThingEaterList::iterator i = lEater.begin(); i; i++ )
+        (*i)->join();
+
+    return 0;
 }
 
-- 
cgit v1.2.3