diff options
author | Steve Huston <shuston@riverace.com> | 2001-07-06 22:27:40 +0000 |
---|---|---|
committer | Steve Huston <shuston@riverace.com> | 2001-07-06 22:27:40 +0000 |
commit | f4a12ea0c3158cdb49d710d763944556bf855d27 (patch) | |
tree | baf9d57bd6cabea231b6c798e49670c3299b8000 /netsvcs | |
parent | 9ce0492ba35587751b7f27041a1a781b0d49a574 (diff) | |
download | ATCD-f4a12ea0c3158cdb49d710d763944556bf855d27.tar.gz |
ChangeLogTag:Fri Jul 06 18:20:39 2001 Steve Huston <shuston@riverace.com>
Diffstat (limited to 'netsvcs')
-rw-r--r-- | netsvcs/lib/Client_Logging_Handler.cpp | 70 |
1 files changed, 37 insertions, 33 deletions
diff --git a/netsvcs/lib/Client_Logging_Handler.cpp b/netsvcs/lib/Client_Logging_Handler.cpp index 43cc54b5b01..8fe4c6d5fbf 100644 --- a/netsvcs/lib/Client_Logging_Handler.cpp +++ b/netsvcs/lib/Client_Logging_Handler.cpp @@ -64,10 +64,11 @@ ACE_Client_Logging_Handler::open (void *) ACE_TEXT ("%p\n"), ACE_TEXT ("get_remote_addr")), -1); - +#if 0 ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("connected to client on handle %u\n"), this->peer ().get_handle ())); +#endif /* 0 */ return 0; } @@ -87,9 +88,11 @@ ACE_Client_Logging_Handler::get_handle (void) const int ACE_Client_Logging_Handler::handle_input (ACE_HANDLE handle) { +#if 0 ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("in handle_input, handle = %u\n"), handle)); +#endif /* 0 */ if (handle == this->logging_output_) // We're getting a message from the logging server! @@ -125,8 +128,10 @@ ACE_Client_Logging_Handler::handle_input (ACE_HANDLE handle) ACE_TEXT ("remove_handler")), -1); spipe.close (); +#if 0 ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("client closing down\n"))); +#endif /* 0 */ return 0; } #else @@ -161,8 +166,10 @@ ACE_Client_Logging_Handler::handle_input (ACE_HANDLE handle) this->peer ().close (); else ACE_OS::closesocket (handle); +#if 0 ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("client closing down\n"))); +#endif /* 0 */ return 0; /* NOTREACHED */ @@ -184,8 +191,10 @@ ACE_Client_Logging_Handler::handle_input (ACE_HANDLE handle) 0); ACE_OS::closesocket (handle); +# if 0 ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("client closing down\n"))); +# endif /* 0 */ return 0; } #endif /* ACE_WIN32 */ @@ -206,38 +215,36 @@ ACE_Client_Logging_Handler::handle_input (ACE_HANDLE handle) // seriously wrong, so shutting down the connection is probably // the best solution. if (retrieved != length) - { - ACE_DEBUG ((LM_DEBUG, + { +#if 0 + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("partial message retrieved, attempting second try...\n"))); +#endif /* 0 */ int remainder = length - retrieved; - - int secondtry = ACE_OS::recv (handle, - ((char *) &log_record) + retrieved, - remainder); - if (secondtry != remainder) - { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("second try failed\n"))); - - if (ACE_Reactor::instance ()->remove_handler - (handle, - ACE_Event_Handler::READ_MASK - | ACE_Event_Handler::EXCEPT_MASK - | ACE_Event_Handler::DONT_CALL) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("%n: %p\n"), - ACE_TEXT ("remove_handler")), - 0); - - ACE_OS::closesocket (handle); - - ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("%p\n"), - ACE_TEXT ("recv")), - 0); - } - } + + int secondtry = ACE_OS::recv (handle, + ((char *) &log_record) + retrieved, + remainder); + if (secondtry != remainder) + { + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("recv"))); + + if (ACE_Reactor::instance ()->remove_handler + (handle, + ACE_Event_Handler::READ_MASK + | ACE_Event_Handler::EXCEPT_MASK + | ACE_Event_Handler::DONT_CALL) == -1) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("%n: %p\n"), + ACE_TEXT ("remove_handler"))); + + ACE_OS::closesocket (handle); + return 0; + } + } } #endif /* ACE_HAS_STREAM_PIPES */ @@ -263,9 +270,6 @@ ACE_Client_Logging_Handler::handle_exception (ACE_HANDLE handle) int ACE_Client_Logging_Handler::close (u_long) { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("shutting down!!!\n"))); - if (this->logging_output_ != ACE_STDERR) ACE_OS::closesocket (this->logging_output_); |