summaryrefslogtreecommitdiff
path: root/ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp')
-rw-r--r--ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp92
1 files changed, 46 insertions, 46 deletions
diff --git a/ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp b/ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp
index bae36ea9c0e..f9d2d2156c6 100644
--- a/ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp
+++ b/ACE/tests/MT_Reference_Counted_Event_Handler_Test.cpp
@@ -139,22 +139,22 @@ class Pipe
{
public:
- Pipe (void);
+ Pipe ();
//FUZZ: disable check_for_lack_ACE_OS
///FUZZ: enable check_for_lack_ACE_OS
- int open (void);
+ int open ();
- ACE_HANDLE read_handle (void) const;
+ ACE_HANDLE read_handle () const;
- ACE_HANDLE write_handle (void) const;
+ ACE_HANDLE write_handle () const;
private:
ACE_HANDLE handles_[2];
};
int
-Pipe::open (void)
+Pipe::open ()
{
ACE_INET_Addr my_addr;
ACE_SOCK_Acceptor acceptor;
@@ -200,20 +200,20 @@ Pipe::open (void)
return 0;
}
-Pipe::Pipe (void)
+Pipe::Pipe ()
{
this->handles_[0] = ACE_INVALID_HANDLE;
this->handles_[1] = ACE_INVALID_HANDLE;
}
ACE_HANDLE
-Pipe::read_handle (void) const
+Pipe::read_handle () const
{
return this->handles_[0];
}
ACE_HANDLE
-Pipe::write_handle (void) const
+Pipe::write_handle () const
{
return this->handles_[1];
}
@@ -230,15 +230,15 @@ public:
Sender (ACE_HANDLE handle,
Connection_Cache &connection_cache);
- ~Sender (void);
+ ~Sender () override;
- int handle_input (ACE_HANDLE);
+ int handle_input (ACE_HANDLE) override;
- ssize_t send_message (void);
+ ssize_t send_message ();
//FUZZ: disable check_for_lack_ACE_OS
///FUZZ: enable check_for_lack_ACE_OS
- void close (void);
+ void close ();
ACE_HANDLE handle_;
@@ -250,21 +250,21 @@ class Connection_Cache
{
public:
- Connection_Cache (void);
+ Connection_Cache ();
- ~Connection_Cache (void);
+ ~Connection_Cache ();
void add_connection (Sender *sender);
void remove_connection (Sender *sender);
- Sender *acquire_connection (void);
+ Sender *acquire_connection ();
void release_connection (Sender *sender);
int find (Sender *sender);
- ACE_SYNCH_MUTEX &lock (void);
+ ACE_SYNCH_MUTEX &lock ();
enum State
{
@@ -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)
+Sender::~Sender ()
{
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_);
@@ -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
@@ -334,7 +334,7 @@ Sender::handle_input (ACE_HANDLE)
}
void
-Sender::close (void)
+Sender::close ()
{
// Remove socket from Reactor (may fail if another thread has already
// removed the handle from the Reactor).
@@ -348,7 +348,7 @@ Sender::close (void)
}
ssize_t
-Sender::send_message (void)
+Sender::send_message ()
{
ACE_Time_Value timeout (0, close_timeout * 1000);
@@ -365,7 +365,7 @@ public:
Event_Loop_Thread (ACE_Thread_Manager &thread_manager,
ACE_Reactor &reactor);
- int svc (void);
+ int svc () override;
ACE_Reactor &reactor_;
@@ -379,17 +379,17 @@ public:
ACE_HANDLE handle,
int nested_upcalls);
- ~Receiver (void);
+ ~Receiver () override;
- int svc (void);
+ int svc () override;
//FUZZ: disable check_for_lack_ACE_OS
///FUZZ: enable check_for_lack_ACE_OS
- int close (u_long flags);
+ int close (u_long flags) override;
- int handle_input (ACE_HANDLE);
+ int handle_input (ACE_HANDLE) override;
- int resume_handler (void);
+ int resume_handler () override;
ACE_HANDLE handle_;
@@ -417,22 +417,22 @@ 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)
+Receiver::~Receiver ()
{
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_);
}
int
-Receiver::svc (void)
+Receiver::svc ()
{
//
// Continuously receive messages from the Sender. On error, exit
@@ -522,7 +522,7 @@ Receiver::handle_input (ACE_HANDLE handle)
}
int
-Receiver::resume_handler (void)
+Receiver::resume_handler ()
{
/// The application takes responsibility of resuming the handler.
return ACE_APPLICATION_RESUMES_HANDLER;
@@ -636,7 +636,7 @@ Connector::connect (ACE_HANDLE &client_handle,
return 0;
}
-Connection_Cache::Connection_Cache (void)
+Connection_Cache::Connection_Cache ()
{
// Initialize the connection cache.
this->entries_ =
@@ -698,7 +698,7 @@ Connection_Cache::remove_connection (Sender *sender)
}
Sender *
-Connection_Cache::acquire_connection (void)
+Connection_Cache::acquire_connection ()
{
ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, this->lock_, 0);
@@ -741,12 +741,12 @@ Connection_Cache::release_connection (Sender *sender)
}
ACE_SYNCH_MUTEX &
-Connection_Cache::lock (void)
+Connection_Cache::lock ()
{
return this->lock_;
}
-Connection_Cache::~Connection_Cache (void)
+Connection_Cache::~Connection_Cache ()
{
for (int i = 0; i < number_of_connections; ++i)
{
@@ -769,9 +769,9 @@ public:
int run_receiver_thread,
int nested_upcalls);
- int svc (void);
+ int svc () override;
- Sender *create_connection (void);
+ Sender *create_connection ();
Connection_Cache &connection_cache_;
@@ -808,7 +808,7 @@ Invocation_Thread::Invocation_Thread (ACE_Thread_Manager &thread_manager,
}
Sender *
-Invocation_Thread::create_connection (void)
+Invocation_Thread::create_connection ()
{
int result = 0;
@@ -867,7 +867,7 @@ Invocation_Thread::create_connection (void)
}
int
-Invocation_Thread::svc (void)
+Invocation_Thread::svc ()
{
int connection_counter = 0;
ACE_DEBUG ((LM_DEBUG,
@@ -977,7 +977,7 @@ public:
int make_invocations,
int run_receiver_thread);
- int svc (void);
+ int svc () override;
ACE_Auto_Event &new_connection_event_;
@@ -1003,7 +1003,7 @@ Close_Socket_Thread::Close_Socket_Thread (ACE_Thread_Manager &thread_manager,
}
int
-Close_Socket_Thread::svc (void)
+Close_Socket_Thread::svc ()
{
unsigned int seed = (unsigned int) ACE_OS::time ();
ACE_Time_Value timeout (0, close_timeout * 1000);
@@ -1083,7 +1083,7 @@ Event_Loop_Thread::Event_Loop_Thread (ACE_Thread_Manager &thread_manager,
}
int
-Event_Loop_Thread::svc (void)
+Event_Loop_Thread::svc ()
{
// Simply run the event loop.
this->reactor_.owner (ACE_Thread::self ());
@@ -1110,7 +1110,7 @@ public:
ACE_Reactor &reactor,
Connection_Cache &connection_cache);
- int svc (void);
+ int svc () override;
ACE_Reactor &reactor_;
@@ -1128,7 +1128,7 @@ Purger_Thread::Purger_Thread (ACE_Thread_Manager &thread_manager,
}
int
-Purger_Thread::svc (void)
+Purger_Thread::svc ()
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("(%t) Purger_Thread::svc commencing\n")));