1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
/* -*- c++ -*- */
// Hey Emacs! This is a C++ file!
#ifndef JAWS_CACHE_MANAGER_T_H
#define JAWS_CACHE_MANAGER_T_H
#include "ace/Singleton.h"
#include "JAWS/Cache_Object.h"
template <class KEY, class HASH_FUNC, class EQ_FUNC> class JAWS_Cache_Hash;
template <class KEY, class FACTORY, class HASH_FUNC, class EQ_FUNC>
class JAWS_Cache_Heap;
template <class KEY, class FACTORY, class HASH_FUNC, class EQ_FUNC>
class JAWS_Cache_List;
template <class KEY, class FACTORY, class HASH_FUNC, class EQ_FUNC>
class JAWS_Cache_Manager
{
friend class JAWS_Cache_Hash<KEY, HASH_FUNC, EQ_FUNC>;
friend class JAWS_Cache_Heap<KEY, FACTORY, HASH_FUNC, EQ_FUNC>;
friend class JAWS_Cache_List<KEY, FACTORY, HASH_FUNC, EQ_FUNC>;
public:
typedef ACE_Singleton<FACTORY, ACE_SYNCH_MUTEX> Object_Factory;
typedef JAWS_Cache_Hash<KEY, HASH_FUNC, EQ_FUNC> Cache_Hash;
typedef JAWS_Cache_List<KEY, FACTORY, HASH_FUNC, EQ_FUNC> Cache_Heap;
JAWS_Cache_Manager (ACE_Allocator *alloc = 0,
JAWS_Cache_Object_Factory *cof = 0,
size_t hashsize = 8192, // number of hash buckets
size_t maxsize = 65535, // max number of in memory
// objects
size_t maxobjsize = 256, // max cached object size in kB
size_t minobjsize = 0, // min cached object size in kB
size_t highwater = 100, // max size of cache in MB
size_t lowwater = 50, // min size of cache when
// expiring after highwater
// has been reached
int timetolive = -1, // amt of time the lowest
// priority item is allowed to
// remain in the cache
int counted = 0 // flag for whether to use
// counts
);
int open (ACE_Allocator *alloc = 0,
JAWS_Cache_Object_Factory *cof = 0,
size_t hashsize = 1024, // number of hash buckets
size_t maxsize = 4096, // max number of in memory
// objects
size_t maxobjsize = 5120, // max cached object size in kB
size_t minobjsize = 0, // min cached object size in kB
size_t highwater = 50, // max size of cache in MB
size_t lowwater = 30, // min size of cache when
// expiring after highwater
// has been reached
int timetolive = -1, // amount of time the lowest
// priority item is allowed to
// remain in the cache
int counted = 0 // flag for whether to use
// counts
);
~JAWS_Cache_Manager ();
int close ();
// Search Methods
int GET (const KEY &key, JAWS_Cache_Object *&cobj);
// Retrieve the object associated with key from cache. Return 0 on
// success, -1 on failure.
int PUT (const KEY &key, const void *data, size_t size,
JAWS_Cache_Object *&obj);
// Inserts or replaces object associated with key into cache.
// Return 0 on success, -1 on failure.
int MAKE (const void *data, size_t size, JAWS_Cache_Object *&cobj);
// Create a cached object, increment reference count.
int TAKE (JAWS_Cache_Object *const &cobj);
// Increment reference count.
int DROP (JAWS_Cache_Object *&cobj);
// Decrement reference count on cached object, perhaps delete.
// Returns 0 if only decremented, 1 if deleted, -1 if error.
int FLUSH ();
// Removes lowest priority object from cache.
protected:
int GET_i (const KEY &key, JAWS_Cache_Object *&object);
// Retrieve the object associated with key from cache. Return 0 on
// success, -1 on failure.
int PUT_i (const KEY &key, const void *data, size_t size,
JAWS_Cache_Object *&object);
// Inserts or replaces object associated with key into cache.
// Return 0 on success, -1 on failure.
int FLUSH_i ();
// Removes lowest priority object from cache.
int FLUSH_i (const KEY &key);
// Removes object associated with key from cache.
int DROP_i (JAWS_Cache_Object *&cobj);
// Decrement reference count on cached object, perhaps delete.
private:
ACE_Allocator *allocator_;
JAWS_Cache_Object_Factory *factory_;
size_t hashsize_;
size_t maxsize_;
size_t maxobjsize_;
size_t minobjsize_;
size_t highwater_;
size_t lowwater_;
size_t waterlevel_;
int timetolive_;
int counted_;
Cache_Hash *hash_;
Cache_Heap *heap_;
ACE_SYNCH_RW_MUTEX lock_;
};
template <class KEY, class DATA, class CACHE_MANAGER>
class JAWS_Cache_Proxy
{
public:
typedef CACHE_MANAGER Cache_Manager;
typedef ACE_Singleton<Cache_Manager, ACE_SYNCH_MUTEX>
Cache_Manager_Singleton;
JAWS_Cache_Proxy (const KEY &, Cache_Manager * = 0);
// Corresponds to a GET
JAWS_Cache_Proxy (const KEY &, DATA *, size_t, Cache_Manager * = 0);
// Corresponds to a U/PUT
virtual ~JAWS_Cache_Proxy ();
DATA *data () const;
operator DATA * () const;
virtual int close (DATA *);
private:
JAWS_Cache_Object *object_;
Cache_Manager *manager_;
};
#include "JAWS/Cache_Manager_T.cpp"
#endif /* JAWS_CACHE_MANAGER_T_H */
|
