diff options
| author | Abdullah Sowayan <sowayan@users.noreply.github.com> | 2007-07-20 03:27:14 +0000 |
|---|---|---|
| committer | Abdullah Sowayan <sowayan@users.noreply.github.com> | 2007-07-20 03:27:14 +0000 |
| commit | 9571e27683d36960ec889ec236cfaaa169d3d2bd (patch) | |
| tree | 9a9b0af5cdb16c5498b1b73eb66f48660d7985c1 /ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp | |
| parent | 64ada59c715e7f5f56bd50910f4a745f30e6c2b2 (diff) | |
| download | ATCD-9571e27683d36960ec889ec236cfaaa169d3d2bd.tar.gz | |
Fri Jul 20 03:22:02 UTC 2007 Abdullah Sowayan <abdullah.sowayan@lmco.com>
Diffstat (limited to 'ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp')
| -rw-r--r-- | ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp b/ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp index 759dcb44861..e3ab37451c6 100644 --- a/ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp +++ b/ACE/examples/C++NPv2/AC_Client_Logging_Daemon.cpp @@ -73,9 +73,11 @@ public: SSL_CTX_free (ssl_ctx_); } + //FUZZ: disable check_for_lack_ACE_OS // Initialize the Connector. virtual int open (ACE_Reactor *r = ACE_Reactor::instance (), int flags = 0); + //FUZZ: enable check_for_lack_ACE_OS // Re-establish a connection to the logging server. int reconnect (); @@ -208,12 +210,13 @@ int AC_Output_Handler::svc () { if (message_index >= ACE_IOV_MAX || (ACE_OS::gettimeofday () - time_of_last_send >= ACE_Time_Value(FLUSH_TIMEOUT))) { - if (send (chunk, message_index) == -1) break; + if (this->send (chunk, message_index) == -1) break; time_of_last_send = ACE_OS::gettimeofday (); } } - if (message_index > 0) send (chunk, message_index); + if (message_index > 0) + this->send (chunk, message_index); no_sigpipe.restore_action (SIGPIPE, original_action); return 0; } @@ -372,7 +375,7 @@ int AC_CLD_Connector::reconnect () { ACE_Synch_Options options (ACE_Synch_Options::USE_TIMEOUT, timeout); if (i > 0) ACE_OS::sleep (timeout); - if (connect (handler_, remote_addr_, options) == 0) + if (this->connect (handler_, remote_addr_, options) == 0) break; timeout *= 2; // Exponential backoff. } |