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
|
/**
* @file /magma/core/indexes/indexes.h
*
* @brief Function declarations and types for the generic index interface.
*/
#ifndef MAGMA_CORE_INDEXES_H
#define MAGMA_CORE_INDEXES_H
/**
* Index types and options.
*/
typedef enum {
M_INX_TREE = 1, //!< M_INX_BTREE
M_INX_HASHED = 2, //!< M_INX_HASHED
M_INX_LINKED = 4, //!< M_INX_LINKED
//M_INX_ALLOW_DUPE = 8, //!< M_INX_ALLOW_DUPE
M_INX_LOCK_MANUAL = 16, //!< M_INX_LOCK_MANUAL
} MAGMA_INDEX;
/**
* The different types of indexes.
*/
#define MAGMA_INDEX_TYPE (M_INX_TREE | M_INX_LINKED | M_INX_HASHED)
/**
* The different index options.
*/
#define MAGMA_INDEX_OPTION (M_INX_INDEX_LOCK)
typedef struct __attribute__ ((packed)) {
// Data and record count
void *index, *last;
pthread_rwlock_t lock;
uint64_t count, serial, automatic, options, references;
// Index function pointers.
void (*data_free)(void *data);
void (*index_free)(void *index);
void (*index_truncate)(void *index);
bool_t (*delete)(void *index, multi_t envelope);
bool_t (*insert)(void *index, multi_t envelope, void *data);
bool_t (*append)(void *index, multi_t envelope, void *data);
void * (*find)(void *index, multi_t envelope);
void (*cursor_free)(void *cursor);
void (*cursor_reset)(void *cursor);
void * (*cursor_alloc)(void *index);
void * (*cursor_value_next)(void *cursor);
void * (*cursor_value_active)(void *cursor);
multi_t (*cursor_key_next)(void *cursor);
multi_t (*cursor_key_active)(void *cursor);
} inx_t;
typedef struct __attribute__ ((packed)) {
inx_t *inx;
} inx_cursor_t;
/// cursors.c
inx_cursor_t * inx_cursor_alloc(inx_t *index);
void inx_cursor_free(inx_cursor_t *cursor);
multi_t inx_cursor_key_active(inx_cursor_t *cursor);
multi_t inx_cursor_key_next(inx_cursor_t *cursor);
void inx_cursor_reset(inx_cursor_t *cursor);
void * inx_cursor_value_active(inx_cursor_t *cursor);
void * inx_cursor_value_next(inx_cursor_t *cursor);
/// inx.c
inx_t * inx_alloc(uint64_t options, void *data_free);
bool_t inx_append(inx_t *inx, multi_t key, void *data);
void inx_auto_read(inx_t *inx);
void inx_auto_unlock(inx_t *inx);
void inx_auto_write(inx_t *inx);
void inx_cleanup(inx_t *inx);
uint64_t inx_count(inx_t *inx);
bool_t inx_delete(inx_t *inx, multi_t key);
void * inx_find(inx_t *inx, multi_t key);
void inx_free(inx_t *inx);
bool_t inx_insert(inx_t *inx, multi_t key, void *data);
void inx_lock_read(inx_t *inx);
void inx_lock_write(inx_t *inx);
uint64_t inx_options(inx_t *inx);
bool_t inx_replace(inx_t *inx, multi_t key, void *data);
uint64_t inx_serial(inx_t *inx);
void inx_truncate(inx_t *inx);
void inx_unlock(inx_t *inx);
/// linked.c
inx_t * linked_alloc(uint64_t options, void *data_free);
/// hashed.c
inx_t * hashed_alloc(uint64_t options, void *data_free);
#endif
|
