summaryrefslogtreecommitdiff
path: root/ace/WFMO_Reactor.cpp
diff options
context:
space:
mode:
authorirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2004-02-27 17:33:04 +0000
committerirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2004-02-27 17:33:04 +0000
commit85d496395343d6e182b07804a6f368af07a32eb4 (patch)
tree44797d01eabd1d270c20662ca354f6ea66953ed8 /ace/WFMO_Reactor.cpp
parent588ea6b5d4279bce4fea945e067dfceb641b1ad6 (diff)
downloadATCD-85d496395343d6e182b07804a6f368af07a32eb4.tar.gz
ChangeLogTag: Fri Feb 27 12:33:10 2004 Irfan Pyarali <irfan@oomworks.com>
Diffstat (limited to 'ace/WFMO_Reactor.cpp')
-rw-r--r--ace/WFMO_Reactor.cpp38
1 files changed, 4 insertions, 34 deletions
diff --git a/ace/WFMO_Reactor.cpp b/ace/WFMO_Reactor.cpp
index 04b98e924af..d1760de95f0 100644
--- a/ace/WFMO_Reactor.cpp
+++ b/ace/WFMO_Reactor.cpp
@@ -654,14 +654,7 @@ ACE_WFMO_Reactor_Handler_Repository::bind_i (int io_entry,
this->handles_to_be_added_++;
- int requires_reference_counting =
- event_handler->reference_counting_policy ().value () ==
- ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
-
- if (requires_reference_counting)
- {
- event_handler->add_reference ();
- }
+ event_handler->add_reference ();
// Wake up all threads in WaitForMultipleObjects so that they can
// reconsult the handle set
@@ -1596,16 +1589,7 @@ ACE_WFMO_Reactor_Handler_Repository::handler (ACE_HANDLE handle,
}
if (event_handler)
- {
- int requires_reference_counting =
- event_handler->reference_counting_policy ().value () ==
- ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
-
- if (requires_reference_counting)
- {
- event_handler->add_reference ();
- }
- }
+ event_handler->add_reference ();
return event_handler;
}
@@ -2515,14 +2499,7 @@ ACE_WFMO_Reactor_Notify::notify (ACE_Event_Handler *event_handler,
return -1;
}
- int requires_reference_counting =
- event_handler->reference_counting_policy ().value () ==
- ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
-
- if (requires_reference_counting)
- {
- event_handler->add_reference ();
- }
+ event_handler->add_reference ();
}
return this->wakeup_one_thread_.signal ();
@@ -2598,14 +2575,7 @@ ACE_WFMO_Reactor_Notify::purge_pending_notifications (ACE_Event_Handler *eh,
{
ACE_Event_Handler *event_handler = buffer->eh_;
- int requires_reference_counting =
- event_handler->reference_counting_policy ().value () ==
- ACE_Event_Handler::Reference_Counting_Policy::ENABLED;
-
- if (requires_reference_counting)
- {
- event_handler->remove_reference ();
- }
+ event_handler->remove_reference ();
mb->release ();
++number_purged;