2
Unix SMB/CIFS mplementation.
4
The module that handles the Schema FSMO Role Owner
5
checkings, it also loads the dsdb_schema.
7
Copyright (C) Stefan Metzmacher <metze@samba.org> 2007
8
Copyright (C) Andrew Bartlett <abartlet@samba.org> 2009-2010
10
This program is free software; you can redistribute it and/or modify
11
it under the terms of the GNU General Public License as published by
12
the Free Software Foundation; either version 3 of the License, or
13
(at your option) any later version.
15
This program is distributed in the hope that it will be useful,
16
but WITHOUT ANY WARRANTY; without even the implied warranty of
17
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18
GNU General Public License for more details.
20
You should have received a copy of the GNU General Public License
21
along with this program. If not, see <http://www.gnu.org/licenses/>.
26
#include "ldb_module.h"
27
#include "dsdb/samdb/samdb.h"
28
#include "librpc/gen_ndr/ndr_misc.h"
29
#include "librpc/gen_ndr/ndr_drsuapi.h"
30
#include "librpc/gen_ndr/ndr_drsblobs.h"
31
#include "param/param.h"
32
#include "dsdb/samdb/ldb_modules/util.h"
34
struct schema_load_private_data {
38
static int dsdb_schema_from_db(struct ldb_module *module, struct ldb_dn *schema_dn, uint64_t current_usn,
39
struct dsdb_schema **schema);
41
struct dsdb_schema *dsdb_schema_refresh(struct ldb_module *module, struct dsdb_schema *schema, bool is_global_schema)
45
struct ldb_result *res;
46
struct ldb_request *treq;
47
struct ldb_seqnum_request *tseq;
48
struct ldb_seqnum_result *tseqr;
49
struct dsdb_control_current_partition *ctrl;
50
struct ldb_context *ldb = ldb_module_get_ctx(module);
51
struct dsdb_schema *new_schema;
53
struct schema_load_private_data *private_data = talloc_get_type(ldb_module_get_private(module), struct schema_load_private_data);
55
/* We can't refresh until the init function has run */
59
/* We don't allow a schema reload during a transaction - nobody else can modify our schema behind our backs */
60
if (private_data->in_transaction) {
64
res = talloc_zero(schema, struct ldb_result);
68
tseq = talloc_zero(res, struct ldb_seqnum_request);
73
tseq->type = LDB_SEQ_HIGHEST_SEQ;
75
ret = ldb_build_extended_req(&treq, ldb_module_get_ctx(module), res,
76
LDB_EXTENDED_SEQUENCE_NUMBER,
80
ldb_extended_default_callback,
82
LDB_REQ_SET_LOCATION(treq);
83
if (ret != LDB_SUCCESS) {
88
ctrl = talloc(treq, struct dsdb_control_current_partition);
93
ctrl->version = DSDB_CONTROL_CURRENT_PARTITION_VERSION;
94
ctrl->dn = schema->base_dn;
96
ret = ldb_request_add_control(treq,
97
DSDB_CONTROL_CURRENT_PARTITION_OID,
99
if (ret != LDB_SUCCESS) {
104
ret = ldb_next_request(module, treq);
105
if (ret != LDB_SUCCESS) {
109
ret = ldb_wait(treq->handle, LDB_WAIT_ALL);
110
if (ret != LDB_SUCCESS) {
114
tseqr = talloc_get_type(res->extended->data,
115
struct ldb_seqnum_result);
116
if (tseqr->seq_num == schema->reload_seq_number) {
121
schema->reload_seq_number = tseqr->seq_num;
124
ret = dsdb_module_load_partition_usn(module, schema->base_dn, ¤t_usn, NULL, NULL);
125
if (ret != LDB_SUCCESS || current_usn == schema->loaded_usn) {
129
ret = dsdb_schema_from_db(module, schema->base_dn, current_usn, &new_schema);
130
if (ret != LDB_SUCCESS) {
134
if (is_global_schema) {
135
dsdb_make_schema_global(ldb, new_schema);
142
Given an LDB module (pointing at the schema DB), and the DN, set the populated schema
145
static int dsdb_schema_from_db(struct ldb_module *module, struct ldb_dn *schema_dn, uint64_t current_usn,
146
struct dsdb_schema **schema)
148
struct ldb_context *ldb = ldb_module_get_ctx(module);
152
struct ldb_result *schema_res;
153
struct ldb_result *a_res;
154
struct ldb_result *c_res;
155
static const char *schema_attrs[] = {
163
tmp_ctx = talloc_new(module);
168
/* we don't want to trace the schema load */
169
flags = ldb_get_flags(ldb);
170
ldb_set_flags(ldb, flags & ~LDB_FLG_ENABLE_TRACING);
173
* setup the prefix mappings and schema info
175
ret = dsdb_module_search_dn(module, tmp_ctx, &schema_res,
176
schema_dn, schema_attrs,
177
DSDB_FLAG_NEXT_MODULE, NULL);
178
if (ret == LDB_ERR_NO_SUCH_OBJECT) {
179
ldb_reset_err_string(ldb);
180
ldb_debug(ldb, LDB_DEBUG_WARNING,
181
"schema_load_init: no schema head present: (skip schema loading)\n");
183
} else if (ret != LDB_SUCCESS) {
184
ldb_asprintf_errstring(ldb,
185
"dsdb_schema: failed to search the schema head: %s",
191
* load the attribute definitions
193
ret = dsdb_module_search(module, tmp_ctx, &a_res,
194
schema_dn, LDB_SCOPE_ONELEVEL, NULL,
195
DSDB_FLAG_NEXT_MODULE,
197
"(objectClass=attributeSchema)");
198
if (ret != LDB_SUCCESS) {
199
ldb_asprintf_errstring(ldb,
200
"dsdb_schema: failed to search attributeSchema objects: %s",
206
* load the objectClass definitions
208
ret = dsdb_module_search(module, tmp_ctx, &c_res,
209
schema_dn, LDB_SCOPE_ONELEVEL, NULL,
210
DSDB_FLAG_NEXT_MODULE |
211
DSDB_SEARCH_SHOW_DN_IN_STORAGE_FORMAT,
213
"(objectClass=classSchema)");
214
if (ret != LDB_SUCCESS) {
215
ldb_asprintf_errstring(ldb,
216
"dsdb_schema: failed to search classSchema objects: %s",
221
ret = dsdb_schema_from_ldb_results(tmp_ctx, ldb,
222
schema_res, a_res, c_res, schema, &error_string);
223
if (ret != LDB_SUCCESS) {
224
ldb_asprintf_errstring(ldb,
225
"dsdb_schema load failed: %s",
230
(*schema)->refresh_in_progress = true;
232
/* If we have the readOnlySchema opaque, then don't check for
233
* runtime schema updates, as they are not permitted (we would
234
* have to update the backend server schema too */
235
if (!ldb_get_opaque(ldb, "readOnlySchema")) {
236
(*schema)->refresh_fn = dsdb_schema_refresh;
237
(*schema)->loaded_from_module = module;
238
(*schema)->loaded_usn = current_usn;
241
/* "dsdb_set_schema()" steals schema into the ldb_context */
242
ret = dsdb_set_schema(ldb, (*schema));
244
(*schema)->refresh_in_progress = false;
246
if (ret != LDB_SUCCESS) {
247
ldb_debug_set(ldb, LDB_DEBUG_FATAL,
248
"schema_load_init: dsdb_set_schema() failed: %d:%s: %s",
249
ret, ldb_strerror(ret), ldb_errstring(ldb));
253
/* Ensure this module won't go away before the callback */
254
if (talloc_reference(*schema, ldb) == NULL) {
256
ret = LDB_ERR_OPERATIONS_ERROR;
260
if (flags & LDB_FLG_ENABLE_TRACING) {
261
flags = ldb_get_flags(ldb);
262
ldb_set_flags(ldb, flags | LDB_FLG_ENABLE_TRACING);
264
talloc_free(tmp_ctx);
269
static int schema_load_init(struct ldb_module *module)
271
struct schema_load_private_data *private_data;
272
struct dsdb_schema *schema;
273
struct ldb_context *ldb = ldb_module_get_ctx(module);
275
uint64_t current_usn;
276
struct ldb_dn *schema_dn;
278
private_data = talloc_zero(module, struct schema_load_private_data);
279
if (private_data == NULL) {
283
ldb_module_set_private(module, private_data);
285
ret = ldb_next_init(module);
286
if (ret != LDB_SUCCESS) {
290
if (dsdb_get_schema(ldb, NULL)) {
294
schema_dn = ldb_get_schema_basedn(ldb);
296
ldb_reset_err_string(ldb);
297
ldb_debug(ldb, LDB_DEBUG_WARNING,
298
"schema_load_init: no schema dn present: (skip schema loading)\n");
302
ret = dsdb_module_load_partition_usn(module, schema_dn, ¤t_usn, NULL, NULL);
303
if (ret != LDB_SUCCESS) {
304
/* Ignore the error and just reload the DB more often */
308
return dsdb_schema_from_db(module, schema_dn, current_usn, &schema);
311
static int schema_load_start_transaction(struct ldb_module *module)
313
struct schema_load_private_data *private_data =
314
talloc_get_type(ldb_module_get_private(module), struct schema_load_private_data);
316
private_data->in_transaction = true;
318
return ldb_next_start_trans(module);
321
static int schema_load_end_transaction(struct ldb_module *module)
323
struct schema_load_private_data *private_data =
324
talloc_get_type(ldb_module_get_private(module), struct schema_load_private_data);
326
private_data->in_transaction = false;
328
return ldb_next_end_trans(module);
331
static int schema_load_del_transaction(struct ldb_module *module)
333
struct schema_load_private_data *private_data =
334
talloc_get_type(ldb_module_get_private(module), struct schema_load_private_data);
336
private_data->in_transaction = false;
338
return ldb_next_del_trans(module);
341
static int schema_load_extended(struct ldb_module *module, struct ldb_request *req)
343
struct ldb_context *ldb;
345
ldb = ldb_module_get_ctx(module);
347
if (strcmp(req->op.extended.oid, DSDB_EXTENDED_SCHEMA_UPDATE_NOW_OID) != 0) {
348
return ldb_next_request(module, req);
351
/* This is a no-op. We reload as soon as we can */
352
return ldb_module_done(req, NULL, NULL, LDB_SUCCESS);
356
static const struct ldb_module_ops ldb_schema_load_module_ops = {
357
.name = "schema_load",
358
.init_context = schema_load_init,
359
.extended = schema_load_extended,
360
.start_transaction = schema_load_start_transaction,
361
.end_transaction = schema_load_end_transaction,
362
.del_transaction = schema_load_del_transaction,
365
int ldb_schema_load_module_init(const char *version)
367
LDB_MODULE_CHECK_VERSION(version);
368
return ldb_register_module(&ldb_schema_load_module_ops);