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
153
154
155
156
157
158
159
160
161
|
/*-
* Copyright (c) 2014-2019 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
/*
* __wt_schema_backup_check --
* Check if a backup cursor is open and give an error if the schema operation will conflict.
* This is called after the schema operations have taken the schema lock so no hot backup cursor
* can be created until this is done.
*/
int
__wt_schema_backup_check(WT_SESSION_IMPL *session, const char *name)
{
WT_CONNECTION_IMPL *conn;
WT_DECL_RET;
int i;
char **backup_list;
conn = S2C(session);
if (!conn->hot_backup)
return (0);
__wt_readlock(session, &conn->hot_backup_lock);
/*
* There is a window at the end of a backup where the list has been cleared from the connection
* but the flag is still set. It is safe to drop at that point.
*/
if (!conn->hot_backup || (backup_list = conn->hot_backup_list) == NULL) {
__wt_readunlock(session, &conn->hot_backup_lock);
return (0);
}
for (i = 0; backup_list[i] != NULL; ++i) {
if (strcmp(backup_list[i], name) == 0) {
ret = __wt_set_return(session, EBUSY);
break;
}
}
__wt_readunlock(session, &conn->hot_backup_lock);
return (ret);
}
/*
* __wt_schema_get_source --
* Find a matching data source or report an error.
*/
WT_DATA_SOURCE *
__wt_schema_get_source(WT_SESSION_IMPL *session, const char *name)
{
WT_NAMED_DATA_SOURCE *ndsrc;
TAILQ_FOREACH (ndsrc, &S2C(session)->dsrcqh, q)
if (WT_PREFIX_MATCH(name, ndsrc->prefix))
return (ndsrc->dsrc);
return (NULL);
}
/*
* __wt_schema_internal_session --
* Create and return an internal schema session if necessary.
*/
int
__wt_schema_internal_session(WT_SESSION_IMPL *session, WT_SESSION_IMPL **int_sessionp)
{
/*
* Open an internal session if a transaction is running so that the schema operations are not
* logged and buffered with any log records in the transaction. The new session inherits its
* flags from the original.
*/
*int_sessionp = session;
if (F_ISSET(&session->txn, WT_TXN_RUNNING)) {
/* We should not have a schema txn running now. */
WT_ASSERT(session, !F_ISSET(session, WT_SESSION_SCHEMA_TXN));
WT_RET(
__wt_open_internal_session(S2C(session), "schema", true, session->flags, int_sessionp));
}
return (0);
}
/*
* __wt_schema_session_release --
* Release an internal schema session if needed.
*/
int
__wt_schema_session_release(WT_SESSION_IMPL *session, WT_SESSION_IMPL *int_session)
{
WT_SESSION *wt_session;
if (session != int_session) {
wt_session = &int_session->iface;
WT_RET(wt_session->close(wt_session, NULL));
}
return (0);
}
/*
* __wt_str_name_check --
* Disallow any use of the WiredTiger name space.
*/
int
__wt_str_name_check(WT_SESSION_IMPL *session, const char *str)
{
int skipped;
const char *name, *sep;
/*
* Check if name is somewhere in the WiredTiger name space: it would be
* "bad" if the application truncated the metadata file. Skip any
* leading URI prefix, check and then skip over a table name.
*/
name = str;
for (skipped = 0; skipped < 2; skipped++) {
if ((sep = strchr(name, ':')) == NULL)
break;
name = sep + 1;
if (WT_PREFIX_MATCH(name, "WiredTiger"))
WT_RET_MSG(session, EINVAL,
"%s: the \"WiredTiger\" name space may not be "
"used by applications",
name);
}
/*
* Disallow JSON quoting characters -- the config string parsing code supports quoted strings,
* but there's no good reason to use them in names and we're not going to do the testing.
*/
if (strpbrk(name, "{},:[]\\\"'") != NULL)
WT_RET_MSG(session, EINVAL,
"%s: WiredTiger objects should not include grouping "
"characters in their names",
name);
return (0);
}
/*
* __wt_name_check --
* Disallow any use of the WiredTiger name space.
*/
int
__wt_name_check(WT_SESSION_IMPL *session, const char *str, size_t len)
{
WT_DECL_ITEM(tmp);
WT_DECL_RET;
WT_RET(__wt_scr_alloc(session, len, &tmp));
WT_ERR(__wt_buf_fmt(session, tmp, "%.*s", (int)len, str));
ret = __wt_str_name_check(session, tmp->data);
err:
__wt_scr_free(session, &tmp);
return (ret);
}
|
