Changeset 4721 for source/ariba/utility/system/SystemQueue.cpp

Timestamp:

Jul 3, 2009, 11:53:21 AM (15 years ago)

Author:

Christoph Mayer

Message:

-minor changes

File:

• source/ariba/utility/system/SystemQueue.cpp (modified) (3 diffs)

source/ariba/utility/system/SystemQueue.cpp

@@ -133 +133 @@
 void SystemQueue::QueueThread::run(){
         running = true;
+
         queueThread = new boost::thread(
                 boost::bind(&QueueThread::threadFunc, this) );
@@ -139 +140 @@
 void SystemQueue::QueueThread::cancel(){
 
+        logging_debug("cancelling system queue");
+
         // cause the thread to exit
         {
-                // get the lock, when we got the lock the 
+                // get the lock, when we got the lock the
                 // queue thread must be in itemsAvailable.wait()
                 boost::mutex::scoped_lock lock(queueMutex);
-                
+
                 // set the running indicator and signal to run on
                 // this will run the thread and quit it
@@ -152 +155 @@
 
         // wait until the thread has exited
+        logging_debug("joining system queue thread");
         queueThread->join();
 
         // delete pending events
+        logging_debug("deleting pending system queue events");
         while( eventsQueue.size() > 0 ){
                 eventsQueue.erase( eventsQueue.begin() );