Skip to content

Commit

Permalink
Merge branch 'master' of https://github.com/DOCGroup/ACE_TAO into master
Browse files Browse the repository at this point in the history
  • Loading branch information
jwillemsen committed Nov 17, 2020
2 parents 7ff0484 + 1192c46 commit 970acaf
Show file tree
Hide file tree
Showing 9 changed files with 33 additions and 31 deletions.
5 changes: 2 additions & 3 deletions ACE/ace/Event_Handler.h
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,8 @@
#endif /* ACE_LACKS_PRAGMA_ONCE */

#include "ace/os_include/os_signal.h"
#include "ace/Atomic_Op.h"
#include "ace/OS_NS_Thread.h"
#include "ace/Synch_Traits.h"
#include <atomic>

ACE_BEGIN_VERSIONED_NAMESPACE_DECL

Expand Down Expand Up @@ -286,7 +285,7 @@ class ACE_Export ACE_Event_Handler
int priority = ACE_Event_Handler::LO_PRIORITY);

/// Typedef for implementation of reference counting.
typedef ACE_Atomic_Op<ACE_SYNCH_MUTEX, Reference_Count> Atomic_Reference_Count;
typedef std::atomic<Reference_Count> Atomic_Reference_Count;

/// Reference count.
Atomic_Reference_Count reference_count_;
Expand Down
1 change: 1 addition & 0 deletions ACE/ace/Reactor.h
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@

// Get ACE_Time_Value in
#include "ace/Time_Value.h"
#include "ace/Synch_Traits.h"

ACE_BEGIN_VERSIONED_NAMESPACE_DECL

Expand Down
1 change: 1 addition & 0 deletions ACE/ace/Reactor_Impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
// Event_Handler.h contains the definition of ACE_Reactor_Mask
#include "ace/Event_Handler.h"
#include "ace/Countdown_Time.h"
#include "ace/Synch_Traits.h"

ACE_BEGIN_VERSIONED_NAMESPACE_DECL

Expand Down
10 changes: 5 additions & 5 deletions ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -296,15 +296,15 @@ Sender::Sender (ACE_HANDLE handle,
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Reference count in Sender::Sender() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));
}

Sender::~Sender (void)
{
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Reference count in ~Sender::Sender() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

// Close the socket that we are responsible for.
ACE_OS::closesocket (this->handle_);
Expand All @@ -316,7 +316,7 @@ Sender::handle_input (ACE_HANDLE)
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Reference count in Sender::handle_input() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

//
// In this test, this method is only called when the connection has
Expand Down Expand Up @@ -417,15 +417,15 @@ Receiver::Receiver (ACE_Thread_Manager &thread_manager,
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Reference count in Receiver::Receiver() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));
}

Receiver::~Receiver (void)
{
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%t) Reference count in ~Receiver::Receiver() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

