summaryrefslogtreecommitdiff
path: root/ACE/examples/Reactor/Proactor/test_proactor3.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/examples/Reactor/Proactor/test_proactor3.cpp')
-rw-r--r--ACE/examples/Reactor/Proactor/test_proactor3.cpp52
1 files changed, 26 insertions, 26 deletions
diff --git a/ACE/examples/Reactor/Proactor/test_proactor3.cpp b/ACE/examples/Reactor/Proactor/test_proactor3.cpp
index 7e5ea77f349..293d64a64e7 100644
--- a/ACE/examples/Reactor/Proactor/test_proactor3.cpp
+++ b/ACE/examples/Reactor/Proactor/test_proactor3.cpp
@@ -51,7 +51,7 @@
// Some debug helper functions
static int disable_signal (int sigmin, int sigmax);
#if 0
-static int print_sigmask (void);
+static int print_sigmask ();
#endif
#define COUT(X) cout << X; cout.flush ();
@@ -90,7 +90,7 @@ class MyTask: public ACE_Task<ACE_MT_SYNCH>
public:
MyTask (void) : threads_ (0), proactor_ (0) {}
- int svc (void);
+ int svc ();
void waitready (void) { event_.wait (); }
private:
@@ -99,12 +99,12 @@ private:
ACE_Proactor *proactor_;
ACE_Manual_Event event_;
- void create_proactor (void);
- void delete_proactor (void);
+ void create_proactor ();
+ void delete_proactor ();
};
void
-MyTask::create_proactor (void)
+MyTask::create_proactor ()
{
ACE_GUARD (ACE_Recursive_Thread_Mutex, locker, mutex_);
@@ -151,7 +151,7 @@ MyTask::create_proactor (void)
}
void
-MyTask::delete_proactor (void)
+MyTask::delete_proactor ()
{
ACE_GUARD (ACE_Recursive_Thread_Mutex, locker, mutex_);
if (--threads_ == 0)
@@ -164,7 +164,7 @@ MyTask::delete_proactor (void)
}
int
-MyTask::svc (void)
+MyTask::svc ()
{
ACE_DEBUG ((LM_DEBUG, "(%t) MyTask started\n"));
@@ -183,8 +183,8 @@ MyTask::svc (void)
class Receiver : public ACE_Service_Handler
{
public:
- Receiver (void);
- ~Receiver (void);
+ Receiver ();
+ ~Receiver ();
//FUZZ: disable check_for_lack_ACE_OS
/// This is called after the new connection has been accepted.
@@ -206,9 +206,9 @@ protected:
virtual void handle_write_stream (const ACE_Asynch_Write_Stream::Result &result);
private:
- int initiate_read_stream (void);
+ int initiate_read_stream ();
int initiate_write_stream (ACE_Message_Block & mb, int nBytes);
- int check_destroy (void);
+ int check_destroy ();
ACE_Asynch_Read_Stream rs_;
ACE_Asynch_Write_Stream ws_;
@@ -220,7 +220,7 @@ private:
long Receiver::sessions_ = 0;
-Receiver::Receiver (void)
+Receiver::Receiver ()
: handle_ (ACE_INVALID_HANDLE),
io_count_ (0)
{
@@ -229,7 +229,7 @@ Receiver::Receiver (void)
ACE_DEBUG ((LM_DEBUG, "Receiver Ctor sessions_=%d\n", sessions_));
}
-Receiver::~Receiver (void)
+Receiver::~Receiver ()
{
ACE_GUARD (ACE_Recursive_Thread_Mutex, locker, mutex_);
sessions_--;
@@ -239,7 +239,7 @@ Receiver::~Receiver (void)
// return true if we alive, false we commited suicide
int
-Receiver::check_destroy (void)
+Receiver::check_destroy ()
{
{
ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, locker, mutex_, -1);
@@ -276,7 +276,7 @@ Receiver::open (ACE_HANDLE handle,
}
int
-Receiver::initiate_read_stream (void)
+Receiver::initiate_read_stream ()
{
ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, locker, mutex_, -1);
@@ -420,13 +420,13 @@ Receiver::handle_write_stream (const ACE_Asynch_Write_Stream::Result &result)
class Sender : public ACE_Handler
{
public:
- Sender (void);
- ~Sender (void);
+ Sender ();
+ ~Sender ();
//FUZZ: disable check_for_lack_ACE_OS
///FUZZ: enable check_for_lack_ACE_OS
int open (const ACE_TCHAR *host, u_short port);
- void close (void);
+ void close ();
ACE_HANDLE handle () const;
virtual void handle (ACE_HANDLE);
@@ -441,8 +441,8 @@ protected:
virtual void handle_write_stream (const ACE_Asynch_Write_Stream::Result &result);
private:
- int initiate_read_stream (void);
- int initiate_write_stream (void);
+ int initiate_read_stream ();
+ int initiate_write_stream ();
/// Network I/O handle
ACE_SOCK_Stream stream_;
@@ -462,19 +462,19 @@ private:
static const char *data = "Welcome to Irfan World! Irfan RULES here !!\n";
-Sender::Sender (void)
+Sender::Sender ()
: io_count_ (0)
{
// Moment of inspiration... :-)
this->welcome_message_.init (data, ACE_OS::strlen (data));
}
-Sender::~Sender (void)
+Sender::~Sender ()
{
this->close ();
}
-void Sender::close (void)
+void Sender::close ()
{
this->stream_.close ();
}
@@ -531,7 +531,7 @@ int Sender::open (const ACE_TCHAR *host, u_short port)
}
int
-Sender::initiate_write_stream (void)
+Sender::initiate_write_stream ()
{
ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, locker, mutex_, -1);
@@ -550,7 +550,7 @@ Sender::initiate_write_stream (void)
}
int
-Sender::initiate_read_stream (void)
+Sender::initiate_read_stream ()
{
ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, locker, mutex_, -1);
@@ -845,7 +845,7 @@ disable_signal (int sigmin, int sigmax)
#if 0
static int
-print_sigmask (void)
+print_sigmask ()
{
#ifndef ACE_WIN32
sigset_t mask;