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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2008-2011 WiredTiger, Inc.
* All rights reserved.
*/
#include "wt_internal.h"
static int __wt_btree_config(BTREE *);
/*
* __wt_connection_btree --
* BTREE constructor.
*/
int
__wt_connection_btree(CONNECTION *conn, BTREE **btreep)
{
BTREE *btree;
int ret;
btree = NULL;
/* Create the BTREE structure. */
WT_ERR(__wt_calloc(&conn->default_session, 1, sizeof(BTREE), &btree));
/* Connect everything together. */
btree->conn = conn;
/* Configure the BTREE and the BTREE. */
WT_ERR(__wt_btree_config(btree));
*btreep = btree;
return (0);
err: (void)__wt_btree_destroy(btree);
return (ret);
}
/*
* __wt_btree_config --
* Set configuration for a just-created BTREE handle.
*/
static int
__wt_btree_config(BTREE *btree)
{
CONNECTION *conn;
SESSION *session;
conn = btree->conn;
session = &conn->default_session;
btree->root_page.addr = btree->free_addr = WT_ADDR_INVALID;
TAILQ_INIT(&btree->freeqa); /* Free queues */
TAILQ_INIT(&btree->freeqs);
/* Add to the connection's list. */
__wt_lock(session, conn->mtx);
TAILQ_INSERT_TAIL(&conn->dbqh, btree, q);
++conn->dbqcnt;
__wt_unlock(session, conn->mtx);
WT_RET(__wt_stat_alloc_btree_stats(session, &btree->stats));
WT_RET(__wt_stat_alloc_btree_file_stats(session, &btree->fstats));
__wt_methods_btree_config_default(btree);
__wt_methods_btree_lockout(btree);
__wt_methods_btree_init_transition(btree);
return (0);
}
/*
* __wt_btree_destroy --
* BTREE handle destructor.
*/
int
__wt_btree_destroy(BTREE *btree)
{
CONNECTION *conn;
SESSION *session;
int ret;
conn = btree->conn;
session = &conn->default_session;
ret = 0;
/* Check that there's something to close. */
if (btree == NULL)
return (0);
/* Diagnostic check: check flags against approved list. */
WT_CONN_FCHK_RET(conn, "Db.close", btree->flags, WT_APIMASK_BTREE, ret);
__wt_free(session, btree->name);
if (btree->huffman_key != NULL) {
/* Key and data may use the same table, only close it once. */
if (btree->huffman_value == btree->huffman_key)
btree->huffman_value = NULL;
__wt_huffman_close(session, btree->huffman_key);
btree->huffman_key = NULL;
}
if (btree->huffman_value != NULL) {
__wt_huffman_close(session, btree->huffman_value);
btree->huffman_value = NULL;
}
__wt_walk_end(session, &btree->evict_walk);
__wt_free(session, btree->stats);
__wt_free(session, btree->fstats);
/* Remove from the connection's list. */
__wt_lock(session, conn->mtx);
TAILQ_REMOVE(&conn->dbqh, btree, q);
--conn->dbqcnt;
__wt_unlock(session, conn->mtx);
/* Discard the BTREE object. */
__wt_free(session, btree);
return (ret);
}
/*
* __wt_btree_lockout_err --
* Report an error for operations on an invalid btree handle.
*/
int
__wt_btree_lockout_err(BTREE *btree)
{
__wt_errx(&btree->conn->default_session,
"This btree handle has failed for some reason, and can no longer "
"be used; the only method permitted on it is Db.close which "
"discards the handle permanently");
return (WT_ERROR);
}
/*
* __wt_btree_lockout_open --
* Report an error for operations on a not-yet-open btree handle.
*/
int
__wt_btree_lockout_open(BTREE *btree)
{
__wt_errx(&btree->conn->default_session,
"This method may not be called until after the Btree.open method "
"has been called");
return (WT_ERROR);
}
|
