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

Timestamp:

Jun 25, 2009, 11:06:52 AM (15 years ago)

Author:

Christoph Mayer

Message:

-StartupWrapper bisschen umgeschrieben, erste Schritte für sauberes runterfahren

File:

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

source/ariba/utility/system/SystemQueue.cpp

@@ -130 +130 @@
 
         // cause the thread to exit
-        running = false;
-        itemsAvailable.notify_all();
+        {
+                boost::mutex::scoped_lock lock(queueMutex);
+                running = false;
+
+                while( eventsQueue.size() > 0 ){
+                        eventsQueue.erase( eventsQueue.begin() );
+                }
+
+                itemsAvailable.notify_all();
+        }
 
         // wait that the thread has exited
@@ -139 +147 @@
         delete queueThread;
         queueThread = NULL;
-
-        while( eventsQueue.size() > 0 ){
-                eventsQueue.erase( eventsQueue.begin() );
-        }
 }
 
@@ -151 +155 @@
 
 void SystemQueue::QueueThread::insert( const SystemEvent& event, uint32_t delay ){
-        {
-                boost::mutex::scoped_lock lock( queueMutex );
-
-                eventsQueue.push_back( event );
-                eventsQueue.back().scheduledTime = boost::posix_time::microsec_clock::local_time();
-                eventsQueue.back().delayTime = delay;
-                eventsQueue.back().remainingDelay = delay;
-
-                onItemInserted( event );
-                itemsAvailable.notify_all();
-        }
+
+        // if this is called from a module that is currently handling
+        // a thread (called from SystemQueue::onNextQueueItem), the
+        // thread is the same anyway and the mutex will be already
+        // aquired, otherwise we aquire it now
+
+        boost::mutex::scoped_lock lock( queueMutex );
+
+        eventsQueue.push_back( event );
+        eventsQueue.back().scheduledTime = boost::posix_time::microsec_clock::local_time();
+        eventsQueue.back().delayTime = delay;
+        eventsQueue.back().remainingDelay = delay;
+
+        onItemInserted( event );
+        itemsAvailable.notify_all();
 }
 
@@ -177 +185 @@
                 while ( obj->eventsQueue.empty() && obj->running ){
 
-                        const boost::system_time duration =
-                                        boost::get_system_time() +
-                                        boost::posix_time::milliseconds(40);
+//                      const boost::system_time duration =
+//                                      boost::get_system_time() +
+//                                      boost::posix_time::milliseconds(100);
 
                         obj->itemsAvailable.wait( lock );
@@ -185 +193 @@
                 }
 
+                //
                 // work all the items that are currently in the queue
-
-                while( !obj->eventsQueue.empty() ) {
-
-                        // fetch the first item in the queue and deliver it to the
-                        // queue handler
+                //
+
+                while( !obj->eventsQueue.empty() && obj->running ) {
+
+                        // fetch the first item in the queue
+                        // and deliver it to the queue handler
                         SystemEvent ev = obj->eventsQueue.front();
                         obj->eventsQueue.erase( obj->eventsQueue.begin() );
 
-                        {
-                                // unlock the queue to that an event handler
-                                // can insert new items into the queue
-//                              obj->queueMutex.unlock();
-                                obj->onNextQueueItem( ev );
-//                              obj->queueMutex.lock();
-                        }
+                        // call the queue and this will
+                        // call the actual event handler
+                        obj->onNextQueueItem( ev );
 
                 } // !obj->eventsQueue.empty() )
         } // while (obj->running)
+
+        logging_debug("system queue exited");
 }