// Close the socket that we are responsible for.
ACE_OS::closesocket (this->handle_);
Expand Down
16 changes: 8 additions & 8 deletions ACE/tests/MT_Reference_Counted_Notify_Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ Reference_Counted_Event_Handler::Reference_Counted_Event_Handler (void)
((LM_DEBUG,
ACE_TEXT ("Reference count in Reference_Counted_Event_Handler() ")
ACE_TEXT ("is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));
}

Reference_Counted_Event_Handler::~Reference_Counted_Event_Handler (void)
Expand All @@ -70,14 +70,14 @@ Reference_Counted_Event_Handler::~Reference_Counted_Event_Handler (void)
((LM_DEBUG,
ACE_TEXT ("Reference count in ~Reference_Counted_Event_Handler() ")
ACE_TEXT ("is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

if (0 != this->reference_count_.value ())
if (0 != this->reference_count_.load ())
ACE_ERROR
((LM_ERROR,
ACE_TEXT ("Reference count in ~Reference_Counted_Event_Handler() ")
ACE_TEXT ("should be 0 but is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));
}

int
Expand All @@ -88,14 +88,14 @@ Reference_Counted_Event_Handler::handle_input (ACE_HANDLE)
((LM_DEBUG,
ACE_TEXT ("Reference count in Reference_Counted_Event_Handler::")
ACE_TEXT ("handle_input() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

if (2 != this->reference_count_.value ())
if (2 != this->reference_count_.load ())
ACE_ERROR
((LM_ERROR,
ACE_TEXT ("Reference count in Reference_Counted_Event_Handler::")
ACE_TEXT ("handle_input() should be 2 but is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

return 0;
}
Expand All @@ -109,7 +109,7 @@ Reference_Counted_Event_Handler::add_reference (void)
if (debug)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Reference count after add_reference() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

return reference_count;
}
Expand Down
18 changes: 9 additions & 9 deletions ACE/tests/Reference_Counted_Event_Handler_Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -78,14 +78,14 @@ Reference_Counted_Event_Handler::Reference_Counted_Event_Handler (int &events)

ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));
}

Reference_Counted_Event_Handler::~Reference_Counted_Event_Handler (void)
{
ACE_DEBUG ((LM_DEBUG,
"Reference count in ~Reference_Counted_Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

this->pipe_.close ();
}
Expand All @@ -95,7 +95,7 @@ Reference_Counted_Event_Handler::handle_input (ACE_HANDLE)
{
ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler::handle_input() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

--this->events_;

Expand Down Expand Up @@ -126,7 +126,7 @@ Reference_Counted_Event_Handler::handle_output (ACE_HANDLE)
{
ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler::handle_output() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

--this->events_;

Expand All @@ -152,7 +152,7 @@ Reference_Counted_Event_Handler::handle_timeout (const ACE_Time_Value &,
ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler::handle_timeout() for arg = %C is %d\n",
(const char *) arg,
this->reference_count_.value ()));
this->reference_count_.load ()));

--this->events_;

Expand All @@ -176,7 +176,7 @@ Reference_Counted_Event_Handler::handle_close (ACE_HANDLE handle,
"Reference count is %d\n",
handle,
masks,
this->reference_count_.value ()));
this->reference_count_.load ()));

return 0;
}
Expand All @@ -189,7 +189,7 @@ Reference_Counted_Event_Handler::add_reference (void)

ACE_DEBUG ((LM_DEBUG,
"Reference count after add_reference() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

return reference_count;
}
Expand Down Expand Up @@ -854,7 +854,7 @@ Closed_In_Upcall_Event_Handler::handle_close (ACE_HANDLE handle,
ACE_TEXT ("Reference count is %d\n"),
handle,
masks,
this->reference_count_.value ()));
this->reference_count_.load ()));

return 0;
}
Expand All @@ -867,7 +867,7 @@ Closed_In_Upcall_Event_Handler::add_reference (void)

ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Reference count after add_reference() is %d\n"),
this->reference_count_.value ()));
this->reference_count_.load ()));

return reference_count;
}
Expand Down
8 changes: 4 additions & 4 deletions ACE/tests/Timer_Queue_Reference_Counting_Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -70,15 +70,15 @@ Reference_Counted_Event_Handler::Reference_Counted_Event_Handler (int expected_n
if (debug)
ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));
}

Reference_Counted_Event_Handler::~Reference_Counted_Event_Handler (void)
{
if (debug)
ACE_DEBUG ((LM_DEBUG,
"Reference count in ~Reference_Counted_Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

if (this->expected_number_of_handle_close_calls_ != -1)
ACE_TEST_ASSERT (this->number_of_handle_close_calls_ ==
Expand All @@ -93,7 +93,7 @@ Reference_Counted_Event_Handler::handle_timeout (const ACE_Time_Value &,
ACE_DEBUG ((LM_DEBUG,
"Reference count in Reference_Counted_Event_Handler::handle_timeout() for arg = %C is %d\n",
(const char *) arg,
this->reference_count_.value ()));
this->reference_count_.load ()));

return 0;
}
Expand All @@ -108,7 +108,7 @@ Reference_Counted_Event_Handler::handle_close (ACE_HANDLE handle,
"Reference count is %d\n",
handle,
masks,
this->reference_count_.value ()));
this->reference_count_.load ()));

++this->number_of_handle_close_calls_;

Expand Down
4 changes: 2 additions & 2 deletions ACE/tests/WFMO_Reactor_Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ Event_Handler::Event_Handler (ACE_Reactor &reactor)

ACE_DEBUG ((LM_DEBUG,
"Reference count in Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

this->reactor (&reactor);

Expand All @@ -62,7 +62,7 @@ Event_Handler::~Event_Handler (void)
{
ACE_DEBUG ((LM_DEBUG,
"Reference count in ~Event_Handler() is %d\n",
this->reference_count_.value ()));
this->reference_count_.load ()));

++number_of_closes;
}
Expand Down
1 change: 1 addition & 0 deletions TAO/tao/GUIResource_Factory.cpp
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
#include "tao/GUIResource_Factory.h"
#include "ace/Reactor.h"
#include "ace/Guard_T.h"
#include "tao/debug.h"

TAO_BEGIN_VERSIONED_NAMESPACE_DECL
Expand Down

0 comments on commit 970acaf

Please sign in to comment.