summaryrefslogtreecommitdiff
path: root/ace/WFMO_Reactor.cpp
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>2001-08-15 20:08:55 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>2001-08-15 20:08:55 +0000
commita4c4eb532846f36e8c67dd2ca047eb3a2469d173 (patch)
tree709b2c028f6ddc0aa2921a4f798828710ad1a474 /ace/WFMO_Reactor.cpp
parentde1924e2245bf5806f0a81b81dcfbe5204cf0f24 (diff)
downloadATCD-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.cpp30
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)
{