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
|
#ifndef HICNLIGHT_CONTENT_STORE_H
#define HICNLIGHT_CONTENT_STORE_H
#include <hicn/base/khash.h>
#include <hicn/base/pool.h>
#include <hicn/core/msgbuf.h>
#include <hicn/core/name.h>
#include <hicn/content_store/lru.h>
typedef struct {
msgbuf_t * message;
//ListLruEntry *lruEntry;
bool hasExpiryTimeTicks;
uint64_t expiryTimeTicks; // single value for both ? 0 allowed ?
} content_store_entry_t;
#define content_store_entry_message(entry) ((entry)->message)
#define content_store_entry_has_expiry_time(entry) ((entry)->hasExpiryTimeTicks)
#define content_store_entry_expiry_time(entry) ((entry)->expiryTimeTicks)
typedef enum {
CONTENT_STORE_TYPE_UNDEFINED,
CONTENT_STORE_TYPE_LRU,
CONTENT_STORE_TYPE_N,
} content_store_type_t;
#define CONTENT_STORE_TYPE_VALID(type) \
(type != CONTENT_STORE_TYPE_UNDEFINED) && \
(type != CONTENT_STORE_TYPE_N)
typedef struct {
/* The maximum allowed expiry time (will never be exceeded). */
uint64_t max_expiry_time; // XXX part of lru ?
} content_store_options_t;
typedef union {
content_store_lru_stats_t lru;
} content_store_stats_t;
// XXX TODO
#define name_hash(name) (name_HashCode(name))
#define name_hash_eq(a, b) (name_hash(b) - name_hash(a))
KHASH_INIT(cs_name, const Name *, unsigned, 0, name_hash, name_hash_eq);
typedef struct {
content_store_type_t type;
size_t max_size;
// XXX TODO api to dynamically set max size
content_store_entry_t * entries; // pool
kh_cs_name_t * index_by_name;
void * index_by_expiry_time;
//ListTimeOrdered *indexByExpirationTime;
void * data; // per cs type data
void * options;
content_store_stats_t stats;
} content_store_t;
/**
* @brief Create a new content store (extended parameters)
*
* @param[in] type Content store type
* @param[in] init_size Initially allocated size (hint, 0 = use default value)
* @param[in] max_size Maximum size (0 = unlimited)
*
* @return content_store_t* - The newly created content store
*/
content_store_t * _content_store_create(content_store_type_t type, size_t init_size, size_t max_size);
/**
* @brief Create a new content store
*
* @param[in] type Content store type
*
* @return content_store_t* - The newly created content store
*/
#define content_store_create( TYPE) _content_store_create((TYPE), 0, 0)
void content_store_free(content_store_t * cs);
void content_store_clear(content_store_t * cs);
msgbuf_t * content_store_match(content_store_t * cs, msgbuf_t * msgbuf, uint64_t now);
void content_store_add(content_store_t * cs, msgbuf_t * msgbuf, uint64_t now);
void content_store_remove_entry(content_store_t * cs, content_store_entry_t * entry);
bool content_store_remove(content_store_t * cs, msgbuf_t * msgbuf);
#define content_store_size(content_store) (pool_len(cs->entries))
void content_store_purge_entry(content_store_t * cs, content_store_entry_t * entry);
typedef struct {
const char * name;
void (*initialize)(content_store_t * cs);
void (*finalize)(content_store_t * cs);
/**
* Place a Message representing a ContentObject into the ContentStore. If
* necessary to make room, remove expired content or content that has exceeded
* the Recommended Cache Time.
*
* @param storeImpl - a pointer to this ContentStoreInterface instance.
* @param content - a pointer to a `Message` to place in the store.
* @param currentTimeTicks - the current time, in hicn-light ticks, since the
* UTC epoch.
*/
// XXX Do we always get now before adding ?
bool (*add_entry)(content_store_t * cs, content_store_entry_t * entry);
/**
* The function to call to remove content from the ContentStore.
* It will Release any references that were created when the content was
* placed into the ContentStore.
*
* @param storeImpl - a pointer to this ContentStoreInterface instance.
* @param content - a pointer to a `Message` to remove from the store.
*/
void (*remove_entry)(content_store_t * cs, content_store_entry_t * entry);
} content_store_ops_t;
extern const content_store_ops_t * const content_store_vft[];
#define DECLARE_CONTENT_STORE(NAME) \
const content_store_ops_t content_store_ ## NAME = { \
.name = #NAME, \
.initialize = content_store_ ## NAME ## _initialize, \
.finalize = content_store_ ## NAME ## _finalize, \
.add_entry = content_store_ ## NAME ## _add_entry, \
.remove_entry = content_store_ ## NAME ## _remove_entry, \
}
#endif /* HICNLIGHT_CONTENT_STORE_H */
|
