diff options
Diffstat (limited to 'ACE/examples/Reactor')
25 files changed, 152 insertions, 79 deletions
diff --git a/ACE/examples/Reactor/Dgram/CODgram.cpp b/ACE/examples/Reactor/Dgram/CODgram.cpp index 4d2aca88d9b..7baafdcdba0 100644 --- a/ACE/examples/Reactor/Dgram/CODgram.cpp +++ b/ACE/examples/Reactor/Dgram/CODgram.cpp @@ -54,8 +54,10 @@ public: virtual int handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask); + //FUZZ: disable check_for_lack_ACE_OS int send (const char *buf, size_t len); // Send the <buf> to the peer. + //FUZZ: enable check_for_lack_ACE_OS private: ACE_SOCK_CODgram endpoint_; diff --git a/ACE/examples/Reactor/Dgram/Dgram.cpp b/ACE/examples/Reactor/Dgram/Dgram.cpp index 93c3a6d02bb..156132028df 100644 --- a/ACE/examples/Reactor/Dgram/Dgram.cpp +++ b/ACE/examples/Reactor/Dgram/Dgram.cpp @@ -51,8 +51,10 @@ public: virtual int handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask); + //FUZZ: disable check_for_lack_ACE_OS int send (const char *buf, size_t len, const ACE_INET_Addr &); // Send the <buf> to the peer. + //FUZZ: enable check_for_lack_ACE_OS private: ACE_SOCK_Dgram endpoint_; diff --git a/ACE/examples/Reactor/Misc/pingpong.cpp b/ACE/examples/Reactor/Misc/pingpong.cpp index f4a3bc0630e..9a7a8566eae 100644 --- a/ACE/examples/Reactor/Misc/pingpong.cpp +++ b/ACE/examples/Reactor/Misc/pingpong.cpp @@ -265,8 +265,10 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[]) ACE_HANDLE handles[2]; + //FUZZ: disable check_for_lack_ACE_OS // Create a pipe and initialize the handles. ACE_Pipe pipe (handles); + //FUZZ: enable check_for_lack_ACE_OS #if defined (ACE_WIN32) || defined (CHORUS) if (ACE_Thread::spawn (ACE_THR_FUNC (worker), diff --git a/ACE/examples/Reactor/Misc/test_demuxing.cpp b/ACE/examples/Reactor/Misc/test_demuxing.cpp index 4bc6d340560..a55bdbab0f1 100644 --- a/ACE/examples/Reactor/Misc/test_demuxing.cpp +++ b/ACE/examples/Reactor/Misc/test_demuxing.cpp @@ -33,7 +33,11 @@ public: Sig_Handler (void); virtual ACE_HANDLE get_handle (void) const; virtual int handle_input (ACE_HANDLE); + + //FUZZ: disable check_for_lack_ACE_OS virtual int shutdown (ACE_HANDLE, ACE_Reactor_Mask); + //FUZZ: enable check_for_lack_ACE_OS + virtual int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0); diff --git a/ACE/examples/Reactor/Misc/test_early_timeouts.cpp b/ACE/examples/Reactor/Misc/test_early_timeouts.cpp index 4c7193d9a67..b539bdf7655 100644 --- a/ACE/examples/Reactor/Misc/test_early_timeouts.cpp +++ b/ACE/examples/Reactor/Misc/test_early_timeouts.cpp @@ -101,6 +101,7 @@ ACE_TMAIN (int, ACE_TCHAR *[]) } } + //FUZZ: disable check_for_lack_ACE_OS ACE_DEBUG ((LM_DEBUG, "There were %d early timers out of %d calls to select() (%f%%)\n" "The max early timeout was: %dsec %dusec\n", @@ -109,6 +110,7 @@ ACE_TMAIN (int, ACE_TCHAR *[]) float (no_of_early_timers) / iterations * 100, maximum_early_timeout.sec (), maximum_early_timeout.usec ())); + //FUZZ: enable check_for_lack_ACE_OS return 0; } diff --git a/ACE/examples/Reactor/Misc/test_event_handler_t.cpp b/ACE/examples/Reactor/Misc/test_event_handler_t.cpp index 4261859784e..021110739b6 100644 --- a/ACE/examples/Reactor/Misc/test_event_handler_t.cpp +++ b/ACE/examples/Reactor/Misc/test_event_handler_t.cpp @@ -15,7 +15,11 @@ public: virtual ACE_HANDLE get_handle (void) const { return 0; } virtual void set_handle (ACE_HANDLE) {} virtual int handle_async_io (ACE_HANDLE) { return 0; } + + //FUZZ: disable check_for_lack_ACE_OS virtual int shutdown (ACE_HANDLE, ACE_Reactor_Mask) { return 0; } + //FUZZ: enable check_for_lack_ACE_OS + virtual int signal_handler (int /* signum */, siginfo_t * = 0, ucontext_t * = 0) diff --git a/ACE/examples/Reactor/Misc/test_reactors.cpp b/ACE/examples/Reactor/Misc/test_reactors.cpp index 1676703118e..1c77f5e8c2f 100644 --- a/ACE/examples/Reactor/Misc/test_reactors.cpp +++ b/ACE/examples/Reactor/Misc/test_reactors.cpp @@ -23,8 +23,11 @@ public: Test_Task (void); ~Test_Task (void); + //FUZZ: disable check_for_lack_ACE_OS virtual int open (void *args = 0); virtual int close (u_long flags = 0); + //FUZZ: enable check_for_lack_ACE_OS + virtual int svc (void); virtual int handle_input (ACE_HANDLE handle); diff --git a/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp b/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp index d5f044e688d..522cbd1add9 100644 --- a/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp +++ b/ACE/examples/Reactor/Multicast/Log_Wrapper.cpp @@ -9,6 +9,7 @@ #include "ace/OS_NS_netdb.h" #include "ace/OS_NS_stdio.h" #include "ace/OS_NS_time.h" +#include "ace/OS_NS_stdlib.h" ACE_RCSID(Multicast, Log_Wrapper, "$Id$") @@ -44,7 +45,7 @@ Log_Wrapper::open (const int port, const char *mcast_addr) server_ = ACE_INET_Addr (port, mcast_addr); if (logger_.subscribe (server_) == -1) - ACE_OS::perror("can't subscribe to multicast group"), exit(1); + ACE_OS::perror("can't subscribe to multicast group"), ACE_OS::exit(1); // success. return 0; diff --git a/ACE/examples/Reactor/Multicast/client.cpp b/ACE/examples/Reactor/Multicast/client.cpp index 25b18c2ae6c..1483d66a381 100644 --- a/ACE/examples/Reactor/Multicast/client.cpp +++ b/ACE/examples/Reactor/Multicast/client.cpp @@ -31,10 +31,12 @@ parse_args (int argc, ACE_TCHAR *argv[]) { ACE_LOG_MSG->open (argv[0]); + //FUZZ: disable check_for_lack_ACE_OS // Start at argv[1] ACE_Get_Opt getopt (argc, argv, ACE_TEXT("m:ui:"), 1); for (int c; (c = getopt ()) != -1; ) + //FUZZ: enable check_for_lack_ACE_OS switch (c) { case 'm': @@ -47,8 +49,8 @@ parse_args (int argc, ACE_TCHAR *argv[]) // usage fallthrough default: ACE_ERROR ((LM_ERROR, - "%n: -m max_message_size (in k) -i iterations\n%a", - 1)); + "%n: -m max_message_size (in k) -i iterations\n%a", + 1)); /* NOTREACHED */ } } @@ -80,7 +82,7 @@ ACE_TMAIN (int argc, ACE_TCHAR **argv) while (iterations--) if (log.log_message (Log_Wrapper::LM_DEBUG, buf) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log"), -1); + ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log"), -1); } // otherwise, a file has been redirected, or give prompts @@ -99,27 +101,29 @@ ACE_TMAIN (int argc, ACE_TCHAR **argv) if (user_prompt) ACE_DEBUG ((LM_DEBUG, "\nEnter message ('Q':quit):\n")); - ssize_t nbytes = ACE_OS::read (ACE_STDIN, buf, max_message_size); + ssize_t nbytes = ACE_OS::read (ACE_STDIN, buf, max_message_size); if (nbytes <= 0) break; // End of file or error. + buf[nbytes - 1] = '\0'; // Quitting? if (user_prompt) - { - if (buf[0] == 'Q' || buf[0] == 'q') - break; - } - else // Keep from overrunning the receiver. - ACE_OS::sleep (1); + { + if (buf[0] == 'Q' || buf[0] == 'q') + break; + } + else // Keep from overrunning the receiver. + ACE_OS::sleep (1); // Send the message to the logger. if (log.log_message (Log_Wrapper::LM_DEBUG, buf) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log_message"), -1); - ACE_DEBUG ((LM_DEBUG, "finished sending message %d\n", count++)); + ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log_message"), -1); + + ACE_DEBUG ((LM_DEBUG, "finished sending message %d\n", count++)); } - } + } ACE_DEBUG ((LM_DEBUG, "Client done.\n")); return 0; diff --git a/ACE/examples/Reactor/Proactor/post_completions.cpp b/ACE/examples/Reactor/Proactor/post_completions.cpp index e9c7bcf43f6..1eaf0c5b176 100644 --- a/ACE/examples/Reactor/Proactor/post_completions.cpp +++ b/ACE/examples/Reactor/Proactor/post_completions.cpp @@ -147,8 +147,10 @@ public: virtual ~My_Task (void) {} // Destructor. + //FUZZ: disable check_for_lack_ACE_OS int open (void *proactor) { + //FUZZ: enable check_for_lack_ACE_OS // Store the proactor. this->proactor_ = (ACE_Proactor *) proactor; @@ -201,14 +203,14 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[]) // Signal set that we want to mask. // Clear the signal set. - if (sigemptyset (&signal_set) == -1) + if (ACE_OS::sigemptyset (&signal_set) == -1) ACE_ERROR_RETURN ((LM_ERROR, "Error:%p\n", "sigemptyset failed"), 1); // Add the SIGRTMAX to the signal set. - if (sigaddset (&signal_set, ACE_SIGRTMAX) == -1) + if (ACE_OS::sigaddset (&signal_set, ACE_SIGRTMAX) == -1) ACE_ERROR_RETURN ((LM_ERROR, "Error:%p\n", "sigaddset failed"), diff --git a/ACE/examples/Reactor/Proactor/simple_test_proactor.cpp b/ACE/examples/Reactor/Proactor/simple_test_proactor.cpp index 99d53bda5ac..147bc2773b5 100644 --- a/ACE/examples/Reactor/Proactor/simple_test_proactor.cpp +++ b/ACE/examples/Reactor/Proactor/simple_test_proactor.cpp @@ -50,8 +50,10 @@ public: ~Simple_Tester (void); + //FUZZ: disable check_for_lack_ACE_OS int open (void); // Open the operations and initiate read from the file. + //FUZZ: enble check_for_lack_ACE_OS protected: // = These methods are called by the freamwork. @@ -144,8 +146,7 @@ Simple_Tester::initiate_read_file (void) ACE_NEW_RETURN (mb, ACE_Message_Block (BUFSIZ + 1), -1); // Inititiate an asynchronous read from the file - if (this->rf_.read (*mb, - mb->size () - 1) == -1) + if (this->rf_.read (*mb, mb->size () - 1) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "ACE_Asynch_Read_File::read"), -1); ACE_DEBUG ((LM_DEBUG, @@ -183,11 +184,11 @@ Simple_Tester::handle_read_file (const ACE_Asynch_Read_File::Result &result) { // Read successful: write this to the file. if (this->wf_.write (result.message_block (), - result.bytes_transferred ()) == -1) - { - ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Asynch_Write_File::write")); - return; - } + result.bytes_transferred ()) == -1) + { + ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Asynch_Write_File::write")); + return; + } } } @@ -231,17 +232,17 @@ parse_args (int argc, ACE_TCHAR *argv[]) switch (c) { case 'f': - file = get_opt.opt_arg (); - break; + file = get_opt.opt_arg (); + break; case 'd': - dump_file = get_opt.opt_arg (); - break; + dump_file = get_opt.opt_arg (); + break; default: - ACE_ERROR ((LM_ERROR, "%p.\n", - "usage :\n" + ACE_ERROR ((LM_ERROR, "%p.\n", + "usage :\n" "-d <dumpfile>\n" - "-f <file>\n")); - return -1; + "-f <file>\n")); + return -1; } return 0; diff --git a/ACE/examples/Reactor/Proactor/test_aiocb.cpp b/ACE/examples/Reactor/Proactor/test_aiocb.cpp index c9c0d280f1b..52eeb6524b9 100644 --- a/ACE/examples/Reactor/Proactor/test_aiocb.cpp +++ b/ACE/examples/Reactor/Proactor/test_aiocb.cpp @@ -21,6 +21,8 @@ // // ============================================================================ +//FUZZ: disable check_for_lack_ACE_OS + #include <unistd.h> #include <fcntl.h> #include <sys/types.h> diff --git a/ACE/examples/Reactor/Proactor/test_aiosig.cpp b/ACE/examples/Reactor/Proactor/test_aiosig.cpp index 8b6702d6f23..0e1d1bc4cc4 100644 --- a/ACE/examples/Reactor/Proactor/test_aiosig.cpp +++ b/ACE/examples/Reactor/Proactor/test_aiosig.cpp @@ -20,6 +20,7 @@ // // ===================================================================== +//FUZZ: disable check_for_lack_ACE_OS #include <unistd.h> #include <fcntl.h> diff --git a/ACE/examples/Reactor/Proactor/test_aiosig_ace.cpp b/ACE/examples/Reactor/Proactor/test_aiosig_ace.cpp index 24a1823b06c..3a76ea81251 100644 --- a/ACE/examples/Reactor/Proactor/test_aiosig_ace.cpp +++ b/ACE/examples/Reactor/Proactor/test_aiosig_ace.cpp @@ -71,7 +71,7 @@ setup_signal_delivery (void) sigset_t full_set; // Get full set. - if (sigfillset (&full_set) != 0) + if (ACE_OS::sigfillset (&full_set) != 0) ACE_ERROR_RETURN ((LM_ERROR, "Error:(%P | %t):%p\n", "sigfillset failed"), @@ -87,13 +87,13 @@ setup_signal_delivery (void) // = Make a mask with SIGRTMIN only. We use only that signal to // issue <aio_>'s. - if (sigemptyset (&completion_signal) == -1) + if (ACE_OS::sigemptyset (&completion_signal) == -1) ACE_ERROR_RETURN ((LM_ERROR, "Error: %p\n", "Couldnt init the RT completion signal set"), -1); - if (sigaddset (&completion_signal, - SIGRTMIN) == -1) + if (ACE_OS::sigaddset (&completion_signal, + SIGRTMIN) == -1) ACE_ERROR_RETURN ((LM_ERROR, "Error: %p\n", "Couldnt init the RT completion signal set"), -1); @@ -109,16 +109,16 @@ setup_signal_handler (int signal_number) // Setting up the handler(!) for these signals. struct sigaction reaction; - sigemptyset (&reaction.sa_mask); // Nothing else to mask. + ACE_OS::sigemptyset (&reaction.sa_mask); // Nothing else to mask. reaction.sa_flags = SA_SIGINFO; // Realtime flag. #if defined (SA_SIGACTION) // Lynx says, it is better to set this bit to be portable. reaction.sa_flags &= SA_SIGACTION; #endif /* SA_SIGACTION */ reaction.sa_sigaction = null_handler; // Null handler. - int sigaction_return = sigaction (SIGRTMIN, - &reaction, - 0); + int sigaction_return = ACE_OS::sigaction (SIGRTMIN, + &reaction, + 0); if (sigaction_return == -1) ACE_ERROR_RETURN ((LM_ERROR, "Error: %p\n", "Proactor couldnt do sigaction for the RT SIGNAL"), @@ -202,9 +202,9 @@ query_aio_completions (void) siginfo_t sig_info; // Await the RT completion signal. - int sig_return = sigtimedwait (&completion_signal, - &sig_info, - &timeout); + int sig_return = ACE_OS::sigtimedwait (&completion_signal, + &sig_info, + &timeout); // Error case. // If failure is coz of timeout, then return *0* but set @@ -215,12 +215,14 @@ query_aio_completions (void) "Error waiting for RT completion signals"), -1); + //FUZZ: disable check_for_lack_ACE_OS // RT completion signals returned. if (sig_return != SIGRTMIN) ACE_ERROR_RETURN ((LM_ERROR, "Unexpected signal (%d) has been received while waiting for RT Completion Signals\n", sig_return), -1); + //FUZZ: enble check_for_lack_ACE_OS // @@ Debugging. ACE_DEBUG ((LM_DEBUG, @@ -349,10 +351,10 @@ int ACE_TMAIN (int, ACE_TCHAR *[]) { if (test_aio_calls () == 0) - printf ("RT SIG test successful:\n" - "ACE_POSIX_SIG_PROACTOR should work in this platform\n"); + ACE_OS::printf ("RT SIG test successful:\n" + "ACE_POSIX_SIG_PROACTOR should work in this platform\n"); else - printf ("RT SIG test failed:\n" - "ACE_POSIX_SIG_PROACTOR may not work in this platform\n"); + ACE_OS::printf ("RT SIG test failed:\n" + "ACE_POSIX_SIG_PROACTOR may not work in this platform\n"); return 0; } diff --git a/ACE/examples/Reactor/Proactor/test_end_event_loop.cpp b/ACE/examples/Reactor/Proactor/test_end_event_loop.cpp index 8a81e379bfd..db1e6645bec 100644 --- a/ACE/examples/Reactor/Proactor/test_end_event_loop.cpp +++ b/ACE/examples/Reactor/Proactor/test_end_event_loop.cpp @@ -51,10 +51,13 @@ public: virtual ~My_Task (void) {} // Destructor. + //FUZZ: disable check_for_lack_ACE_OS // If time_flag is zero do the eventloop indefinitely, otherwise do // it for finite amount of time (13secs!!!). int open (void *timed_event_loop) { + //FUZZ: enble check_for_lack_ACE_OS + // Set the local variable. if (timed_event_loop == 0) this->time_flag_ = 0; diff --git a/ACE/examples/Reactor/Proactor/test_proactor.cpp b/ACE/examples/Reactor/Proactor/test_proactor.cpp index db257d2ae96..8a3c0a72f06 100644 --- a/ACE/examples/Reactor/Proactor/test_proactor.cpp +++ b/ACE/examples/Reactor/Proactor/test_proactor.cpp @@ -279,8 +279,12 @@ class Sender : public ACE_Handler public: Sender (void); ~Sender (void); + + //FUZZ: disable check_for_lack_ACE_OS int open (const ACE_TCHAR *host, u_short port); + //FUZZ: enable check_for_lack_ACE_OS + ACE_HANDLE handle (void) const; void handle (ACE_HANDLE); diff --git a/ACE/examples/Reactor/Proactor/test_proactor2.cpp b/ACE/examples/Reactor/Proactor/test_proactor2.cpp index 084cb0eb840..ad483e962a8 100644 --- a/ACE/examples/Reactor/Proactor/test_proactor2.cpp +++ b/ACE/examples/Reactor/Proactor/test_proactor2.cpp @@ -118,9 +118,11 @@ public: Receiver (void); ~Receiver (void); + //FUZZ: disable check_for_lack_ACE_OS virtual void open (ACE_HANDLE handle, ACE_Message_Block &message_block); // This is called after the new connection has been accepted. + //FUZZ: enable check_for_lack_ACE_OS protected: // These methods are called by the framework @@ -372,8 +374,12 @@ class Sender : public ACE_Handler public: Sender (void); ~Sender (void); + + //FUZZ: disable check_for_lack_ACE_OS int open (const ACE_TCHAR *host, u_short port); void close (); + //FUZZ: enable check_for_lack_ACE_OS + ACE_HANDLE handle (void) const; void handle (ACE_HANDLE); @@ -420,7 +426,7 @@ Sender::Sender (void) Sender::~Sender (void) { - close (); + this->close (); } void Sender::close () @@ -746,14 +752,14 @@ int DisableSignal ( int SigNum ) #ifndef ACE_WIN32 sigset_t signal_set; - if ( sigemptyset (&signal_set) == - 1 ) + if ( ACE_OS::sigemptyset (&signal_set) == - 1 ) { ACE_ERROR ((LM_ERROR, "Error:(%P | %t):%p\n", "sigemptyset failed")); } - sigaddset (&signal_set, SigNum); + ACE_OS::sigaddset (&signal_set, SigNum); // Put the <signal_set>. if (ACE_OS::pthread_sigmask (SIG_BLOCK, &signal_set, 0) != 0) @@ -789,7 +795,7 @@ int PrintSigMask () } else for (int i = 1 ; i < 1000; i++) { - member = sigismember (&mask,i); + member = ACE_OS::sigismember (&mask,i); COUT ( "\nSig " ) COUT ( i ) diff --git a/ACE/examples/Reactor/Proactor/test_proactor3.cpp b/ACE/examples/Reactor/Proactor/test_proactor3.cpp index 7310fdc6a6f..9b92723e29a 100644 --- a/ACE/examples/Reactor/Proactor/test_proactor3.cpp +++ b/ACE/examples/Reactor/Proactor/test_proactor3.cpp @@ -188,9 +188,11 @@ public: Receiver (void); ~Receiver (void); + //FUZZ: disable check_for_lack_ACE_OS virtual void open (ACE_HANDLE handle, - ACE_Message_Block &message_block); + ACE_Message_Block &message_block); // This is called after the new connection has been accepted. + //FUZZ: enable check_for_lack_ACE_OS static long get_number_sessions (void) { return sessions_; } @@ -254,7 +256,7 @@ Receiver::check_destroy (void) void Receiver::open (ACE_HANDLE handle, - ACE_Message_Block &) + ACE_Message_Block &) { ACE_DEBUG ((LM_DEBUG, "%N:%l:Receiver::open called\n")); @@ -399,7 +401,7 @@ Receiver::handle_write_stream (const ACE_Asynch_Write_Stream::Result &result) { // This code is not robust enough to deal with short file writes // (which hardly ever happen);-) - // ACE_ASSERT (result.bytes_to_write () == result.bytes_transferred ()); + // ACE_ASSERT (result.bytes_to_write () == result.bytes_transferred ()); if (duplex == 0) initiate_read_stream (); @@ -419,8 +421,12 @@ class Sender : public ACE_Handler public: Sender (void); ~Sender (void); + + //FUZZ: disable check_for_lack_ACE_OS int open (const ACE_TCHAR *host, u_short port); void close (void); + //FUZZ: enable check_for_lack_ACE_OS + ACE_HANDLE handle (void) const; virtual void handle (ACE_HANDLE); @@ -465,7 +471,7 @@ Sender::Sender (void) Sender::~Sender (void) { - close (); + this->close (); } void Sender::close (void) @@ -490,8 +496,7 @@ int Sender::open (const ACE_TCHAR *host, u_short port) ACE_INET_Addr address (port, host); ACE_SOCK_Connector connector; - if (connector.connect (this->stream_, - address) == -1) + if (connector.connect (this->stream_, address) == -1) { ACE_ERROR_RETURN ((LM_ERROR, "%p\n", @@ -661,7 +666,7 @@ set_proactor_type (const char *ptype) if (!ptype) return false; - switch (toupper (*ptype)) + switch (ACE_OS::ace_toupper (*ptype)) { case 'D' : proactor_type = 0; return true; case 'A' : proactor_type = 1; return true; @@ -684,44 +689,44 @@ parse_args (int argc, ACE_TCHAR *argv[]) { case 'd': // duplex duplex = ACE_OS::atoi (get_opt.opt_arg ()); - break; + break; case 'h': // host for sender host = get_opt.opt_arg (); - break; + break; case 'p': // port number port = ACE_OS::atoi (get_opt.opt_arg ()); - break; + break; case 'n': // thread pool size threads = ACE_OS::atoi (get_opt.opt_arg ()); - break; + break; case 's': // number of senders senders = ACE_OS::atoi (get_opt.opt_arg ()); - if (senders > MaxSenders) - senders = MaxSenders; - break; + if (senders > MaxSenders) + senders = MaxSenders; + break; case 'o': // max number of aio for proactor max_aio_operations = ACE_OS::atoi (get_opt.opt_arg ()); break; case 't': // Proactor Type - if (set_proactor_type (get_opt.opt_arg ())) + if (set_proactor_type (get_opt.opt_arg ())) break; case 'u': default: - ACE_ERROR ((LM_ERROR, "%p.", - "\nusage:" - "\n-o <max number of started aio operations for Proactor>" + ACE_ERROR ((LM_ERROR, "%p.", + "\nusage:" + "\n-o <max number of started aio operations for Proactor>" "\n-t <Proactor type> UNIX-only, Win32-default always:" "\n a AIOCB" "\n i SIG" "\n s SUN" "\n d default" - "\n-d <duplex mode 1-on/0-off>" - "\n-h <host> for Sender mode" - "\n-n <number threads for Proactor pool>" - "\n-p <port to listen/connect>" - "\n-s <number of sender's instances>" - "\n-u show this message" - "\n")); + "\n-d <duplex mode 1-on/0-off>" + "\n-h <host> for Sender mode" + "\n-n <number threads for Proactor pool>" + "\n-p <port to listen/connect>" + "\n-s <number of sender's instances>" + "\n-u show this message" + "\n")); return -1; } @@ -815,13 +820,13 @@ disable_signal (int sigmin, int sigmax) #ifndef ACE_WIN32 sigset_t signal_set; - if (sigemptyset (&signal_set) == - 1) + if (ACE_OS::sigemptyset (&signal_set) == - 1) ACE_ERROR ((LM_ERROR, "Error:(%P | %t):%p\n", "sigemptyset failed")); for (int i = sigmin; i <= sigmax; i++) - sigaddset (&signal_set, i); + ACE_OS::sigaddset (&signal_set, i); // Put the <signal_set>. if (ACE_OS::pthread_sigmask (SIG_BLOCK, &signal_set, 0) != 0) @@ -855,7 +860,7 @@ print_sigmask (void) else for (int i = 1; i < 1000; i++) { - member = sigismember (&mask,i); + member = ACE_OS::sigismember (&mask,i); COUT ("\nSig ") COUT (i) diff --git a/ACE/examples/Reactor/Proactor/test_udp_proactor.cpp b/ACE/examples/Reactor/Proactor/test_udp_proactor.cpp index c14dc280c9e..1ff800afb04 100644 --- a/ACE/examples/Reactor/Proactor/test_udp_proactor.cpp +++ b/ACE/examples/Reactor/Proactor/test_udp_proactor.cpp @@ -223,7 +223,10 @@ class Sender : public ACE_Handler public: Sender (void); ~Sender (void); + + //FUZZ: disable check_for_lack_ACE_OS int open (const ACE_TCHAR *host, u_short port); + //FUZZ: enable check_for_lack_ACE_OS protected: // These methods are called by the freamwork diff --git a/ACE/examples/Reactor/WFMO_Reactor/Handle_Close.cpp b/ACE/examples/Reactor/WFMO_Reactor/Handle_Close.cpp index 9eb6d7c727a..c90e1f5bcb8 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Handle_Close.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Handle_Close.cpp @@ -260,9 +260,12 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[]) { int result = 0; + //FUZZ: disable check_for_lack_ACE_OS // Parse args ACE_Get_Opt getopt (argc, argv, ACE_TEXT ("swmc"), 1); + for (int c; (c = getopt ()) != -1; ) + //FUZZ: enable check_for_lack_ACE_OS switch (c) { case 's': @@ -323,8 +326,11 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[]) // Note that handle_output will get called automatically since the // pipe is writable! + //FUZZ: disable check_for_lack_ACE_OS // Run for three seconds ACE_Time_Value time (3); + //FUZZ: enable check_for_lack_ACE_OS + reactor->run_reactor_event_loop (time); ACE_DEBUG ((LM_DEBUG, "\nClosing down the application\n\n")); diff --git a/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp b/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp index ba4565cfd95..6ada1e55780 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp @@ -109,8 +109,10 @@ public: int svc (void); // Task event loop. + //FUZZ: disable check_for_lack_ACE_OS int signal (size_t index); // Signal an event. + //FUZZ: enable check_for_lack_ACE_OS private: ACE_Auto_Event *events_; diff --git a/ACE/examples/Reactor/WFMO_Reactor/Prerun_State_Changes.cpp b/ACE/examples/Reactor/WFMO_Reactor/Prerun_State_Changes.cpp index e276fd7d3f8..740ee77041c 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Prerun_State_Changes.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Prerun_State_Changes.cpp @@ -21,6 +21,7 @@ #include "ace/Reactor.h" #include "ace/OS_main.h" +#include "ace/OS_NS_sys_socket.h" ACE_RCSID(WFMO_Reactor, Prerun_State_Changes, "$Id$") @@ -44,7 +45,7 @@ public: int ACE_TMAIN (int, ACE_TCHAR *[]) { - ACE_HANDLE handle = (ACE_HANDLE) ::socket (PF_INET, SOCK_STREAM, 0); + ACE_HANDLE handle = ACE_OS::socket (PF_INET, SOCK_STREAM, 0); Event_Handler *event_handler = new Event_Handler; diff --git a/ACE/examples/Reactor/WFMO_Reactor/Removals.cpp b/ACE/examples/Reactor/WFMO_Reactor/Removals.cpp index 260b9e897ee..238115e05eb 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Removals.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Removals.cpp @@ -91,7 +91,11 @@ ACE_TMAIN (int argc, ACE_TCHAR *[]) new Event_Handler (static_cast<int> (i), close_down); int result = 0; + + //FUZZ: disable check_for_lack_ACE_OS ACE_Time_Value time (1); + //FUZZ: enable check_for_lack_ACE_OS + while (1) { result = ACE_Reactor::instance ()->handle_events (time); diff --git a/ACE/examples/Reactor/WFMO_Reactor/Suspended_Removals.cpp b/ACE/examples/Reactor/WFMO_Reactor/Suspended_Removals.cpp index ead467146a5..a2a781a0c55 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Suspended_Removals.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Suspended_Removals.cpp @@ -61,7 +61,10 @@ ACE_TMAIN (int, ACE_TCHAR *[]) Event_Handler handler; ACE_WFMO_Reactor reactor; ACE_Reactor base_reactor (&reactor); + + //FUZZ: disable check_for_lack_ACE_OS ACE_Time_Value time (1); + //FUZZ: enable check_for_lack_ACE_OS int result = reactor.register_handler (&handler); diff --git a/ACE/examples/Reactor/WFMO_Reactor/Talker.cpp b/ACE/examples/Reactor/WFMO_Reactor/Talker.cpp index dd10962b320..12bf5e32eaa 100644 --- a/ACE/examples/Reactor/WFMO_Reactor/Talker.cpp +++ b/ACE/examples/Reactor/WFMO_Reactor/Talker.cpp @@ -161,10 +161,12 @@ public: Peer_Handler (int argc, ACE_TCHAR *argv[]); ~Peer_Handler (void); + //FUZZ: disable check_for_lack_ACE_OS int open (void * =0); // This method creates the network connection to the remote peer. // It does blocking connects and accepts depending on whether a // hostname was specified from the command line. + //FUZZ: enable check_for_lack_ACE_OS virtual void handle_read_stream (const ACE_Asynch_Read_Stream::Result &result); // This method will be called when an asynchronous read completes on a stream. @@ -227,11 +229,13 @@ public: STDIN_Handler (MT_TASK &ph); // Initialization. + //FUZZ: disable check_for_lack_ACE_OS virtual int open (void * = 0); // Activate object. virtual int close (u_long = 0); // Shut down. + //FUZZ: enable check_for_lack_ACE_OS int svc (void); // Thread runs here as an active object. |