Fri Jul 20 03:22:02 UTC 2007 Abdullah Sowayan <abdullah.sowayan@lmco.com>

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.