diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-08-15 20:08:55 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-08-15 20:08:55 +0000 |
commit | a4c4eb532846f36e8c67dd2ca047eb3a2469d173 (patch) | |
tree | 709b2c028f6ddc0aa2921a4f798828710ad1a474 /ace/WFMO_Reactor.cpp | |
parent | de1924e2245bf5806f0a81b81dcfbe5204cf0f24 (diff) | |
download | ATCD-a4c4eb532846f36e8c67dd2ca047eb3a2469d173.tar.gz |
ChangeLogTag:Wed Aug 15 11:33:26 2001 Carlos O'Ryan <coryan@uci.edu>
Diffstat (limited to 'ace/WFMO_Reactor.cpp')
-rw-r--r-- | ace/WFMO_Reactor.cpp | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/ace/WFMO_Reactor.cpp b/ace/WFMO_Reactor.cpp index 78248c21065..c65a6dee4ae 100644 --- a/ace/WFMO_Reactor.cpp +++ b/ace/WFMO_Reactor.cpp @@ -2372,20 +2372,20 @@ ACE_WFMO_Reactor_Notify::purge_pending_notifications (ACE_Event_Handler *eh, { ACE_TRACE ("ACE_WFMO_Reactor_Notify::purge_pending_notifications"); - // Go over message queue and take out all the matching event handlers. - // If eh == 0, purge all. Note that reactor notifies (no handler specified) - // are never purged, as this may lose a needed notify the reactor - // queued for itself. + // Go over message queue and take out all the matching event + // handlers. If eh == 0, purge all. Note that reactor notifies (no + // handler specified) are never purged, as this may lose a needed + // notify the reactor queued for itself. if (this->message_queue_.is_empty ()) return 0; // Guard against new and/or delivered notifications while purging. - // WARNING!!! The use of the notification queue's lock object for this - // guard makes use of the knowledge that on Win32, the mutex protecting - // the queue is really a CriticalSection, which is recursive. This is - // how we can get away with locking it down here and still calling - // member functions on the queue object. + // WARNING!!! The use of the notification queue's lock object for + // this guard makes use of the knowledge that on Win32, the mutex + // protecting the queue is really a CriticalSection, which is + // recursive. This is how we can get away with locking it down here + // and still calling member functions on the queue object. ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, monitor, this->message_queue_.lock(), -1); // first, copy all to our own local queue. Since we've locked everyone out @@ -2421,10 +2421,10 @@ ACE_WFMO_Reactor_Notify::purge_pending_notifications (ACE_Event_Handler *eh, } else { - // To preserve it, move it to the local_queue. - // But first, if this is not a Reactor notify (it is for a particularhandler), - // and it matches the specified handler (or purging all), then - // apply the mask + // To preserve it, move it to the local_queue. But first, if + // this is not a Reactor notify (it is for a + // particularhandler), and it matches the specified handler + // (or purging all), then apply the mask if ((0 != buffer->eh_) && (0 == eh || eh == buffer->eh_)) ACE_CLR_BITS(buffer->mask_, mask); @@ -2439,8 +2439,8 @@ ACE_WFMO_Reactor_Notify::purge_pending_notifications (ACE_Event_Handler *eh, return -1; } - // Now copy back from the local queue to the class queue, taking care to - // preserve the original order... + // Now copy back from the local queue to the class queue, taking + // care to preserve the original order... queue_size = local_queue.message_count (); for (index = 0; index < queue_size; ++index) { |