TAO/tao/ObjectKey_Table.cpp

   1 #include "tao/ObjectKey_Table.h"
   2 #include "tao/ORB_Core.h"
   3 #include "tao/Refcounted_ObjectKey.h"
   4
   5 #if !defined (__ACE_INLINE__)
   6 # include "tao/ObjectKey_Table.inl"
   7 #endif /* ! __ACE_INLINE__ */
   8
   9 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 bool
  12 TAO::Less_Than_ObjectKey::operator () (const TAO::ObjectKey &lhs,
  13                                        const TAO::ObjectKey &rhs) const
  14 {
  15   const CORBA::ULong rlen = rhs.length ();
  16   const CORBA::ULong llen = lhs.length ();
  17   if (llen < rlen)
  18     {
  19       return 1;
  20     }
  21   else if (llen > rlen)
  22     {
  23       return 0;
  24     }
  25
  26   const CORBA::Octet * rhs_buff = rhs.get_buffer ();
  27   const CORBA::Octet * lhs_buff = lhs.get_buffer ();
  28   const bool result = (ACE_OS::memcmp (lhs_buff, rhs_buff, rlen) < 0);
  29
  30   return result;
  31 }
  32
  33 /********************************************************/
  34 TAO::ObjectKey_Table::ObjectKey_Table ()
  35   : table_ ()
  36 {
  37 }
  38
  39 TAO::ObjectKey_Table::~ObjectKey_Table ()
  40 {
  41   this->table_.close ();
  42 }
  43
  44 int
  45 TAO::ObjectKey_Table::destroy ()
  46 {
  47   if (this->table_.current_size ())
  48     {
  49       ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
  50                         ace_mon,
  51                         this->lock_,
  52                         0);
  53
  54       TABLE::ITERATOR end_iter = this->table_.end ();
  55       TABLE::ITERATOR start;
  56
  57       while ((start = this->table_.begin ()) != end_iter)
  58         {
  59           TABLE::ENTRY &ent = (*start);
  60
  61           ent.item ()->decr_refcount ();
  62           this->table_.unbind (&ent);
  63         }
  64     }
  65
  66   return 0;
  67 }
  68
  69 int
  70 TAO::ObjectKey_Table::bind_i (const TAO::ObjectKey &key,
  71                               TAO::Refcounted_ObjectKey *&key_new)
  72 {
  73   ACE_NEW_RETURN (key_new,
  74                   TAO::Refcounted_ObjectKey (key),
  75                   -1);
  76
  77   int const retval =  this->table_.bind (key, key_new);
  78
  79   if (retval != -1)
  80     {
  81       key_new->incr_refcount ();
  82     }
  83   else
  84     {
  85       key_new->decr_refcount ();
  86     }
  87
  88   return retval;
  89 }
  90
  91 int
  92 TAO::ObjectKey_Table::unbind_i (TAO::Refcounted_ObjectKey *&key_new)
  93 {
  94   TAO::Refcounted_ObjectKey *tmp = nullptr;
  95
  96   if (this->table_.unbind (key_new->object_key (), tmp) != -1)
  97     {
  98       // @@ Cant do much if the unbind fails.
  99       // Remove our refcount on the ObjectKey
 100       (void) tmp->decr_refcount ();
 101     }
 102
 103   return 0;
 104 }
 105
 106 TAO_END_VERSIONED_NAMESPACE_DECL