ACE/ace/Handle_Gobbler.inl

   1 // -*- C++ -*-
   2 // Since this is only included in Handle_Gobbler.h, these should be
   3 // inline, not ACE_INLINE.
   4 // FUZZ: disable check_for_inline
   5
   6 #include "ace/ACE.h"
   7 #include "ace/OS_NS_unistd.h"
   8 #include "ace/OS_NS_fcntl.h"
   9
  10 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  11
  12 inline void
  13 ACE_Handle_Gobbler::close_remaining_handles ()
  14 {
  15   ACE_Handle_Set_Iterator iter (this->handle_set_);
  16   for (ACE_HANDLE h = iter (); h != ACE_INVALID_HANDLE; h = iter ())
  17     ACE_OS::close (h);
  18 }
  19
  20 inline
  21 ACE_Handle_Gobbler::~ACE_Handle_Gobbler ()
  22 {
  23   this->close_remaining_handles ();
  24 }
  25
  26 inline int
  27 ACE_Handle_Gobbler::free_handles (size_t n_handles)
  28 {
  29   ACE_Handle_Set_Iterator iter (this->handle_set_);
  30   for (ACE_HANDLE h = iter ();
  31        h != ACE_INVALID_HANDLE && n_handles > 0;
  32        --n_handles, h = iter ())
  33     ACE_OS::close (h);
  34
  35   return 0;
  36 }
  37
  38 inline int
  39 ACE_Handle_Gobbler::consume_handles (size_t n_handles_to_keep_available)
  40 {
  41   int result = 0;
  42
  43 #if defined(ACE_WIN32)
  44   // On Win32, this style of gobbling doesn't seem to work.
  45   ACE_UNUSED_ARG(n_handles_to_keep_available);
  46
  47 #else
  48
  49   while (1)
  50     {
  51       ACE_HANDLE handle = ACE_OS::open (ACE_DEV_NULL, O_WRONLY);
  52
  53       if (handle == ACE_INVALID_HANDLE)
  54         {
  55           if (ACE::out_of_handles (errno))
  56             {
  57               result = this->free_handles (n_handles_to_keep_available);
  58               break;
  59             }
  60           else
  61             {
  62               result = -1;
  63               break;
  64             }
  65         }
  66       if (handle >= static_cast<ACE_HANDLE>(FD_SETSIZE))
  67         break;
  68       this->handle_set_.set_bit (handle);
  69     }
  70
  71 #endif /* ACE_WIN32 */
  72
  73   return result;
  74 }
  75
  76 ACE_END_VERSIONED_NAMESPACE_DECL