summaryrefslogtreecommitdiff
path: root/examples/Connection/blocking
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>1996-11-01 08:40:32 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>1996-11-01 08:40:32 +0000
commit76171efcb983b4f2ff55a4013fed794f7a9bb471 (patch)
treea817b83efdc199c8f292b9a5bfd4047ef900f6b0 /examples/Connection/blocking
parentbad6c3a7b49b64377c60931084a6ef68ae64877b (diff)
downloadATCD-76171efcb983b4f2ff55a4013fed794f7a9bb471.tar.gz
foo
Diffstat (limited to 'examples/Connection/blocking')
-rw-r--r--examples/Connection/blocking/SPIPE-connector.cpp9
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))
{
}