summaryrefslogtreecommitdiff
path: root/examples/Connection
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>1999-01-03 21:48:41 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>1999-01-03 21:48:41 +0000
commitfdcdf85d64fe723d212a5d7ebc58ef463869913f (patch)
tree25a4dc53aac9c6338b8ed446276ec035b028c18e /examples/Connection
parent55147c5ba6dc403aaf7428fb7720175d3161d80b (diff)
downloadATCD-fdcdf85d64fe723d212a5d7ebc58ef463869913f.tar.gz
.
Diffstat (limited to 'examples/Connection')
-rw-r--r--examples/Connection/blocking/SPIPE-connector.cpp53
1 files changed, 38 insertions, 15 deletions
diff --git a/examples/Connection/blocking/SPIPE-connector.cpp b/examples/Connection/blocking/SPIPE-connector.cpp
index 0684d54c5ac..a3e61e90e33 100644
--- a/examples/Connection/blocking/SPIPE-connector.cpp
+++ b/examples/Connection/blocking/SPIPE-connector.cpp
@@ -17,14 +17,16 @@ Peer_Handler::Peer_Handler (int iterations)
{
}
-Peer_Handler::~Peer_Handler ()
+Peer_Handler::~Peer_Handler (void)
{
}
int
Peer_Handler::open (void *)
{
- ACE_DEBUG ((LM_DEBUG, "activating %d\n", this->get_handle ()));
+ ACE_DEBUG ((LM_DEBUG,
+ "activating %d\n",
+ this->get_handle ()));
// If iterations_ has not been set, read from stdin.
if (iterations_ == 0)
@@ -33,7 +35,10 @@ Peer_Handler::open (void *)
if (ACE_Event_Handler::register_stdin_handler (this,
ACE_Reactor::instance (),
ACE_Thread_Manager::instance ()) == -1)
- ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "register_stdin_handler"), -1);
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "%p\n",
+ "register_stdin_handler"),
+ -1);
else
return 0;
}
@@ -67,11 +72,17 @@ Peer_Handler::handle_input (ACE_HANDLE)
if (n > 0)
if (this->peer ().send (buf, n) != n)
- ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "write failed"), -1);
- else if (n == 0) /* Explicitly close the connection. */
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "%p\n",
+ "write failed"),
+ -1);
+ else if (n == 0) // Explicitly close the connection.
{
if (this->peer ().close () == -1)
- ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "close"), 1);
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "%p\n",
+ "close"),
+ 1);
return -1;
}
else
@@ -83,7 +94,8 @@ int
Peer_Handler::handle_close (ACE_HANDLE,
ACE_Reactor_Mask)
{
- ACE_DEBUG ((LM_DEBUG, "Shutting down\n"));
+ ACE_DEBUG ((LM_DEBUG,
+ "Shutting down\n"));
return 0;
}
@@ -96,14 +108,16 @@ Peer_Handler::get_handle (void) const
void
Peer_Handler::display_menu (void)
{
- ACE_DEBUG ((LM_DEBUG, "\nplease enter input..: "));
+ ACE_DEBUG ((LM_DEBUG,
+ "\nplease enter input..: "));
}
IPC_Client::IPC_Client (void)
: iterations_ (0),
done_handler_ (ACE_Sig_Handler_Ex (ACE_Proactor::end_event_loop))
{
- ACE_OS::strcpy (rendezvous_, ACE_TEXT ("acepipe"));
+ ACE_OS::strcpy (rendezvous_,
+ ACE_TEXT ("acepipe"));
}
IPC_Client::~IPC_Client (void)
@@ -122,21 +136,28 @@ IPC_Client::init (int argc, char *argv[])
(SIGINT, &this->done_handler_) == -1)
return -1;
- ACE_DEBUG ((LM_DEBUG, "Opening %s\n", ACE_MULTIBYTE_STRING (rendezvous_)));
+ ACE_DEBUG ((LM_DEBUG,
+ "Opening %s\n",
+ ACE_MULTIBYTE_STRING (rendezvous_)));
Peer_Handler *ph;
- ACE_NEW_RETURN (ph, Peer_Handler (iterations_), -1);
+ ACE_NEW_RETURN (ph,
+ Peer_Handler (iterations_),
+ -1);
// Connect to the peer, reusing the local addr if necessary.
if (this->connect (ph,
ACE_SPIPE_Addr (rendezvous_),
ACE_Synch_Options::defaults,
- (ACE_SPIPE_Addr &) ACE_Addr::sap_any,
+ ACE_sap_any_cast (ACE_SPIPE_Addr &),
0,
O_RDWR | FILE_FLAG_OVERLAPPED,
0) == -1)
- ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "connect"), -1);
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "%p\n",
+ "connect"),
+ -1);
return 0;
}
@@ -155,7 +176,8 @@ IPC_Client::svc (void)
}
int
-IPC_Client::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
+IPC_Client::handle_close (ACE_HANDLE,
+ ACE_Reactor_Mask)
{
return 0;
}
@@ -183,7 +205,8 @@ IPC_Client::parse_args (int argc, char *argv[])
default:
ACE_ERROR_RETURN ((LM_ERROR,
"usage: %n -i <iterations>\n"
- "-r <rendezvous>\n"), -1);
+ "-r <rendezvous>\n"),
+ -1);
break;
}
}