ACE/ace/Monitor_Point_Registry.cpp

   1 #include "ace/Monitor_Point_Registry.h"
   2
   3 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
   4
   5 #include "ace/Monitor_Base.h"
   6 #include "ace/Guard_T.h"
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 namespace ACE
  11 {
  12   namespace Monitor_Control
  13   {
  14     Monitor_Point_Registry*
  15     Monitor_Point_Registry::instance ()
  16     {
  17       return
  18         ACE_Singleton<Monitor_Point_Registry, ACE_SYNCH_MUTEX>::instance ();
  19     }
  20
  21     bool
  22     Monitor_Point_Registry::add (Monitor_Base* type)
  23     {
  24       if (type == 0)
  25         {
  26           ACELIB_ERROR_RETURN ((LM_ERROR,
  27                              "registry add: null type\n"),
  28                             false);
  29         }
  30
  31       int status = 0;
  32
  33       {
  34         ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, this->mutex_, false);
  35
  36         type->add_ref ();
  37
  38         status = this->map_.bind (type->name (), type);
  39       }
  40
  41       if (status == -1)
  42         {
  43           ACELIB_ERROR_RETURN ((LM_ERROR,
  44                              "registry add: map bind failed\n"),
  45                             false);
  46         }
  47
  48       return (status == 0);
  49     }
  50
  51     bool
  52     Monitor_Point_Registry::remove (const char* name)
  53     {
  54       if (name == 0)
  55         {
  56           ACELIB_ERROR_RETURN ((LM_ERROR,
  57                              "registry remove: null name\n"),
  58                             false);
  59         }
  60
  61       int status = 0;
  62       Map::data_type mp = 0;
  63
  64       {
  65         ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, this->mutex_, false);
  66
  67         ACE_CString name_str (name, 0, false);
  68         status = this->map_.unbind (name_str, mp);
  69       }
  70
  71       if (status == -1)
  72         {
  73 // (JP) There is a problem with this failing on a single ACE_Message_Queue
  74 //      monitor per process. I think it is the message queue associated
  75 //      with the default reactor, maybe because at that low level, ACE
  76 //      is using malloc with placement, then free, which may bypass the
  77 //      normal destructors. In any case, it happens only at shutdown
  78 //      and there seems to be no memory leak.
  79 //          ACELIB_ERROR_RETURN ((LM_ERROR,
  80 //                             "registry remove: unbind failed for %s\n",
  81 //                             name),
  82 //                            false);
  83         }
  84       else
  85         {
  86           mp->remove_ref ();
  87         }
  88
  89       return (status == 0);
  90     }
  91
  92     Monitor_Control_Types::NameList
  93     Monitor_Point_Registry::names ()
  94     {
  95       Monitor_Control_Types::NameList name_holder_;
  96
  97       {
  98         ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, this->mutex_, 0);
  99
 100         for (Map::CONST_ITERATOR i (this->map_); !i.done (); i.advance ())
 101           {
 102             name_holder_.push_back (i->key ());
 103           }
 104       }
 105
 106       return name_holder_;
 107     }
 108
 109     Monitor_Base*
 110     Monitor_Point_Registry::get (const ACE_CString& name) const
 111     {
 112       Map::data_type mp = 0;
 113
 114       {
 115         ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, this->mutex_, 0);
 116
 117         this->map_.find (name, mp);
 118       }
 119
 120       if (mp != 0)
 121         {
 122           mp->add_ref ();
 123         }
 124
 125       return mp;
 126     }
 127
 128     long
 129     Monitor_Point_Registry::constraint_id ()
 130     {
 131       long retval = 0;
 132
 133       {
 134         ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, this->mutex_, -1);
 135
 136         retval = this->constraint_id_++;
 137       }
 138
 139       return retval;
 140     }
 141
 142     void
 143     Monitor_Point_Registry::cleanup ()
 144     {
 145       for (Map::ITERATOR i = this->map_.begin ();
 146            i != this->map_.end ();
 147            i.advance ())
 148         {
 149           Map::ENTRY* entry = 0;
 150           i.next (entry);
 151           entry->int_id_->remove_ref ();
 152         }
 153     }
 154   }
 155 }
 156
 157 ACE_END_VERSIONED_NAMESPACE_DECL
 158
 159 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
 160