ACE/apps/JAWS2/JAWS/Cache_Object.h

   1 // -*- C++ -*-
   2
   3
   4 #ifndef JAWS_CACHE_OBJECT_H
   5 #define JAWS_CACHE_OBJECT_H
   6
   7 #include "ace/Thread_Mutex.h"
   8 #include "ace/Synch_Traits.h"
   9 #include "ace/Malloc.h"
  10 #include "ace/RW_Thread_Mutex.h"
  11 #include "ace/Lock_Adapter_T.h"
  12
  13 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  14 class ACE_Allocator;
  15 ACE_END_VERSIONED_NAMESPACE_DECL
  16
  17
  18 // Cache bucket -- use Hash_Bucket to hold cacheable objects.
  19
  20 class JAWS_Cache_Object
  21 {
  22 public:
  23   JAWS_Cache_Object (const void *, size_t);
  24   virtual ~JAWS_Cache_Object (void);
  25
  26   void *internal (void) const;
  27   void internal (void *);
  28
  29   const void *data (void) const;
  30   size_t size (void) const;
  31   unsigned int count (void) const;
  32
  33   int acquire (void);
  34   int release (void);
  35
  36   time_t last_access (void) const;
  37   time_t first_access (void) const;
  38
  39   unsigned int priority (void) const;
  40
  41   enum { ACE_CO_REFERENCED, ACE_CO_COUNTED };
  42
  43   void *heap_item (void) const;
  44   void heap_item (void *item);
  45
  46   virtual ACE_Lock & lock (void) = 0;
  47
  48 protected:
  49
  50   virtual unsigned int count_i (void) const = 0;
  51   virtual int acquire_i (void) = 0;
  52   virtual int release_i (void) = 0;
  53   virtual unsigned int priority_i (void) const = 0;
  54
  55 private:
  56
  57   void *internal_;
  58   const void *data_;
  59   size_t size_;
  60
  61   time_t last_access_;
  62   time_t first_access_;
  63   time_t new_last_access_;
  64
  65   void *heap_item_;
  66
  67 };
  68
  69 class JAWS_Referenced_Cache_Object : public JAWS_Cache_Object
  70 {
  71 public:
  72   JAWS_Referenced_Cache_Object (const void *, size_t);
  73   virtual ~JAWS_Referenced_Cache_Object (void);
  74
  75   virtual ACE_Lock & lock (void);
  76
  77 protected:
  78
  79   virtual unsigned int count_i (void) const;
  80   virtual int acquire_i (void);
  81   virtual int release_i (void);
  82   virtual unsigned int priority_i (void) const;
  83
  84 private:
  85
  86   mutable ACE_SYNCH_RW_MUTEX count_;
  87   mutable ACE_Lock_Adapter<ACE_SYNCH_RW_MUTEX> lock_adapter_;
  88
  89 };
  90
  91 class JAWS_Counted_Cache_Object : public JAWS_Cache_Object
  92 {
  93 public:
  94   JAWS_Counted_Cache_Object (const void *, size_t);
  95   virtual ~JAWS_Counted_Cache_Object (void);
  96
  97   virtual ACE_Lock & lock (void);
  98
  99 protected:
 100
 101   virtual unsigned int count_i (void) const;
 102   virtual int acquire_i (void);
 103   virtual int release_i (void);
 104   virtual unsigned int priority_i (void) const;
 105
 106 private:
 107
 108   unsigned int count_;
 109   unsigned int new_count_;
 110   mutable ACE_SYNCH_MUTEX lock_;
 111   mutable ACE_Lock_Adapter<ACE_SYNCH_MUTEX> lock_adapter_;
 112
 113 };
 114
 115 class JAWS_Cache_Object_Factory
 116 {
 117 public:
 118
 119   JAWS_Cache_Object_Factory (ACE_Allocator *alloc = 0);
 120   virtual ~JAWS_Cache_Object_Factory (void);
 121
 122   int open (ACE_Allocator *alloc = 0);
 123
 124   virtual JAWS_Cache_Object * create (const void *, size_t) = 0;
 125   virtual void destroy (JAWS_Cache_Object *) = 0;
 126
 127 protected:
 128
 129   ACE_Allocator *allocator_;
 130
 131 };
 132
 133 class JAWS_Referenced_Cache_Object_Factory : public JAWS_Cache_Object_Factory
 134 {
 135 public:
 136   JAWS_Referenced_Cache_Object_Factory (ACE_Allocator *alloc = 0);
 137   virtual ~JAWS_Referenced_Cache_Object_Factory (void);
 138
 139   virtual JAWS_Cache_Object * create (const void *, size_t);
 140   virtual void destroy (JAWS_Cache_Object *);
 141
 142 };
 143
 144 class JAWS_Counted_Cache_Object_Factory : public JAWS_Cache_Object_Factory
 145 {
 146 public:
 147   JAWS_Counted_Cache_Object_Factory (ACE_Allocator *alloc = 0);
 148   virtual ~JAWS_Counted_Cache_Object_Factory (void);
 149
 150   virtual JAWS_Cache_Object * create (const void *, size_t);
 151   virtual void destroy (JAWS_Cache_Object *);
 152
 153 };
 154
 155 #endif /* JAWS_CACHE_OBJECT_H */