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

Timestamp:

Jan 25, 2010, 10:50:57 AM (14 years ago)

Author:

Christoph Mayer

Message:

-timer delete fix (noch auskommentiert), -interface cleanup

File:

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

source/ariba/utility/system/SystemQueue.cpp

@@ -95 +95 @@
 }
 
+void SystemQueue::dropAll( const SystemEventListener* mlistener){
+#ifndef UNDERLAY_OMNET
+        directScheduler.dropAll(mlistener);
+        delayScheduler.dropAll(mlistener);
+#endif
+}
+
 bool SystemQueue::isEmpty() {
 #ifndef UNDERLAY_OMNET
@@ -192 +199 @@
 }
 
+void SystemQueue::QueueThread::dropAll( const SystemEventListener* mlistener) {
+        boost::mutex::scoped_lock lock( queueMutex );
+
+        bool deleted = false;
+        do{
+                EventQueue::iterator i = eventsQueue.begin();
+                EventQueue::iterator iend = eventsQueue.end();
+
+                for( ; i != iend; i++){
+                        if((*i).getListener() == mlistener){
+                                eventsQueue.erase(i);
+                                deleted = true;
+                                break;
+                        }
+                }
+        }while(deleted);
+}
+
 void SystemQueue::QueueThread::threadFunc( QueueThread* obj ) {