1 files changed, 99 insertions, 99 deletions

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;
 }