diff options
author | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-07-26 20:44:27 +0000 |
---|---|---|
committer | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-07-26 20:44:27 +0000 |
commit | 6b02514f8332715829f82e0f49f47d5f6a59a2f8 (patch) | |
tree | 86d968964d75dee5fb35253f52fd8ee21453deb0 /examples/Service_Configurator/IPC-tests/server | |
parent | 0725903fd35de34a14bf4fc7eb08fbca79443495 (diff) | |
download | ATCD-6b02514f8332715829f82e0f49f47d5f6a59a2f8.tar.gz |
*** empty log message ***
Diffstat (limited to 'examples/Service_Configurator/IPC-tests/server')
12 files changed, 23 insertions, 23 deletions
diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i b/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i index 11c30e02fec..14de88bce6e 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i @@ -61,7 +61,7 @@ Handle_Broadcast::init (int argc, char *argv[]) if (this->open (sba) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -70,7 +70,7 @@ Handle_Broadcast::init (int argc, char *argv[]) ACE_INLINE int Handle_Broadcast::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.i index e30f506122a..735ca3fd066 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.i @@ -61,7 +61,7 @@ Handle_L_CODgram::init (int argc, char *argv[]) sucd.set (this->rendezvous); if (this->open (sucd) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); @@ -71,7 +71,7 @@ Handle_L_CODgram::init (int argc, char *argv[]) ACE_INLINE int Handle_L_CODgram::fini(void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.i index aaa6e97f18a..adbb9be45e5 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.i @@ -60,7 +60,7 @@ Handle_L_Dgram::init (int argc, char *argv[]) sudg.set (this->rendezvous); if (this->open (sudg) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler (this, + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -69,7 +69,7 @@ Handle_L_Dgram::init (int argc, char *argv[]) ACE_INLINE int Handle_L_Dgram::fini (void) { - return ACE_Reactor::instance()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } ACE_INLINE int diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.i index 377afb33845..b70e8002c32 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.i @@ -54,7 +54,7 @@ Handle_L_FIFO::init (int argc, char *argv[]) ACE_OS::unlink (rendezvous_fifo); if (this->open (rendezvous_fifo) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::READ_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -63,7 +63,7 @@ Handle_L_FIFO::init (int argc, char *argv[]) ACE_INLINE int Handle_L_FIFO::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.i index 39e38a82ef8..b8c93ff25f5 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.i @@ -76,7 +76,7 @@ Handle_L_Pipe::init (int argc, char *argv[]) sup.set (this->rendezvous); if (this->open (sup) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); @@ -86,7 +86,7 @@ Handle_L_Pipe::init (int argc, char *argv[]) ACE_INLINE int Handle_L_Pipe::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.i index 47c45f9600e..b3cb6005b58 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.i @@ -60,7 +60,7 @@ Handle_L_SPIPE::init (int argc, char *argv[]) susp.set (rendezvous); if (this->open (susp) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -69,7 +69,7 @@ Handle_L_SPIPE::init (int argc, char *argv[]) ACE_INLINE int Handle_L_SPIPE::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.i b/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.i index 7ecb6acc8cd..d3d4933ee69 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.i @@ -70,7 +70,7 @@ Handle_L_Stream::init (int argc, char *argv[]) if (this->open (sus) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); @@ -80,7 +80,7 @@ Handle_L_Stream::init (int argc, char *argv[]) ACE_INLINE int Handle_L_Stream::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.i b/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.i index 2f3c83431c1..1112125956f 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.i @@ -56,7 +56,7 @@ Handle_R_Dgram::init (int argc, char *argv[]) if (this->open (sidg) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -65,7 +65,7 @@ Handle_R_Dgram::init (int argc, char *argv[]) ACE_INLINE int Handle_R_Dgram::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i b/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i index 59c65dc8cda..a925df264e1 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i @@ -58,7 +58,7 @@ Handle_R_Stream::init (int argc, char *argv[]) if (this->open (sis) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); return 0; @@ -67,7 +67,7 @@ Handle_R_Stream::init (int argc, char *argv[]) ACE_INLINE int Handle_R_Stream::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp b/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp index 701d5a9e0f1..f08965d7832 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp +++ b/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp @@ -81,7 +81,7 @@ Handle_Thr_Acceptor<SH, PR_AC_2>::init (int argc, char *argv[]) // Initialize the Acceptor base class, passing in the desired // concurrency strategy. - else if (this->open (local_addr, ACE_Reactor::instance(), + else if (this->open (local_addr, ACE_Reactor::instance (), 0, 0, &this->thr_strategy_) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); else @@ -91,7 +91,7 @@ Handle_Thr_Acceptor<SH, PR_AC_2>::init (int argc, char *argv[]) template <class SH, PR_AC_1> int Handle_Thr_Acceptor<SH, PR_AC_2>::fini (void) { - return ACE_Reactor::instance()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_Timeout.i b/examples/Service_Configurator/IPC-tests/server/Handle_Timeout.i index d2d77829756..f522de2cc9b 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_Timeout.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_Timeout.i @@ -47,7 +47,7 @@ Handle_Timeout::init (int argc, char *argv[]) break; } - if (ACE_Reactor::instance()->schedule_timer (this, + if (ACE_Reactor::instance ()->schedule_timer (this, (void *) arg, delta, interval) == -1) diff --git a/examples/Service_Configurator/IPC-tests/server/server_test.cpp b/examples/Service_Configurator/IPC-tests/server/server_test.cpp index 082cbf05cf4..528aaac3172 100644 --- a/examples/Service_Configurator/IPC-tests/server/server_test.cpp +++ b/examples/Service_Configurator/IPC-tests/server/server_test.cpp @@ -16,13 +16,13 @@ main (int argc, char *argv[]) ACE_Sig_Adapter sa ((ACE_Sig_Handler_Ex) ACE_Reactor::end_event_loop); // Register a signal handler. - ACE_Reactor::instance()->register_handler (SIGINT, &sa); + ACE_Reactor::instance ()->register_handler (SIGINT, &sa); // Run forever, performing the configured services until we are shut // down by a SIGINT/SIGQUIT signal. while (ACE_Reactor::event_loop_done() == 0) - ACE_Reactor::run_event_loop(); + ACE_Reactor::run_event_loop (); return 0; } |