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