diff options
Diffstat (limited to 'examples/APG/Reactor/HAStatus-AC.cpp')
-rw-r--r-- | examples/APG/Reactor/HAStatus-AC.cpp | 147 |
1 files changed, 0 insertions, 147 deletions
diff --git a/examples/APG/Reactor/HAStatus-AC.cpp b/examples/APG/Reactor/HAStatus-AC.cpp deleted file mode 100644 index 24861113f85..00000000000 --- a/examples/APG/Reactor/HAStatus-AC.cpp +++ /dev/null @@ -1,147 +0,0 @@ -// $Id$ - -#include "ace/OS_NS_errno.h" -#include "ace/OS_NS_sys_time.h" -#include "ace/os_include/os_netdb.h" -#include "ClientService.h" - -// Listing 1 code/ch07 -#include "ace/Log_Msg.h" -#include "ace/INET_Addr.h" -#include "ace/SOCK_Acceptor.h" -#include "ace/Reactor.h" -#include "ace/Acceptor.h" - -typedef ACE_Acceptor<ClientService, ACE_SOCK_ACCEPTOR> - ClientAcceptor; -// Listing 1 - -// Listing 4 code/ch07 -int -ClientService::open (void *p) -{ - if (super::open (p) == -1) - return -1; - - ACE_TCHAR peer_name[MAXHOSTNAMELEN]; - ACE_INET_Addr peer_addr; - if (this->peer ().get_remote_addr (peer_addr) == 0 && - peer_addr.addr_to_string (peer_name, MAXHOSTNAMELEN) == 0) - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("(%P|%t) Connection from %s\n"), - peer_name)); - return 0; -} -// Listing 4 - -// Listing 5 code/ch07 -int -ClientService::handle_input (ACE_HANDLE) -{ - const size_t INPUT_SIZE = 4096; - char buffer[INPUT_SIZE]; - ssize_t recv_cnt, send_cnt; - - recv_cnt = this->peer ().recv (buffer, sizeof(buffer)); - if (recv_cnt <= 0) - { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("(%P|%t) Connection closed\n"))); - return -1; - } - - send_cnt = - this->peer ().send (buffer, - static_cast<size_t> (recv_cnt)); - if (send_cnt == recv_cnt) - return 0; - if (send_cnt == -1 && ACE_OS::last_error () != EWOULDBLOCK) - ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("(%P|%t) %p\n"), - ACE_TEXT ("send")), - 0); - if (send_cnt == -1) - send_cnt = 0; - ACE_Message_Block *mb; - size_t remaining = - static_cast<size_t> ((recv_cnt - send_cnt)); - ACE_NEW_RETURN (mb, ACE_Message_Block (remaining), -1); - mb->copy (&buffer[send_cnt], remaining); - int output_off = this->msg_queue ()->is_empty (); - ACE_Time_Value nowait (ACE_OS::gettimeofday ()); - if (this->putq (mb, &nowait) == -1) - { - ACE_ERROR ((LM_ERROR, - ACE_TEXT ("(%P|%t) %p; discarding data\n"), - ACE_TEXT ("enqueue failed"))); - mb->release (); - return 0; - } - if (output_off) - return this->reactor ()->register_handler - (this, ACE_Event_Handler::WRITE_MASK); - return 0; -} -// Listing 5 - -// Listing 6 code/ch07 -int -ClientService::handle_output (ACE_HANDLE) -{ - ACE_Message_Block *mb; - ACE_Time_Value nowait (ACE_OS::gettimeofday ()); - while (-1 != this->getq (mb, &nowait)) - { - ssize_t send_cnt = - this->peer ().send (mb->rd_ptr (), mb->length ()); - if (send_cnt == -1) - ACE_ERROR ((LM_ERROR, - ACE_TEXT ("(%P|%t) %p\n"), - ACE_TEXT ("send"))); - else - mb->rd_ptr (static_cast<size_t> (send_cnt)); - if (mb->length () > 0) - { - this->ungetq (mb); - break; - } - mb->release (); - } - return (this->msg_queue ()->is_empty ()) ? -1 : 0; -} -// Listing 6 - -// Listing 7 code/ch07 -int -ClientService::handle_close (ACE_HANDLE h, ACE_Reactor_Mask mask) -{ - if (mask == ACE_Event_Handler::WRITE_MASK) - return 0; - return super::handle_close (h, mask); -} -// Listing 7 - -// Listing 2 code/ch07 -int ACE_TMAIN (int, ACE_TCHAR *[]) -{ - ACE_INET_Addr port_to_listen ("HAStatus"); - ClientAcceptor acceptor; - if (acceptor.open (port_to_listen) == -1) - return 1; - - ACE_Reactor::instance ()->run_reactor_event_loop (); - - return (0); -} -// Listing 2 - -// Listing 8 code/ch07 -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Acceptor<ClientService, ACE_SOCK_ACCEPTOR>; -template class ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Acceptor<ClientService, ACE_SOCK_ACCEPTOR> -#pragma instantiate \ - ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ -// Listing 8 |