diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-01 08:40:32 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-01 08:40:32 +0000 |
commit | 76171efcb983b4f2ff55a4013fed794f7a9bb471 (patch) | |
tree | a817b83efdc199c8f292b9a5bfd4047ef900f6b0 /examples/Connection/blocking | |
parent | bad6c3a7b49b64377c60931084a6ef68ae64877b (diff) | |
download | ATCD-76171efcb983b4f2ff55a4013fed794f7a9bb471.tar.gz |
foo
Diffstat (limited to 'examples/Connection/blocking')
-rw-r--r-- | examples/Connection/blocking/SPIPE-connector.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/examples/Connection/blocking/SPIPE-connector.cpp b/examples/Connection/blocking/SPIPE-connector.cpp index 940f716433f..3bc22f1a280 100644 --- a/examples/Connection/blocking/SPIPE-connector.cpp +++ b/examples/Connection/blocking/SPIPE-connector.cpp @@ -30,7 +30,7 @@ Peer_Handler::open (void *) if (ACE::register_stdin_handler (this, ACE_Service_Config::reactor (), ACE_Service_Config::thr_mgr ()) == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "register_stdin_handler")); + ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_stdin_handler"), -1); } else // If iterations_ has been set, send iterations_ buffers. { @@ -46,9 +46,8 @@ Peer_Handler::open (void *) while (iterations_-- > 0 && this->peer ().send_n (buffer, length) == length) continue; - - return this->peer ().close (); } + return this->peer ().close (); } int @@ -93,8 +92,8 @@ Peer_Handler::display_menu (void) } IPC_Client::IPC_Client (void) - : rendezvous_ ("acepipe"), - iterations_ (0), + : iterations_ (0), + rendezvous_ ("acepipe"), done_handler_ (ACE_Sig_Handler_Ex (ACE_Service_Config::end_proactor_event_loop)) { } |