diff options
Diffstat (limited to 'ACE/examples/Reactor/Proactor/test_proactor3.cpp')
-rw-r--r-- | ACE/examples/Reactor/Proactor/test_proactor3.cpp | 52 |
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; |