Changeset 7468 for source/ariba/utility/system/SystemQueue.cpp
- Timestamp:
- Jan 25, 2010, 10:50:57 AM (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/utility/system/SystemQueue.cpp
r6919 r7468 95 95 } 96 96 97 void SystemQueue::dropAll( const SystemEventListener* mlistener){ 98 #ifndef UNDERLAY_OMNET 99 directScheduler.dropAll(mlistener); 100 delayScheduler.dropAll(mlistener); 101 #endif 102 } 103 97 104 bool SystemQueue::isEmpty() { 98 105 #ifndef UNDERLAY_OMNET … … 192 199 } 193 200 201 void SystemQueue::QueueThread::dropAll( const SystemEventListener* mlistener) { 202 boost::mutex::scoped_lock lock( queueMutex ); 203 204 bool deleted = false; 205 do{ 206 EventQueue::iterator i = eventsQueue.begin(); 207 EventQueue::iterator iend = eventsQueue.end(); 208 209 for( ; i != iend; i++){ 210 if((*i).getListener() == mlistener){ 211 eventsQueue.erase(i); 212 deleted = true; 213 break; 214 } 215 } 216 }while(deleted); 217 } 218 194 219 void SystemQueue::QueueThread::threadFunc( QueueThread* obj ) { 195 220
Note:
See TracChangeset
for help on using the changeset viewer.