?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
smbd: Simplify an if-condition
[Samba.git] / source3 / smbd / smbXsrv_open.c
blobed2cf6f8a9f53abcc2b5769e797f2344daa9bf55
1 /*
2 Unix SMB/CIFS implementation.
3
4 Copyright (C) Stefan Metzmacher 2012
5 Copyright (C) Michael Adam 2012
6
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
11
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
16
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
19 */
20
21 #include "smbXsrv_open.h"
22 #include "includes.h"
23 #include "system/filesys.h"
24 #include "lib/util/server_id.h"
25 #include "smbd/smbd.h"
26 #include "smbd/globals.h"
27 #include "dbwrap/dbwrap.h"
28 #include "dbwrap/dbwrap_rbt.h"
29 #include "dbwrap/dbwrap_open.h"
30 #include "../libcli/security/security.h"
31 #include "messages.h"
32 #include "lib/util/util_tdb.h"
33 #include "librpc/gen_ndr/ndr_smbXsrv.h"
34 #include "serverid.h"
35 #include "source3/include/util_tdb.h"
36 #include "lib/util/idtree_random.h"
37 #include "lib/util/time_basic.h"
38
39 struct smbXsrv_open_table {
40 struct {
41 struct idr_context *idr;
42 struct db_context *replay_cache_db_ctx;
43 uint32_t lowest_id;
44 uint32_t highest_id;
45 uint32_t max_opens;
46 uint32_t num_opens;
47 } local;
48 struct {
49 struct db_context *db_ctx;
50 } global;
51 };
52
53 static struct db_context *smbXsrv_open_global_db_ctx = NULL;
54
55 NTSTATUS smbXsrv_open_global_init(void)
56 {
57 char *global_path = NULL;
58 struct db_context *db_ctx = NULL;
59
60 if (smbXsrv_open_global_db_ctx != NULL) {
61 return NT_STATUS_OK;
62 }
63
64 global_path = lock_path(talloc_tos(), "smbXsrv_open_global.tdb");
65 if (global_path == NULL) {
66 return NT_STATUS_NO_MEMORY;
67 }
68
69 db_ctx = db_open(NULL, global_path,
70 SMBD_VOLATILE_TDB_HASH_SIZE,
71 SMBD_VOLATILE_TDB_FLAGS,
72 O_RDWR | O_CREAT, 0600,
73 DBWRAP_LOCK_ORDER_1,
74 DBWRAP_FLAG_NONE);
75 TALLOC_FREE(global_path);
76 if (db_ctx == NULL) {
77 NTSTATUS status = map_nt_error_from_unix_common(errno);
78 return status;
79 }
80
81 smbXsrv_open_global_db_ctx = db_ctx;
82
83 return NT_STATUS_OK;
84 }
85
86 /*
87 * NOTE:
88 * We need to store the keys in big endian so that dbwrap_rbt's memcmp
89 * has the same result as integer comparison between the uint32_t
90 * values.
91 *
92 * TODO: implement string based key
93 */
94
95 struct smbXsrv_open_global_key_buf { uint8_t buf[sizeof(uint32_t)]; };
96
97 static TDB_DATA smbXsrv_open_global_id_to_key(
98 uint32_t id, struct smbXsrv_open_global_key_buf *key_buf)
99 {
100 RSIVAL(key_buf->buf, 0, id);
101
102 return (TDB_DATA) {
103 .dptr = key_buf->buf,
104 .dsize = sizeof(key_buf->buf),
105 };
106 }
107
108 static NTSTATUS smbXsrv_open_table_init(struct smbXsrv_connection *conn,
109 uint32_t lowest_id,
110 uint32_t highest_id,
111 uint32_t max_opens)
112 {
113 struct smbXsrv_client *client = conn->client;
114 struct smbXsrv_open_table *table;
115 NTSTATUS status;
116 uint64_t max_range;
117
118 if (lowest_id > highest_id) {
119 return NT_STATUS_INTERNAL_ERROR;
120 }
121
122 max_range = highest_id;
123 max_range -= lowest_id;
124 max_range += 1;
125
126 if (max_opens > max_range) {
127 return NT_STATUS_INTERNAL_ERROR;
128 }
129
130 table = talloc_zero(client, struct smbXsrv_open_table);
131 if (table == NULL) {
132 return NT_STATUS_NO_MEMORY;
133 }
134
135 table->local.idr = idr_init(table);
136 if (table->local.idr == NULL) {
137 TALLOC_FREE(table);
138 return NT_STATUS_NO_MEMORY;
139 }
140 table->local.replay_cache_db_ctx = db_open_rbt(table);
141 if (table->local.replay_cache_db_ctx == NULL) {
142 TALLOC_FREE(table);
143 return NT_STATUS_NO_MEMORY;
144 }
145 table->local.lowest_id = lowest_id;
146 table->local.highest_id = highest_id;
147 table->local.max_opens = max_opens;
148
149 status = smbXsrv_open_global_init();
150 if (!NT_STATUS_IS_OK(status)) {
151 TALLOC_FREE(table);
152 return status;
153 }
154
155 table->global.db_ctx = smbXsrv_open_global_db_ctx;
156
157 client->open_table = table;
158 return NT_STATUS_OK;
159 }
160
161 static NTSTATUS smbXsrv_open_local_lookup(struct smbXsrv_open_table *table,
162 uint32_t open_local_id,
163 uint32_t open_global_id,
164 NTTIME now,
165 struct smbXsrv_open **_open)
166 {
167 struct smbXsrv_open *op = NULL;
168
169 *_open = NULL;
170
171 if (open_local_id == 0) {
172 return NT_STATUS_FILE_CLOSED;
173 }
174
175 if (table == NULL) {
176 /* this might happen before the end of negprot */
177 return NT_STATUS_FILE_CLOSED;
178 }
179
180 if (table->local.idr == NULL) {
181 return NT_STATUS_INTERNAL_ERROR;
182 }
183
184 op = idr_find(table->local.idr, open_local_id);
185 if (op == NULL) {
186 return NT_STATUS_FILE_CLOSED;
187 }
188
189 if (open_global_id == 0) {
190 /* make the global check a no-op for SMB1 */
191 open_global_id = op->global->open_global_id;
192 }
193
194 if (op->global->open_global_id != open_global_id) {
195 return NT_STATUS_FILE_CLOSED;
196 }
197
198 if (now != 0) {
199 op->idle_time = now;
200 }
201
202 *_open = op;
203 return NT_STATUS_OK;
204 }
205
206 static NTSTATUS smbXsrv_open_global_parse_record(
207 TALLOC_CTX *mem_ctx,
208 TDB_DATA key,
209 TDB_DATA val,
210 struct smbXsrv_open_global0 **global)
211 {
212 DATA_BLOB blob = data_blob_const(val.dptr, val.dsize);
213 struct smbXsrv_open_globalB global_blob;
214 enum ndr_err_code ndr_err;
215 NTSTATUS status;
216 TALLOC_CTX *frame = talloc_stackframe();
217
218 ndr_err = ndr_pull_struct_blob(&blob, frame, &global_blob,
219 (ndr_pull_flags_fn_t)ndr_pull_smbXsrv_open_globalB);
220 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
221 DEBUG(1,("Invalid record in smbXsrv_open_global.tdb:"
222 "key '%s' ndr_pull_struct_blob - %s\n",
223 tdb_data_dbg(key),
224 ndr_errstr(ndr_err)));
225 status = ndr_map_error2ntstatus(ndr_err);
226 goto done;
227 }
228
229 DBG_DEBUG("\n");
230 if (CHECK_DEBUGLVL(10)) {
231 NDR_PRINT_DEBUG(smbXsrv_open_globalB, &global_blob);
232 }
233
234 if (global_blob.version != SMBXSRV_VERSION_0) {
235 status = NT_STATUS_INTERNAL_DB_CORRUPTION;
236 DEBUG(1,("Invalid record in smbXsrv_open_global.tdb:"
237 "key '%s' unsupported version - %d - %s\n",
238 tdb_data_dbg(key),
239 (int)global_blob.version,
240 nt_errstr(status)));
241 goto done;
242 }
243
244 if (global_blob.info.info0 == NULL) {
245 status = NT_STATUS_INTERNAL_DB_CORRUPTION;
246 DEBUG(1,("Invalid record in smbXsrv_open_global.tdb:"
247 "key '%s' info0 NULL pointer - %s\n",
248 tdb_data_dbg(key),
249 nt_errstr(status)));
250 goto done;
251 }
252
253 *global = talloc_move(mem_ctx, &global_blob.info.info0);
254 status = NT_STATUS_OK;
255 done:
256 talloc_free(frame);
257 return status;
258 }
259
260 static NTSTATUS smbXsrv_open_global_verify_record(
261 TDB_DATA key,
262 TDB_DATA val,
263 TALLOC_CTX *mem_ctx,
264 struct smbXsrv_open_global0 **_global0)
265 {
266 struct smbXsrv_open_global0 *global0 = NULL;
267 struct server_id_buf buf;
268 NTSTATUS status;
269
270 if (val.dsize == 0) {
271 return NT_STATUS_NOT_FOUND;
272 }
273
274 status = smbXsrv_open_global_parse_record(mem_ctx, key, val, &global0);
275 if (!NT_STATUS_IS_OK(status)) {
276 DBG_WARNING("smbXsrv_open_global_parse_record for %s failed: "
277 "%s\n",
278 tdb_data_dbg(key),
279 nt_errstr(status));
280 return status;
281 }
282 *_global0 = global0;
283
284 if (server_id_is_disconnected(&global0->server_id)) {
285 return NT_STATUS_OK;
286 }
287 if (serverid_exists(&global0->server_id)) {
288 return NT_STATUS_OK;
289 }
290
291 DBG_WARNING("smbd %s did not clean up record %s\n",
292 server_id_str_buf(global0->server_id, &buf),
293 tdb_data_dbg(key));
294
295 return NT_STATUS_FATAL_APP_EXIT;
296 }
297
298 static NTSTATUS smbXsrv_open_global_store(
299 struct db_record *rec,
300 TDB_DATA key,
301 TDB_DATA oldval,
302 struct smbXsrv_open_global0 *global)
303 {
304 struct smbXsrv_open_globalB global_blob;
305 DATA_BLOB blob = data_blob_null;
306 TDB_DATA val = { .dptr = NULL, };
307 NTSTATUS status;
308 enum ndr_err_code ndr_err;
309
310 /*
311 * TODO: if we use other versions than '0'
312 * we would add glue code here, that would be able to
313 * store the information in the old format.
314 */
315
316 global_blob = (struct smbXsrv_open_globalB) {
317 .version = smbXsrv_version_global_current(),
318 };
319
320 if (oldval.dsize >= 8) {
321 global_blob.seqnum = IVAL(oldval.dptr, 4);
322 }
323 global_blob.seqnum += 1;
324 global_blob.info.info0 = global;
325
326 ndr_err = ndr_push_struct_blob(&blob, talloc_tos(), &global_blob,
327 (ndr_push_flags_fn_t)ndr_push_smbXsrv_open_globalB);
328 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
329 DBG_WARNING("key '%s' ndr_push - %s\n",
330 tdb_data_dbg(key),
331 ndr_map_error2string(ndr_err));
332 return ndr_map_error2ntstatus(ndr_err);
333 }
334
335 val = make_tdb_data(blob.data, blob.length);
336 status = dbwrap_record_store(rec, val, TDB_REPLACE);
337 TALLOC_FREE(blob.data);
338 if (!NT_STATUS_IS_OK(status)) {
339 DBG_WARNING("key '%s' store - %s\n",
340 tdb_data_dbg(key),
341 nt_errstr(status));
342 return status;
343 }
344
345 if (CHECK_DEBUGLVL(10)) {
346 DBG_DEBUG("key '%s' stored\n", tdb_data_dbg(key));
347 NDR_PRINT_DEBUG(smbXsrv_open_globalB, &global_blob);
348 }
349
350 return NT_STATUS_OK;
351 }
352
353 struct smbXsrv_open_global_allocate_state {
354 uint32_t id;
355 struct smbXsrv_open_global0 *global;
356 NTSTATUS status;
357 };
358
359 static void smbXsrv_open_global_allocate_fn(
360 struct db_record *rec, TDB_DATA oldval, void *private_data)
361 {
362 struct smbXsrv_open_global_allocate_state *state = private_data;
363 struct smbXsrv_open_global0 *global = state->global;
364 struct smbXsrv_open_global0 *tmp_global0 = NULL;
365 TDB_DATA key = dbwrap_record_get_key(rec);
366
367 state->status = smbXsrv_open_global_verify_record(
368 key, oldval, talloc_tos(), &tmp_global0);
369
370 if (NT_STATUS_IS_OK(state->status)) {
371 /*
372 * Found an existing record
373 */
374 TALLOC_FREE(tmp_global0);
375 state->status = NT_STATUS_RETRY;
376 return;
377 }
378
379 if (NT_STATUS_EQUAL(state->status, NT_STATUS_NOT_FOUND)) {
380 /*
381 * Found an empty slot
382 */
383 global->open_global_id = state->id;
384 global->open_persistent_id = state->id;
385
386 state->status = smbXsrv_open_global_store(
387 rec, key, (TDB_DATA) { .dsize = 0, }, state->global);
388 if (!NT_STATUS_IS_OK(state->status)) {
389 DBG_WARNING("smbXsrv_open_global_store() for "
390 "id %"PRIu32" failed: %s\n",
391 state->id,
392 nt_errstr(state->status));
393 }
394 return;
395 }
396
397 if (NT_STATUS_EQUAL(state->status, NT_STATUS_FATAL_APP_EXIT)) {
398 NTSTATUS status;
399
400 TALLOC_FREE(tmp_global0);
401
402 /*
403 * smbd crashed
404 */
405 status = dbwrap_record_delete(rec);
406 if (!NT_STATUS_IS_OK(status)) {
407 DBG_WARNING("dbwrap_record_delete() failed "
408 "for record %"PRIu32": %s\n",
409 state->id,
410 nt_errstr(status));
411 state->status = NT_STATUS_INTERNAL_DB_CORRUPTION;
412 return;
413 }
414 return;
415 }
416 }
417
418 static NTSTATUS smbXsrv_open_global_allocate(
419 struct db_context *db, struct smbXsrv_open_global0 *global)
420 {
421 struct smbXsrv_open_global_allocate_state state = {
422 .global = global,
423 };
424 uint32_t i;
425 uint32_t last_free = 0;
426 const uint32_t min_tries = 3;
427
428 /*
429 * Here we just randomly try the whole 32-bit space
430 *
431 * We use just 32-bit, because we want to reuse the
432 * ID for SRVSVC.
433 */
434 for (i = 0; i < UINT32_MAX; i++) {
435 struct smbXsrv_open_global_key_buf key_buf;
436 TDB_DATA key;
437 NTSTATUS status;
438
439 if (i >= min_tries && last_free != 0) {
440 state.id = last_free;
441 } else {
442 generate_nonce_buffer(
443 (uint8_t *)&state.id, sizeof(state.id));
444 state.id = MAX(state.id, 1);
445 state.id = MIN(state.id, UINT32_MAX-1);
446 }
447
448 key = smbXsrv_open_global_id_to_key(state.id, &key_buf);
449
450 status = dbwrap_do_locked(
451 db, key, smbXsrv_open_global_allocate_fn, &state);
452
453 if (!NT_STATUS_IS_OK(status)) {
454 DBG_WARNING("dbwrap_do_locked() failed: %s\n",
455 nt_errstr(status));
456 return NT_STATUS_INTERNAL_DB_ERROR;
457 }
458
459 if (NT_STATUS_IS_OK(state.status)) {
460 /*
461 * Found an empty slot, done.
462 */
463 DBG_DEBUG("Found slot %"PRIu32"\n", state.id);
464 return NT_STATUS_OK;
465 }
466
467 if (NT_STATUS_EQUAL(state.status, NT_STATUS_FATAL_APP_EXIT)) {
468
469 if ((i < min_tries) && (last_free == 0)) {
470 /*
471 * Remember "id" as free but also try
472 * others to not recycle ids too
473 * quickly.
474 */
475 last_free = state.id;
476 }
477 continue;
478 }
479
480 if (NT_STATUS_EQUAL(state.status, NT_STATUS_RETRY)) {
481 /*
482 * Normal collision, try next
483 */
484 DBG_DEBUG("Found record for id %"PRIu32"\n",
485 state.id);
486 continue;
487 }
488
489 DBG_WARNING("smbXsrv_open_global_allocate_fn() failed: %s\n",
490 nt_errstr(state.status));
491 return state.status;
492 }
493
494 /* should not be reached */
495 return NT_STATUS_INTERNAL_ERROR;
496 }
497
498 static int smbXsrv_open_destructor(struct smbXsrv_open *op)
499 {
500 NTSTATUS status;
501
502 status = smbXsrv_open_close(op, 0);
503 if (!NT_STATUS_IS_OK(status)) {
504 DEBUG(0, ("smbXsrv_open_destructor: "
505 "smbXsrv_open_close() failed - %s\n",
506 nt_errstr(status)));
507 }
508
509 TALLOC_FREE(op->global);
510
511 return 0;
512 }
513
514 NTSTATUS smbXsrv_open_create(struct smbXsrv_connection *conn,
515 struct auth_session_info *session_info,
516 NTTIME now,
517 struct smbXsrv_open **_open)
518 {
519 struct smbXsrv_open_table *table = conn->client->open_table;
520 struct smbXsrv_open *op = NULL;
521 struct smbXsrv_open_global0 *global = NULL;
522 NTSTATUS status;
523 struct dom_sid *current_sid = NULL;
524 struct security_token *current_token = NULL;
525 int local_id;
526
527 if (session_info == NULL) {
528 return NT_STATUS_INVALID_HANDLE;
529 }
530 current_token = session_info->security_token;
531
532 if ((current_token == NULL) ||
533 (current_token->num_sids <= PRIMARY_USER_SID_INDEX)) {
534 return NT_STATUS_INVALID_HANDLE;
535 }
536 current_sid = &current_token->sids[PRIMARY_USER_SID_INDEX];
537
538 if (table->local.num_opens >= table->local.max_opens) {
539 return NT_STATUS_INSUFFICIENT_RESOURCES;
540 }
541
542 op = talloc_zero(table, struct smbXsrv_open);
543 if (op == NULL) {
544 return NT_STATUS_NO_MEMORY;
545 }
546 op->table = table;
547 op->status = NT_STATUS_OK; /* TODO: start with INTERNAL_ERROR */
548 op->idle_time = now;
549
550 global = talloc_zero(op, struct smbXsrv_open_global0);
551 if (global == NULL) {
552 TALLOC_FREE(op);
553 return NT_STATUS_NO_MEMORY;
554 }
555 op->global = global;
556
557 /*
558 * We mark every slot as invalid using 0xFF.
559 * Valid values are masked with 0xF.
560 */
561 memset(global->lock_sequence_array, 0xFF,
562 sizeof(global->lock_sequence_array));
563
564 local_id = idr_get_new_random(
565 table->local.idr,
566 op,
567 table->local.lowest_id,
568 table->local.highest_id);
569 if (local_id == -1) {
570 TALLOC_FREE(op);
571 return NT_STATUS_INSUFFICIENT_RESOURCES;
572 }
573 op->local_id = local_id;
574
575 global->open_volatile_id = op->local_id;
576
577 global->server_id = messaging_server_id(conn->client->msg_ctx);
578 global->open_time = now;
579 global->open_owner = *current_sid;
580 if (conn->protocol >= PROTOCOL_SMB2_10) {
581 global->client_guid = conn->smb2.client.guid;
582 }
583
584 status = smbXsrv_open_global_allocate(table->global.db_ctx,
585 global);
586 if (!NT_STATUS_IS_OK(status)) {
587 int ret = idr_remove(table->local.idr, local_id);
588 SMB_ASSERT(ret == 0);
589
590 DBG_WARNING("smbXsrv_open_global_allocate() failed: %s\n",
591 nt_errstr(status));
592 TALLOC_FREE(op);
593 return status;
594 }
595
596 table->local.num_opens += 1;
597 talloc_set_destructor(op, smbXsrv_open_destructor);
598
599 if (CHECK_DEBUGLVL(10)) {
600 struct smbXsrv_openB open_blob = {
601 .version = SMBXSRV_VERSION_0,
602 .info.info0 = op,
603 };
604
605 DEBUG(10,("smbXsrv_open_create: global_id (0x%08x) stored\n",
606 op->global->open_global_id));
607 NDR_PRINT_DEBUG(smbXsrv_openB, &open_blob);
608 }
609
610 *_open = op;
611 return NT_STATUS_OK;
612 }
613
614 static NTSTATUS smbXsrv_open_set_replay_cache(struct smbXsrv_open *op)
615 {
616 struct GUID *create_guid;
617 struct GUID_txt_buf buf;
618 char *guid_string;
619 struct db_context *db = op->table->local.replay_cache_db_ctx;
620 struct smbXsrv_open_replay_cache rc = {
621 .idle_time = op->idle_time,
622 .local_id = op->local_id,
623 };
624 uint8_t data[SMBXSRV_OPEN_REPLAY_CACHE_FIXED_SIZE] = { 0 };
625 DATA_BLOB blob = { .data = data, .length = sizeof(data), };
626 enum ndr_err_code ndr_err;
627 NTSTATUS status;
628 TDB_DATA val;
629
630 if (!(op->flags & SMBXSRV_OPEN_NEED_REPLAY_CACHE)) {
631 return NT_STATUS_OK;
632 }
633
634 if (op->flags & SMBXSRV_OPEN_HAVE_REPLAY_CACHE) {
635 return NT_STATUS_OK;
636 }
637
638 create_guid = &op->global->create_guid;
639 guid_string = GUID_buf_string(create_guid, &buf);
640
641 ndr_err = ndr_push_struct_into_fixed_blob(&blob, &rc,
642 (ndr_push_flags_fn_t)ndr_push_smbXsrv_open_replay_cache);
643 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
644 status = ndr_map_error2ntstatus(ndr_err);
645 return status;
646 }
647 val = make_tdb_data(blob.data, blob.length);
648
649 status = dbwrap_store_bystring(db, guid_string, val, TDB_REPLACE);
650
651 if (NT_STATUS_IS_OK(status)) {
652 op->flags |= SMBXSRV_OPEN_HAVE_REPLAY_CACHE;
653 op->flags &= ~SMBXSRV_OPEN_NEED_REPLAY_CACHE;
654 }
655
656 return status;
657 }
658
659 NTSTATUS smbXsrv_open_purge_replay_cache(struct smbXsrv_client *client,
660 const struct GUID *create_guid)
661 {
662 struct GUID_txt_buf buf;
663 char *guid_string;
664 struct db_context *db;
665
666 if (client->open_table == NULL) {
667 return NT_STATUS_OK;
668 }
669
670 db = client->open_table->local.replay_cache_db_ctx;
671
672 guid_string = GUID_buf_string(create_guid, &buf);
673 if (guid_string == NULL) {
674 return NT_STATUS_INVALID_PARAMETER;
675 }
676
677 return dbwrap_purge_bystring(db, guid_string);
678 }
679
680 static NTSTATUS smbXsrv_open_clear_replay_cache(struct smbXsrv_open *op)
681 {
682 struct GUID *create_guid;
683 struct GUID_txt_buf buf;
684 char *guid_string;
685 struct db_context *db;
686 NTSTATUS status;
687
688 if (op->table == NULL) {
689 return NT_STATUS_OK;
690 }
691
692 db = op->table->local.replay_cache_db_ctx;
693
694 if (!(op->flags & SMBXSRV_OPEN_HAVE_REPLAY_CACHE)) {
695 return NT_STATUS_OK;
696 }
697
698 create_guid = &op->global->create_guid;
699 if (GUID_all_zero(create_guid)) {
700 return NT_STATUS_OK;
701 }
702
703 guid_string = GUID_buf_string(create_guid, &buf);
704 if (guid_string == NULL) {
705 return NT_STATUS_INVALID_PARAMETER;
706 }
707
708 status = dbwrap_purge_bystring(db, guid_string);
709
710 if (NT_STATUS_IS_OK(status)) {
711 op->flags &= ~SMBXSRV_OPEN_HAVE_REPLAY_CACHE;
712 }
713
714 return status;
715 }
716
717 struct smbXsrv_open_update_state {
718 struct smbXsrv_open_global0 *global;
719 NTSTATUS status;
720 };
721
722 static void smbXsrv_open_update_fn(
723 struct db_record *rec, TDB_DATA oldval, void *private_data)
724 {
725 struct smbXsrv_open_update_state *state = private_data;
726 TDB_DATA key = dbwrap_record_get_key(rec);
727
728 state->status = smbXsrv_open_global_store(
729 rec, key, oldval, state->global);
730 }
731
732 NTSTATUS smbXsrv_open_update(struct smbXsrv_open *op)
733 {
734 struct smbXsrv_open_update_state state = { .global = op->global, };
735 struct smbXsrv_open_table *table = op->table;
736 struct smbXsrv_open_global_key_buf key_buf;
737 TDB_DATA key = smbXsrv_open_global_id_to_key(
738 op->global->open_global_id, &key_buf);
739 NTSTATUS status;
740
741 status = dbwrap_do_locked(
742 table->global.db_ctx, key, smbXsrv_open_update_fn, &state);
743 if (!NT_STATUS_IS_OK(status)) {
744 DBG_WARNING("global_id (0x%08x) dbwrap_do_locked failed: %s\n",
745 op->global->open_global_id,
746 nt_errstr(status));
747 return NT_STATUS_INTERNAL_DB_ERROR;
748 }
749
750 if (!NT_STATUS_IS_OK(state.status)) {
751 DBG_WARNING("global_id (0x%08x) smbXsrv_open_global_store "
752 "failed: %s\n",
753 op->global->open_global_id,
754 nt_errstr(state.status));
755 return state.status;
756 }
757
758 status = smbXsrv_open_set_replay_cache(op);
759 if (!NT_STATUS_IS_OK(status)) {
760 DBG_ERR("smbXsrv_open_set_replay_cache failed: %s\n",
761 nt_errstr(status));
762 return status;
763 }
764
765 if (CHECK_DEBUGLVL(10)) {
766 struct smbXsrv_openB open_blob = {
767 .version = SMBXSRV_VERSION_0,
768 .info.info0 = op,
769 };
770
771 DEBUG(10,("smbXsrv_open_update: global_id (0x%08x) stored\n",
772 op->global->open_global_id));
773 NDR_PRINT_DEBUG(smbXsrv_openB, &open_blob);
774 }
775
776 return NT_STATUS_OK;
777 }
778
779 struct smbXsrv_open_close_state {
780 struct smbXsrv_open *op;
781 NTSTATUS status;
782 };
783
784 static void smbXsrv_open_close_fn(
785 struct db_record *rec, TDB_DATA oldval, void *private_data)
786 {
787 struct smbXsrv_open_close_state *state = private_data;
788 struct smbXsrv_open_global0 *global = state->op->global;
789 TDB_DATA key = dbwrap_record_get_key(rec);
790
791 if (global->durable) {
792 /*
793 * Durable open -- we need to update the global part
794 * instead of deleting it
795 */
796 state->status = smbXsrv_open_global_store(
797 rec, key, oldval, global);
798 if (!NT_STATUS_IS_OK(state->status)) {
799 DBG_WARNING("failed to store global key '%s': %s\n",
800 tdb_data_dbg(key),
801 nt_errstr(state->status));
802 return;
803 }
804
805 if (CHECK_DEBUGLVL(10)) {
806 struct smbXsrv_openB open_blob = {
807 .version = SMBXSRV_VERSION_0,
808 .info.info0 = state->op,
809 };
810
811 DBG_DEBUG("(0x%08x) stored disconnect\n",
812 global->open_global_id);
813 NDR_PRINT_DEBUG(smbXsrv_openB, &open_blob);
814 }
815 return;
816 }
817
818 state->status = dbwrap_record_delete(rec);
819 if (!NT_STATUS_IS_OK(state->status)) {
820 DBG_WARNING("failed to delete global key '%s': %s\n",
821 tdb_data_dbg(key),
822 nt_errstr(state->status));
823 }
824 }
825
826 NTSTATUS smbXsrv_open_close(struct smbXsrv_open *op, NTTIME now)
827 {
828 struct smbXsrv_open_close_state state = { .op = op, };
829 struct smbXsrv_open_global0 *global = op->global;
830 struct smbXsrv_open_table *table;
831 NTSTATUS status;
832 NTSTATUS error = NT_STATUS_OK;
833 struct smbXsrv_open_global_key_buf key_buf;
834 TDB_DATA key = smbXsrv_open_global_id_to_key(
835 global->open_global_id, &key_buf);
836 int ret;
837
838 error = smbXsrv_open_clear_replay_cache(op);
839 if (!NT_STATUS_IS_OK(error)) {
840 DBG_ERR("smbXsrv_open_clear_replay_cache failed: %s\n",
841 nt_errstr(error));
842 }
843
844 if (op->table == NULL) {
845 return error;
846 }
847
848 table = op->table;
849 op->table = NULL;
850
851 op->status = NT_STATUS_FILE_CLOSED;
852 global->disconnect_time = now;
853 server_id_set_disconnected(&global->server_id);
854
855 status = dbwrap_do_locked(
856 table->global.db_ctx, key, smbXsrv_open_close_fn, &state);
857 if (!NT_STATUS_IS_OK(status)) {
858 DBG_WARNING("dbwrap_do_locked() for %s failed: %s\n",
859 tdb_data_dbg(key),
860 nt_errstr(status));
861 error = status;
862 } else if (!NT_STATUS_IS_OK(state.status)) {
863 DBG_WARNING("smbXsrv_open_close_fn() for %s failed: %s\n",
864 tdb_data_dbg(key),
865 nt_errstr(state.status));
866 error = state.status;
867 }
868
869 ret = idr_remove(table->local.idr, op->local_id);
870 SMB_ASSERT(ret == 0);
871
872 table->local.num_opens -= 1;
873
874 if (op->compat) {
875 op->compat->op = NULL;
876 file_free(NULL, op->compat);
877 op->compat = NULL;
878 }
879
880 return error;
881 }
882
883 NTSTATUS smb1srv_open_table_init(struct smbXsrv_connection *conn)
884 {
885 uint32_t max_opens;
886
887 /*
888 * Allow a range from 1..65534.
889 *
890 * With real_max_open_files possible ids,
891 * truncated to the SMB1 limit of 16-bit.
892 *
893 * 0 and 0xFFFF are no valid ids.
894 */
895 max_opens = conn->client->sconn->real_max_open_files;
896 max_opens = MIN(max_opens, UINT16_MAX - 1);
897
898 return smbXsrv_open_table_init(conn, 1, UINT16_MAX - 1, max_opens);
899 }
900
901 NTSTATUS smb1srv_open_lookup(struct smbXsrv_connection *conn,
902 uint16_t fnum, NTTIME now,
903 struct smbXsrv_open **_open)
904 {
905 struct smbXsrv_open_table *table = conn->client->open_table;
906 uint32_t local_id = fnum;
907 uint32_t global_id = 0;
908
909 return smbXsrv_open_local_lookup(table, local_id, global_id, now, _open);
910 }
911
912 NTSTATUS smb2srv_open_table_init(struct smbXsrv_connection *conn)
913 {
914 uint32_t max_opens;
915 uint32_t highest_id;
916
917 /*
918 * Allow a range from 1..4294967294.
919 *
920 * With real_max_open_files possible ids,
921 * truncated to 16-bit (the same as SMB1 for now).
922 *
923 * 0 and 0xFFFFFFFF are no valid ids.
924 *
925 * The usage of conn->sconn->real_max_open_files
926 * is the reason that we use one open table per
927 * transport connection (as we still have a 1:1 mapping
928 * between process and transport connection).
929 */
930 max_opens = conn->client->sconn->real_max_open_files;
931 max_opens = MIN(max_opens, UINT16_MAX - 1);
932
933 /*
934 * idtree uses "int" for local IDs. Limit the maximum ID to
935 * what "int" can hold.
936 */
937 highest_id = UINT32_MAX-1;
938 highest_id = MIN(highest_id, INT_MAX);
939
940 return smbXsrv_open_table_init(conn, 1, highest_id, max_opens);
941 }
942
943 NTSTATUS smb2srv_open_lookup(struct smbXsrv_connection *conn,
944 uint64_t persistent_id,
945 uint64_t volatile_id,
946 NTTIME now,
947 struct smbXsrv_open **_open)
948 {
949 struct smbXsrv_open_table *table = conn->client->open_table;
950 uint32_t local_id = volatile_id & UINT32_MAX;
951 uint64_t local_zeros = volatile_id & 0xFFFFFFFF00000000LLU;
952 uint32_t global_id = persistent_id & UINT32_MAX;
953 uint64_t global_zeros = persistent_id & 0xFFFFFFFF00000000LLU;
954 NTSTATUS status;
955
956 if (local_zeros != 0) {
957 return NT_STATUS_FILE_CLOSED;
958 }
959
960 if (global_zeros != 0) {
961 return NT_STATUS_FILE_CLOSED;
962 }
963
964 if (global_id == 0) {
965 return NT_STATUS_FILE_CLOSED;
966 }
967
968 status = smbXsrv_open_local_lookup(table, local_id, global_id, now,
969 _open);
970 if (!NT_STATUS_IS_OK(status)) {
971 return status;
972 }
973
974 /*
975 * Clear the replay cache for this create_guid if it exists:
976 * This is based on the assumption that this lookup will be
977 * triggered by a client request using the file-id for lookup.
978 * Hence the client has proven that it has in fact seen the
979 * reply to its initial create call. So subsequent create replays
980 * should be treated as invalid. Hence the index for create_guid
981 * lookup needs to be removed.
982 */
983 status = smbXsrv_open_clear_replay_cache(*_open);
984
985 return status;
986 }
987
988 /*
989 * This checks or marks the replay cache, we have the following
990 * cases:
991 *
992 * 1. There is no record in the cache
993 * => we add the passes caller_req_guid as holder_req_guid
994 * together with local_id as 0.
995 * => We return STATUS_FWP_RESERVED in order to indicate
996 * that the caller holds the current reservation
997 *
998 * 2. There is a record in the cache and holder_req_guid
999 * is already the same as caller_req_guid and local_id is 0
1000 * => We return STATUS_FWP_RESERVED in order to indicate
1001 * that the caller holds the current reservation
1002 *
1003 * 3. There is a record in the cache with a holder_req_guid
1004 * other than caller_req_guid (and local_id is 0):
1005 * => We return NT_STATUS_FILE_NOT_AVAILABLE to indicate
1006 * the original request is still pending
1007 *
1008 * 4. There is a record in the cache with a zero holder_req_guid
1009 * and a valid local_id:
1010 * => We lookup the existing open by local_id
1011 * => We return NT_STATUS_OK together with the smbXsrv_open
1012 *
1013 *
1014 * With NT_STATUS_OK the caller can continue the replay processing.
1015 *
1016 * With STATUS_FWP_RESERVED the caller should continue the normal
1017 * open processing:
1018 * - On success:
1019 * - smbXsrv_open_update()/smbXsrv_open_set_replay_cache()
1020 * will convert the record to a zero holder_req_guid
1021 * with a valid local_id.
1022 * - On failure:
1023 * - smbXsrv_open_purge_replay_cache() should cleanup
1024 * the reservation.
1025 *
1026 * All other values should be returned to the client,
1027 * while NT_STATUS_FILE_NOT_AVAILABLE will trigger the
1028 * retry loop on the client.
1029 */
1030 NTSTATUS smb2srv_open_lookup_replay_cache(struct smbXsrv_connection *conn,
1031 struct GUID caller_req_guid,
1032 struct GUID create_guid,
1033 const char *name,
1034 NTTIME now,
1035 struct smbXsrv_open **_open)
1036 {
1037 TALLOC_CTX *frame = talloc_stackframe();
1038 NTSTATUS status;
1039 struct smbXsrv_open_table *table = conn->client->open_table;
1040 struct db_context *db = table->local.replay_cache_db_ctx;
1041 struct GUID_txt_buf tmp_guid_buf;
1042 struct GUID_txt_buf _create_guid_buf;
1043 const char *create_guid_str = GUID_buf_string(&create_guid, &_create_guid_buf);
1044 TDB_DATA create_guid_key = string_term_tdb_data(create_guid_str);
1045 struct db_record *db_rec = NULL;
1046 struct smbXsrv_open *op = NULL;
1047 struct smbXsrv_open_replay_cache rc = {
1048 .holder_req_guid = caller_req_guid,
1049 .idle_time = now,
1050 .local_id = 0,
1051 };
1052 enum ndr_err_code ndr_err;
1053 DATA_BLOB blob = data_blob_null;
1054 TDB_DATA val;
1055
1056 *_open = NULL;
1057
1058 db_rec = dbwrap_fetch_locked(db, frame, create_guid_key);
1059 if (db_rec == NULL) {
1060 TALLOC_FREE(frame);
1061 return NT_STATUS_INTERNAL_DB_ERROR;
1062 }
1063
1064 val = dbwrap_record_get_value(db_rec);
1065 if (val.dsize == 0) {
1066 uint8_t data[SMBXSRV_OPEN_REPLAY_CACHE_FIXED_SIZE];
1067
1068 blob = data_blob_const(data, ARRAY_SIZE(data));
1069 ndr_err = ndr_push_struct_into_fixed_blob(&blob, &rc,
1070 (ndr_push_flags_fn_t)ndr_push_smbXsrv_open_replay_cache);
1071 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
1072 status = ndr_map_error2ntstatus(ndr_err);
1073 TALLOC_FREE(frame);
1074 return status;
1075 }
1076
1077 val = make_tdb_data(blob.data, blob.length);
1078 status = dbwrap_record_store(db_rec, val, TDB_REPLACE);
1079 if (!NT_STATUS_IS_OK(status)) {
1080 TALLOC_FREE(frame);
1081 return status;
1082 }
1083
1084 /*
1085 * We're the new holder
1086 */
1087 *_open = NULL;
1088 TALLOC_FREE(frame);
1089 return NT_STATUS_FWP_RESERVED;
1090 }
1091
1092 if (val.dsize != SMBXSRV_OPEN_REPLAY_CACHE_FIXED_SIZE) {
1093 TALLOC_FREE(frame);
1094 return NT_STATUS_INTERNAL_DB_CORRUPTION;
1095 }
1096
1097 blob = data_blob_const(val.dptr, val.dsize);
1098 ndr_err = ndr_pull_struct_blob_all_noalloc(&blob, &rc,
1099 (ndr_pull_flags_fn_t)ndr_pull_smbXsrv_open_replay_cache);
1100 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
1101 status = ndr_map_error2ntstatus(ndr_err);
1102 TALLOC_FREE(frame);
1103 return status;
1104 }
1105 if (rc.local_id != 0) {
1106 if (GUID_equal(&rc.holder_req_guid, &caller_req_guid)) {
1107 /*
1108 * This should not happen
1109 */
1110 status = NT_STATUS_INTERNAL_ERROR;
1111 DBG_ERR("caller %s already holds local_id %u for create %s [%s] - %s\n",
1112 GUID_buf_string(&caller_req_guid, &tmp_guid_buf),
1113 (unsigned)rc.local_id,
1114 create_guid_str,
1115 name,
1116 nt_errstr(status));
1117
1118 TALLOC_FREE(frame);
1119 return status;
1120 }
1121
1122 status = smbXsrv_open_local_lookup(table,
1123 rc.local_id,
1124 0, /* global_id */
1125 now,
1126 &op);
1127 if (!NT_STATUS_IS_OK(status)) {
1128 DBG_ERR("holder %s stale for local_id %u for create %s [%s] - %s\n",
1129 GUID_buf_string(&rc.holder_req_guid, &tmp_guid_buf),
1130 (unsigned)rc.local_id,
1131 create_guid_str,
1132 name,
1133 nt_errstr(status));
1134
1135 TALLOC_FREE(frame);
1136 return status;
1137 }
1138
1139 /*
1140 * We found an open the caller can reuse.
1141 */
1142 SMB_ASSERT(op != NULL);
1143 *_open = op;
1144 TALLOC_FREE(frame);
1145 return NT_STATUS_OK;
1146 }
1147
1148 if (GUID_equal(&rc.holder_req_guid, &caller_req_guid)) {
1149 /*
1150 * We're still the holder
1151 */
1152 *_open = NULL;
1153 TALLOC_FREE(frame);
1154 return NT_STATUS_FWP_RESERVED;
1155 }
1156
1157 /*
1158 * The original request (or a former replay) is still
1159 * pending, ask the client to retry by sending FILE_NOT_AVAILABLE.
1160 */
1161 status = NT_STATUS_FILE_NOT_AVAILABLE;
1162 DBG_DEBUG("holder %s still pending for create %s [%s] - %s\n",
1163 GUID_buf_string(&rc.holder_req_guid, &tmp_guid_buf),
1164 create_guid_str,
1165 name,
1166 nt_errstr(status));
1167 TALLOC_FREE(frame);
1168 return status;
1169 }
1170
1171 struct smb2srv_open_recreate_state {
1172 struct smbXsrv_open *op;
1173 const struct GUID *create_guid;
1174 struct security_token *current_token;
1175 struct server_id me;
1176
1177 NTSTATUS status;
1178 };
1179
1180 static void smb2srv_open_recreate_fn(
1181 struct db_record *rec, TDB_DATA oldval, void *private_data)
1182 {
1183 struct smb2srv_open_recreate_state *state = private_data;
1184 TDB_DATA key = dbwrap_record_get_key(rec);
1185 struct smbXsrv_open_global0 *global = NULL;
1186
1187 state->status = smbXsrv_open_global_verify_record(
1188 key, oldval, state->op, &state->op->global);
1189 if (!NT_STATUS_IS_OK(state->status)) {
1190 DBG_WARNING("smbXsrv_open_global_verify_record for %s "
1191 "failed: %s\n",
1192 tdb_data_dbg(key),
1193 nt_errstr(state->status));
1194 goto not_found;
1195 }
1196 global = state->op->global;
1197
1198 /*
1199 * If the provided create_guid is NULL, this means that
1200 * the reconnect request was a v1 request. In that case
1201 * we should skip the create GUID verification, since
1202 * it is valid to v1-reconnect a v2-opened handle.
1203 */
1204 if ((state->create_guid != NULL) &&
1205 !GUID_equal(&global->create_guid, state->create_guid)) {
1206 struct GUID_txt_buf buf1, buf2;
1207 DBG_NOTICE("%s != %s in %s\n",
1208 GUID_buf_string(&global->create_guid, &buf1),
1209 GUID_buf_string(state->create_guid, &buf2),
1210 tdb_data_dbg(key));
1211 goto not_found;
1212 }
1213
1214 if (!security_token_is_sid(
1215 state->current_token, &global->open_owner)) {
1216 struct dom_sid_buf buf;
1217 DBG_NOTICE("global owner %s not in our token in %s\n",
1218 dom_sid_str_buf(&global->open_owner, &buf),
1219 tdb_data_dbg(key));
1220 goto not_found;
1221 }
1222
1223 if (!global->durable) {
1224 DBG_NOTICE("%"PRIu64"/%"PRIu64" not durable in %s\n",
1225 global->open_persistent_id,
1226 global->open_volatile_id,
1227 tdb_data_dbg(key));
1228 goto not_found;
1229 }
1230
1231 global->open_volatile_id = state->op->local_id;
1232 global->server_id = state->me;
1233
1234 state->status = smbXsrv_open_global_store(rec, key, oldval, global);
1235 if (!NT_STATUS_IS_OK(state->status)) {
1236 DBG_WARNING("smbXsrv_open_global_store for %s failed: %s\n",
1237 tdb_data_dbg(key),
1238 nt_errstr(state->status));
1239 return;
1240 }
1241 return;
1242
1243 not_found:
1244 state->status = NT_STATUS_OBJECT_NAME_NOT_FOUND;
1245 }
1246
1247 NTSTATUS smb2srv_open_recreate(struct smbXsrv_connection *conn,
1248 struct auth_session_info *session_info,
1249 uint64_t persistent_id,
1250 const struct GUID *create_guid,
1251 NTTIME now,
1252 struct smbXsrv_open **_open)
1253 {
1254 struct smbXsrv_open_table *table = conn->client->open_table;
1255 struct smb2srv_open_recreate_state state = {
1256 .create_guid = create_guid,
1257 .me = messaging_server_id(conn->client->msg_ctx),
1258 };
1259 struct smbXsrv_open_global_key_buf key_buf;
1260 TDB_DATA key = smbXsrv_open_global_id_to_key(
1261 persistent_id & UINT32_MAX, &key_buf);
1262 int ret, local_id;
1263 NTSTATUS status;
1264
1265 if (session_info == NULL) {
1266 DEBUG(10, ("session_info=NULL\n"));
1267 return NT_STATUS_INVALID_HANDLE;
1268 }
1269 state.current_token = session_info->security_token;
1270
1271 if (state.current_token == NULL) {
1272 DEBUG(10, ("current_token=NULL\n"));
1273 return NT_STATUS_INVALID_HANDLE;
1274 }
1275
1276 if ((persistent_id & 0xFFFFFFFF00000000LLU) != 0) {
1277 /*
1278 * We only use 32 bit for the persistent ID
1279 */
1280 DBG_DEBUG("persistent_id=%"PRIx64"\n", persistent_id);
1281 return NT_STATUS_OBJECT_NAME_NOT_FOUND;
1282 }
1283
1284 if (table->local.num_opens >= table->local.max_opens) {
1285 return NT_STATUS_INSUFFICIENT_RESOURCES;
1286 }
1287
1288 state.op = talloc_zero(table, struct smbXsrv_open);
1289 if (state.op == NULL) {
1290 return NT_STATUS_NO_MEMORY;
1291 }
1292 state.op->table = table;
1293
1294 local_id = idr_get_new_random(
1295 table->local.idr,
1296 state.op,
1297 table->local.lowest_id,
1298 table->local.highest_id);
1299 if (local_id == -1) {
1300 TALLOC_FREE(state.op);
1301 return NT_STATUS_INSUFFICIENT_RESOURCES;
1302 }
1303 state.op->local_id = local_id;
1304 SMB_ASSERT(state.op->local_id == local_id); /* No coercion loss */
1305
1306 table->local.num_opens += 1;
1307
1308 state.op->idle_time = now;
1309 state.op->status = NT_STATUS_FILE_CLOSED;
1310
1311 status = dbwrap_do_locked(
1312 table->global.db_ctx, key, smb2srv_open_recreate_fn, &state);
1313 if (!NT_STATUS_IS_OK(status)) {
1314 DBG_DEBUG("dbwrap_do_locked() for %s failed: %s\n",
1315 tdb_data_dbg(key),
1316 nt_errstr(status));
1317 goto fail;
1318 }
1319
1320 if (!NT_STATUS_IS_OK(state.status)) {
1321 status = state.status;
1322 DBG_DEBUG("smb2srv_open_recreate_fn for %s failed: %s\n",
1323 tdb_data_dbg(key),
1324 nt_errstr(status));
1325 goto fail;
1326 }
1327
1328 talloc_set_destructor(state.op, smbXsrv_open_destructor);
1329
1330 if (CHECK_DEBUGLVL(10)) {
1331 struct smbXsrv_openB open_blob = {
1332 .info.info0 = state.op,
1333 };
1334 DBG_DEBUG("global_id (0x%08x) stored\n",
1335 state.op->global->open_global_id);
1336 NDR_PRINT_DEBUG(smbXsrv_openB, &open_blob);
1337 }
1338
1339 *_open = state.op;
1340
1341 return NT_STATUS_OK;
1342 fail:
1343 table->local.num_opens -= 1;
1344
1345 ret = idr_remove(table->local.idr, state.op->local_id);
1346 SMB_ASSERT(ret == 0);
1347 TALLOC_FREE(state.op);
1348 return status;
1349 }
1350
1351 struct smbXsrv_open_global_traverse_state {
1352 int (*fn)(struct db_record *rec, struct smbXsrv_open_global0 *, void *);
1353 void *private_data;
1354 };
1355
1356 static int smbXsrv_open_global_traverse_fn(struct db_record *rec, void *data)
1357 {
1358 struct smbXsrv_open_global_traverse_state *state =
1359 (struct smbXsrv_open_global_traverse_state*)data;
1360 struct smbXsrv_open_global0 *global = NULL;
1361 TDB_DATA key = dbwrap_record_get_key(rec);
1362 TDB_DATA val = dbwrap_record_get_value(rec);
1363 NTSTATUS status;
1364 int ret = -1;
1365
1366 status = smbXsrv_open_global_parse_record(
1367 talloc_tos(), key, val, &global);
1368 if (!NT_STATUS_IS_OK(status)) {
1369 return -1;
1370 }
1371
1372 ret = state->fn(rec, global, state->private_data);
1373 talloc_free(global);
1374 return ret;
1375 }
1376
1377 NTSTATUS smbXsrv_open_global_traverse(
1378 int (*fn)(struct db_record *rec, struct smbXsrv_open_global0 *, void *),
1379 void *private_data)
1380 {
1381
1382 NTSTATUS status;
1383 int count = 0;
1384 struct smbXsrv_open_global_traverse_state state = {
1385 .fn = fn,
1386 .private_data = private_data,
1387 };
1388
1389 become_root();
1390 status = smbXsrv_open_global_init();
1391 if (!NT_STATUS_IS_OK(status)) {
1392 unbecome_root();
1393 DEBUG(0, ("Failed to initialize open_global: %s\n",
1394 nt_errstr(status)));
1395 return status;
1396 }
1397
1398 status = dbwrap_traverse_read(smbXsrv_open_global_db_ctx,
1399 smbXsrv_open_global_traverse_fn,
1400 &state,
1401 &count);
1402 unbecome_root();
1403
1404 return status;
1405 }
1406
1407 struct smbXsrv_open_cleanup_state {
1408 uint32_t global_id;
1409 NTSTATUS status;
1410 };
1411
1412 static void smbXsrv_open_cleanup_fn(
1413 struct db_record *rec, TDB_DATA oldval, void *private_data)
1414 {
1415 struct smbXsrv_open_cleanup_state *state = private_data;
1416 struct smbXsrv_open_global0 *global = NULL;
1417 TDB_DATA key = dbwrap_record_get_key(rec);
1418 bool delete_open = false;
1419
1420 if (oldval.dsize == 0) {
1421 DBG_DEBUG("[global: 0x%08x] "
1422 "empty record in %s, skipping...\n",
1423 state->global_id,
1424 dbwrap_name(dbwrap_record_get_db(rec)));
1425 state->status = NT_STATUS_OK;
1426 return;
1427 }
1428
1429 state->status = smbXsrv_open_global_parse_record(
1430 talloc_tos(), key, oldval, &global);
1431 if (!NT_STATUS_IS_OK(state->status)) {
1432 DBG_WARNING("[global: %x08x] "
1433 "smbXsrv_open_global_parse_record() in %s "
1434 "failed: %s, deleting record\n",
1435 state->global_id,
1436 dbwrap_name(dbwrap_record_get_db(rec)),
1437 nt_errstr(state->status));
1438 delete_open = true;
1439 goto do_delete;
1440 }
1441
1442 if (server_id_is_disconnected(&global->server_id)) {
1443 struct timeval now = timeval_current();
1444 struct timeval disconnect_time;
1445 struct timeval_buf buf;
1446 int64_t tdiff;
1447
1448 nttime_to_timeval(&disconnect_time, global->disconnect_time);
1449 tdiff = usec_time_diff(&now, &disconnect_time);
1450 delete_open = (tdiff >= 1000*global->durable_timeout_msec);
1451
1452 DBG_DEBUG("[global: 0x%08x] "
1453 "disconnected at [%s] %"PRIi64"s ago with "
1454 "timeout of %"PRIu32"s -%s reached\n",
1455 state->global_id,
1456 timeval_str_buf(&disconnect_time,
1457 false,
1458 false,
1459 &buf),
1460 tdiff/1000000,
1461 global->durable_timeout_msec / 1000,
1462 delete_open ? "" : " not");
1463 } else if (!serverid_exists(&global->server_id)) {
1464 struct server_id_buf idbuf;
1465 DBG_DEBUG("[global: 0x%08x] "
1466 "server[%s] does not exist\n",
1467 state->global_id,
1468 server_id_str_buf(global->server_id, &idbuf));
1469 delete_open = true;
1470 }
1471
1472 if (!delete_open) {
1473 state->status = NT_STATUS_OK;
1474 return;
1475 }
1476 do_delete:
1477 state->status = dbwrap_record_delete(rec);
1478 if (!NT_STATUS_IS_OK(state->status)) {
1479 DBG_WARNING("[global: 0x%08x] "
1480 "failed to delete record "
1481 "from %s: %s\n",
1482 state->global_id,
1483 dbwrap_name(dbwrap_record_get_db(rec)),
1484 nt_errstr(state->status));
1485 return;
1486 }
1487
1488 DBG_DEBUG("[global: 0x%08x] "
1489 "deleted record from %s\n",
1490 state->global_id,
1491 dbwrap_name(dbwrap_record_get_db(rec)));
1492 }
1493
1494 NTSTATUS smbXsrv_open_cleanup(uint64_t persistent_id)
1495 {
1496 struct smbXsrv_open_cleanup_state state = {
1497 .global_id = persistent_id & UINT32_MAX,
1498 };
1499 struct smbXsrv_open_global_key_buf key_buf;
1500 TDB_DATA key = smbXsrv_open_global_id_to_key(
1501 state.global_id, &key_buf);
1502 NTSTATUS status;
1503
1504 status = dbwrap_do_locked(
1505 smbXsrv_open_global_db_ctx,
1506 key,
1507 smbXsrv_open_cleanup_fn,
1508 &state);
1509 if (!NT_STATUS_IS_OK(status)) {
1510 DBG_DEBUG("[global: 0x%08x] dbwrap_do_locked failed: %s\n",
1511 state.global_id,
1512 nt_errstr(status));
1513 return status;
1514 }
1515
1516 return state.status;
1517 }
Samba GIT mirror