forked from memcached/memcached
/
slabs_items.h
92 lines (71 loc) · 3.98 KB
/
slabs_items.h
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
/* -*- Mode: C; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
#if !defined(_slabs_items_h_)
#define _slabs_items_h_
#include "generic.h"
/* forward declare some data types. */
typedef struct _stritem item;
typedef item* item_ptr_t;
#include "memcached.h"
#define ITEM_LINKED 1
#define ITEM_DELETED 2
/* temp */
#define ITEM_SLABBED 4
#define ITEM_VISITED 8 /* cache hit */
#define ITEM_HAS_IP_ADDRESS 0x10
#define ITEM_HAS_TIMESTAMP 0x20
struct _stritem {
#if defined(CAS_SUPPORT)
uint64_t cas_id;
#endif /* #if defined(CAS_SUPPORT) */
struct _stritem *next;
struct _stritem *prev;
struct _stritem *h_next; /* hash chain next */
rel_time_t time; /* least recent access */
rel_time_t exptime; /* expire time */
int nbytes; /* size of data */
unsigned int flags; /* flags field */
unsigned short refcount;
uint8_t it_flags; /* ITEM_* above */
uint8_t slabs_clsid;/* which slab class we're in */
uint8_t nkey; /* key length, w/terminating null and padding */
char end;
/* then key */
/* then data */
};
#define stritem_length ((intptr_t) &(((item*) 0)->end))
#define NULL_ITEM_PTR ((item_ptr_t) NULL)
static inline item* ITEM(item_ptr_t iptr) { return (item*) iptr; }
static inline item_ptr_t ITEM_PTR(item* it) { return (item_ptr_t) it; }
static inline bool ITEM_PTR_IS_NULL(item_ptr_t iptr) { return (iptr != NULL); }
static inline char* ITEM_key(item* it) { return &(it->end); }
static inline uint8_t ITEM_nkey(const item* it) { return it->nkey; }
static inline int ITEM_nbytes(const item* it) { return it->nbytes; }
static inline size_t ITEM_ntotal(const item* it) { return stritem_length + it->nkey + it->nbytes; }
static inline unsigned int ITEM_flags(const item* it) { return it->flags; }
static inline rel_time_t ITEM_time(const item* it) { return it->time; }
static inline rel_time_t ITEM_exptime(const item* it) { return it->exptime; }
static inline unsigned short ITEM_refcount(const item* it) { return it->refcount; }
#if defined(CAS_SUPPORT)
static inline uint64_t ITEM_casid(const item* it) { return it->cas_id; }
#endif /* #if defined(CAS_SUPPORT) */
static inline void ITEM_set_nbytes(item* it, int new_nbytes) { it->nbytes = new_nbytes; }
static inline void ITEM_set_exptime(item* it, rel_time_t t) { it->exptime = t; }
#if defined(CAS_SUPPORT)
static inline void ITEM_set_casid(item* it, uint64_t cas_id) { it->cas_id = cas_id; }
#endif /* #if defined(CAS_SUPPORT) */
static inline item_ptr_t ITEM_PTR_h_next(item_ptr_t iptr) { return ITEM(iptr)->h_next; }
static inline item_ptr_t* ITEM_h_next_p(item* it) { return &it->h_next; }
static inline void ITEM_set_h_next(item* it, item_ptr_t next) { it->h_next = next; }
static inline bool ITEM_is_valid(const item* it) { return !(it->it_flags & ITEM_SLABBED); }
static inline bool ITEM_has_timestamp(const item* it) { return (it->it_flags & ITEM_HAS_TIMESTAMP); }
static inline bool ITEM_has_ip_address(const item* it) { return (it->it_flags & ITEM_HAS_IP_ADDRESS); }
static inline void ITEM_mark_deleted(item* it) { it->it_flags |= ITEM_DELETED; }
static inline void ITEM_unmark_deleted(item* it) { it->it_flags &= ~ITEM_DELETED; }
static inline void ITEM_set_has_timestamp(item* it) { it->it_flags |= ITEM_HAS_TIMESTAMP; }
static inline void ITEM_clear_has_timestamp(item* it) { it->it_flags &= ~(ITEM_HAS_TIMESTAMP); }
static inline void ITEM_set_has_ip_address(item* it) { it->it_flags |= ITEM_HAS_IP_ADDRESS; }
static inline void ITEM_clear_has_ip_address(item* it) { it->it_flags &= ~(ITEM_HAS_IP_ADDRESS); }
extern char* do_item_cachedump(const unsigned int slabs_clsid, const unsigned int limit, unsigned int *bytes);
extern char* do_item_stats(int *bytes);
extern void item_mark_visited(item* it);
#endif /* #if !defined(_slabs_items_h_) */