diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1999-01-03 21:48:41 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1999-01-03 21:48:41 +0000 |
commit | fdcdf85d64fe723d212a5d7ebc58ef463869913f (patch) | |
tree | 25a4dc53aac9c6338b8ed446276ec035b028c18e /examples/Connection | |
parent | 55147c5ba6dc403aaf7428fb7720175d3161d80b (diff) | |
download | ATCD-fdcdf85d64fe723d212a5d7ebc58ef463869913f.tar.gz |
.
Diffstat (limited to 'examples/Connection')
-rw-r--r-- | examples/Connection/blocking/SPIPE-connector.cpp | 53 |
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; } } |