blob: 31514744701d2363b1f322d09d04871111a9104f (
plain)
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
|
/*-
* Copyright (c) 2008-2012 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
struct __wt_cursor_lsm {
WT_CURSOR iface;
WT_LSM_TREE *lsm_tree;
uint64_t dsk_gen;
int nchunks;
WT_BLOOM **blooms;
WT_CURSOR **cursors;
WT_CURSOR *current; /* The current cursor for iteration */
WT_LSM_CHUNK *primary_chunk; /* The current primary chunk. */
#define WT_CLSM_ITERATE_NEXT 0x01 /* Forward iteration */
#define WT_CLSM_ITERATE_PREV 0x02 /* Backward iteration */
#define WT_CLSM_MERGE 0x04 /* Merge cursor, don't update. */
#define WT_CLSM_MINOR_MERGE 0x08 /* Minor merge, include tombstones. */
#define WT_CLSM_MULTIPLE 0x10 /* Multiple cursors have values for the
current key */
#define WT_CLSM_UPDATED 0x20 /* Cursor has done updates */
uint32_t flags;
};
struct __wt_lsm_chunk {
const char *uri; /* Data source for this chunk. */
const char *bloom_uri; /* URI of Bloom filter, if any. */
uint64_t count; /* Approximate count of records. */
uint32_t ncursor; /* Cursors with the chunk as primary. */
#define WT_LSM_CHUNK_ONDISK 0x01
uint32_t flags;
};
struct __wt_lsm_tree {
const char *name, *config, *filename;
const char *key_format, *value_format, *file_config;
WT_COLLATOR *collator;
WT_RWLOCK *rwlock;
TAILQ_ENTRY(__wt_lsm_tree) q;
WT_SPINLOCK lock;
uint64_t dsk_gen;
uint32_t *memsizep;
/* Configuration parameters */
uint32_t bloom_bit_count;
uint32_t bloom_hash_count;
uint32_t chunk_size;
uint32_t merge_max;
uint32_t bloom; /* Is bloom enabled. */
WT_SESSION_IMPL *worker_session;/* Passed to thread_create */
pthread_t worker_tid; /* LSM worker thread */
WT_SESSION_IMPL *ckpt_session; /* For checkpoint worker */
pthread_t ckpt_tid; /* LSM checkpoint worker thread */
int nchunks; /* Number of active chunks */
int last; /* Last allocated ID. */
WT_LSM_CHUNK **chunk; /* Array of active LSM chunks */
size_t chunk_alloc; /* Space allocated for chunks */
WT_LSM_CHUNK **old_chunks; /* Array of old LSM chunks */
size_t old_alloc; /* Space allocated for old chunks */
int nold_chunks; /* Number of old chunks */
int old_avail; /* Available old chunk slots */
#define WT_LSM_TREE_WORKING 0x01
#define WT_LSM_TREE_OPEN 0x02
uint32_t flags;
};
struct __wt_lsm_data_source {
WT_DATA_SOURCE iface;
WT_RWLOCK *rwlock;
};
struct __wt_lsm_worker_cookie {
WT_LSM_CHUNK **chunk_array;
size_t chunk_alloc;
int nchunks;
#define WT_LSM_WORKER_MERGE 0x01
#define WT_LSM_WORKER_CHECKPOINT 0x02
uint32_t flags;
};
|
