ACE/ace/Based_Pointer_Repository.cpp

   1 #include "ace/Map_Manager.h"
   2 #include "ace/Based_Pointer_Repository.h"
   3 #include "ace/Guard_T.h"
   4 #include "ace/Null_Mutex.h"
   5 #include "ace/Synch_Traits.h"
   6 #include "ace/RW_Thread_Mutex.h"
   7
   8 #if defined (ACE_HAS_ALLOC_HOOKS)
   9 # include "ace/Malloc_Base.h"
  10 #endif /* ACE_HAS_ALLOC_HOOKS */
  11
  12 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  13
  14 /**
  15  * @class ACE_Based_Pointer_Repository_Rep
  16  *
  17  * @brief Implementation for the ACE_Based_Pointer_Repository.
  18  *
  19  * Every memory pool in ACE binds it's mapping base address and
  20  * the mapped size to this repository every time it maps/remaps a
  21  * new chunk of memory successfully.
  22  */
  23 class ACE_Based_Pointer_Repository_Rep
  24 {
  25 public:
  26   // Useful typedefs.
  27   typedef ACE_Map_Manager <void *, size_t, ACE_Null_Mutex> MAP_MANAGER;
  28   typedef ACE_Map_Iterator <void *, size_t, ACE_Null_Mutex> MAP_ITERATOR;
  29   typedef ACE_Map_Entry <void *, size_t> MAP_ENTRY;
  30
  31   /// Keeps track of the mapping between addresses and their associated
  32   /// values.
  33   MAP_MANAGER addr_map_;
  34
  35   /// Synchronize concurrent access to the map.
  36   ACE_SYNCH_MUTEX lock_;
  37
  38   ACE_ALLOC_HOOK_DECLARE;
  39 };
  40
  41 ACE_ALLOC_HOOK_DEFINE(ACE_Based_Pointer_Repository_Rep);
  42
  43 ACE_Based_Pointer_Repository::ACE_Based_Pointer_Repository (void)
  44 {
  45   ACE_TRACE ("ACE_Based_Pointer_Repository::ACE_Based_Pointer_Repository");
  46   ACE_NEW (this->rep_,
  47            ACE_Based_Pointer_Repository_Rep);
  48 }
  49
  50 ACE_Based_Pointer_Repository::~ACE_Based_Pointer_Repository (void)
  51 {
  52   ACE_TRACE ("ACE_Based_Pointer_Repository::~ACE_Based_Pointer_Repository");
  53   delete this->rep_;
  54 }
  55
  56 // Search for appropriate base address in repository
  57
  58 int
  59 ACE_Based_Pointer_Repository::find (void *addr, void *&base_addr)
  60 {
  61   ACE_TRACE ("ACE_Based_Pointer_Repository::find");
  62   ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, mon, this->rep_->lock_, -1);
  63   ACE_Based_Pointer_Repository_Rep::MAP_ENTRY *ce = 0;
  64
  65   for (ACE_Based_Pointer_Repository_Rep::MAP_ITERATOR iter (this->rep_->addr_map_);
  66        iter.next (ce) != 0;
  67        iter.advance ())
  68     // Check to see if <addr> is within any of the regions.
  69     if (addr >= ce->ext_id_
  70         && addr < ((char *)ce->ext_id_ + ce->int_id_))
  71       {
  72         // Assign the base address.
  73         base_addr = ce->ext_id_;
  74         return 1;
  75       }
  76
  77   // Assume base address 0 (e.g., if new'ed).
  78   base_addr = 0;
  79   return 0;
  80 }
  81
  82 // Bind a new entry to the repository or update the size of an
  83 // existing entry.
  84
  85 int
  86 ACE_Based_Pointer_Repository::bind (void *addr, size_t size)
  87 {
  88   ACE_TRACE ("ACE_Based_Pointer_Repository::bind");
  89   ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, mon, this->rep_->lock_, -1);
  90
  91   return this->rep_->addr_map_.rebind (addr, size);
  92 }
  93
  94 // Unbind a base from the repository.
  95
  96 int
  97 ACE_Based_Pointer_Repository::unbind (void *addr)
  98 {
  99   ACE_TRACE ("ACE_Based_Pointer_Repository::unbind");
 100   ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, mon, this->rep_->lock_, -1);
 101   ACE_Based_Pointer_Repository_Rep::MAP_ENTRY *ce = 0;
 102
 103   // Search for service handlers that requested notification.
 104
 105   for (ACE_Based_Pointer_Repository_Rep::MAP_ITERATOR iter (this->rep_->addr_map_);
 106        iter.next (ce) != 0;
 107        iter.advance ())
 108     {
 109       // Check to see if <addr> is within any of the regions and if
 110       // so, unbind the key from the map.
 111       if (addr >= ce->ext_id_
 112           && addr < ((char *)ce->ext_id_ + ce->int_id_))
 113         // Unbind base address.
 114         return this->rep_->addr_map_.unbind (ce->ext_id_);
 115     }
 116
 117   return 0;
 118 }
 119
 120 ACE_SINGLETON_TEMPLATE_INSTANTIATE(ACE_Singleton, ACE_Based_Pointer_Repository, ACE_SYNCH_RW_MUTEX);
 121
 122
 123 ACE_END_VERSIONED_NAMESPACE_DECL