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/Connection | |
parent | 0725903fd35de34a14bf4fc7eb08fbca79443495 (diff) | |
download | ATCD-6b02514f8332715829f82e0f49f47d5f6a59a2f8.tar.gz |
*** empty log message ***
Diffstat (limited to 'examples/Connection')
-rw-r--r-- | examples/Connection/blocking/SPIPE-acceptor.cpp | 4 | ||||
-rw-r--r-- | examples/Connection/blocking/SPIPE-connector.cpp | 6 | ||||
-rw-r--r-- | examples/Connection/misc/Connection_Handler.cpp | 4 | ||||
-rw-r--r-- | examples/Connection/misc/test_upipe.cpp | 2 | ||||
-rw-r--r-- | examples/Connection/non_blocking/CPP-acceptor.cpp | 6 | ||||
-rw-r--r-- | examples/Connection/non_blocking/CPP-connector.cpp | 6 |
6 files changed, 14 insertions, 14 deletions
diff --git a/examples/Connection/blocking/SPIPE-acceptor.cpp b/examples/Connection/blocking/SPIPE-acceptor.cpp index 5c2913029ed..a1548f39205 100644 --- a/examples/Connection/blocking/SPIPE-acceptor.cpp +++ b/examples/Connection/blocking/SPIPE-acceptor.cpp @@ -70,7 +70,7 @@ IPC_Server::init (int argc, char *argv[]) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), 1); // Register to receive shutdowns. - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_handler_) == -1) return -1; else @@ -126,7 +126,7 @@ run_reactor_event_loop (void *) ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); ACE_DEBUG ((LM_DEBUG, "(%t) worker thread starting\n")); - ACE_Proactor::run_event_loop(); + ACE_Proactor::run_event_loop (); return 0; } diff --git a/examples/Connection/blocking/SPIPE-connector.cpp b/examples/Connection/blocking/SPIPE-connector.cpp index fe29d5ce1ac..60ef04275ba 100644 --- a/examples/Connection/blocking/SPIPE-connector.cpp +++ b/examples/Connection/blocking/SPIPE-connector.cpp @@ -28,7 +28,7 @@ Peer_Handler::open (void *) { this->display_menu (); if (ACE::register_stdin_handler (this, - ACE_Reactor::instance(), + ACE_Reactor::instance (), ACE_Thread_Manager::instance ()) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_stdin_handler"), -1); else @@ -115,7 +115,7 @@ IPC_Client::init (int argc, char *argv[]) if (this->parse_args (argc, argv) == -1) return -1; // Handle signals through the ACE_Reactor. - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_handler_) == -1) return -1; @@ -147,7 +147,7 @@ IPC_Client::fini (void) int IPC_Client::svc (void) { - ACE_Reactor::run_event_loop(); + ACE_Reactor::run_event_loop (); return 0; } diff --git a/examples/Connection/misc/Connection_Handler.cpp b/examples/Connection/misc/Connection_Handler.cpp index 6a3599eb3aa..79141d9e1c2 100644 --- a/examples/Connection/misc/Connection_Handler.cpp +++ b/examples/Connection/misc/Connection_Handler.cpp @@ -115,7 +115,7 @@ Connection_Handler::svc (void) } // Cancel all pending timeouts. - ACE_Reactor::instance()->cancel_timer (this); + ACE_Reactor::instance ()->cancel_timer (this); // Remove ourselves from the Reactor. this->reactor ()->remove_handler @@ -219,7 +219,7 @@ main (int argc, char *argv[]) // Perform connection service until we receive SIGINT. while (ACE_Reactor::event_loop_done() == 0) - ACE_Reactor::run_event_loop(); + ACE_Reactor::run_event_loop (); ACE_DEBUG ((LM_DEBUG, " (%P|%t) shutting down connection server\n")); diff --git a/examples/Connection/misc/test_upipe.cpp b/examples/Connection/misc/test_upipe.cpp index ca4f367418d..fc782d1ed3d 100644 --- a/examples/Connection/misc/test_upipe.cpp +++ b/examples/Connection/misc/test_upipe.cpp @@ -157,7 +157,7 @@ int main (int argc, char *argv[]) ACE_Thread_Manager thr_mgr; Client peer_connector (&thr_mgr); - Server peer_acceptor (&thr_mgr, ACE_Reactor::instance()); + Server peer_acceptor (&thr_mgr, ACE_Reactor::instance ()); // Establish the connection between Acceptor and Connector. diff --git a/examples/Connection/non_blocking/CPP-acceptor.cpp b/examples/Connection/non_blocking/CPP-acceptor.cpp index af9e05b2c5c..cdb0745c17a 100644 --- a/examples/Connection/non_blocking/CPP-acceptor.cpp +++ b/examples/Connection/non_blocking/CPP-acceptor.cpp @@ -90,16 +90,16 @@ IPC_Server<SH, PR_AC_2>::init (int argc, char *argv[]) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "set"), -1); // Call down to the ACCEPTOR's open() method to do the initialization. if (this->inherited::open (this->server_addr_, - use_reactor ? ACE_Reactor::instance() : 0) == -1) + use_reactor ? ACE_Reactor::instance () : 0) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); // Handle the SIGINT signal through the ACE_Reactor. - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_handler_) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_handler"), -1); #if !defined (ACE_WIN32) // Handle the SIGPIPE signal through the ACE_Reactor. - else if (ACE_Reactor::instance()->register_handler + else if (ACE_Reactor::instance ()->register_handler (SIGPIPE, &this->done_handler_) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_handler"), -1); #endif /* ACE_WIN32 */ diff --git a/examples/Connection/non_blocking/CPP-connector.cpp b/examples/Connection/non_blocking/CPP-connector.cpp index f3bf738f408..03b75f063c5 100644 --- a/examples/Connection/non_blocking/CPP-connector.cpp +++ b/examples/Connection/non_blocking/CPP-connector.cpp @@ -152,7 +152,7 @@ template <class SH, PR_CO_1> int IPC_Client<SH, PR_CO_2>::svc (void) { if (this->reactor ()) - ACE_Reactor::run_event_loop(); + ACE_Reactor::run_event_loop (); return 0; } @@ -173,7 +173,7 @@ template <class SH, PR_CO_1> int IPC_Client<SH, PR_CO_2>::init (int argc, char *argv[]) { // Call down to the CONNECTOR's open() method to do the initialization. - this->inherited::open (ACE_Reactor::instance()); + this->inherited::open (ACE_Reactor::instance ()); char *r_addr = argc > 1 ? argv[1] : ACE_SERVER_ADDRESS (ACE_DEFAULT_SERVER_HOST, @@ -184,7 +184,7 @@ IPC_Client<SH, PR_CO_2>::init (int argc, char *argv[]) char *l_addr = argc > 3 ? argv[3] : ACE_DEFAULT_LOCAL_PORT_STR; // Handle signals through the ACE_Reactor. - if (ACE_Reactor::instance()->register_handler + if (ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_handler_) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_handler"), -1); |