summaryrefslogtreecommitdiff
path: root/netsvcs
diff options
context:
space:
mode:
authorSteve Huston <shuston@riverace.com>2001-07-06 22:27:40 +0000
committerSteve Huston <shuston@riverace.com>2001-07-06 22:27:40 +0000
commitf4a12ea0c3158cdb49d710d763944556bf855d27 (patch)
treebaf9d57bd6cabea231b6c798e49670c3299b8000 /netsvcs
parent9ce0492ba35587751b7f27041a1a781b0d49a574 (diff)
downloadATCD-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.cpp70
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_);