summaryrefslogtreecommitdiff
path: root/examples/Connection
diff options
context:
space:
mode:
authorirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-07-26 20:44:27 +0000
committerirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-07-26 20:44:27 +0000
commit6b02514f8332715829f82e0f49f47d5f6a59a2f8 (patch)
tree86d968964d75dee5fb35253f52fd8ee21453deb0 /examples/Connection
parent0725903fd35de34a14bf4fc7eb08fbca79443495 (diff)
downloadATCD-6b02514f8332715829f82e0f49f47d5f6a59a2f8.tar.gz
*** empty log message ***
Diffstat (limited to 'examples/Connection')
-rw-r--r--examples/Connection/blocking/SPIPE-acceptor.cpp4
-rw-r--r--examples/Connection/blocking/SPIPE-connector.cpp6
-rw-r--r--examples/Connection/misc/Connection_Handler.cpp4
-rw-r--r--examples/Connection/misc/test_upipe.cpp2
-rw-r--r--examples/Connection/non_blocking/CPP-acceptor.cpp6
-rw-r--r--examples/Connection/non_blocking/CPP-connector.cpp6
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);