source4/ntvfs/common/opendb_tdb.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3
   4    Copyright (C) Andrew Tridgell 2004
   5    Copyright (C) Stefan Metzmacher 2008
   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 /*
  22   this is the open files database, tdb backend. It implements shared
  23   storage of what files are open between server instances, and
  24   implements the rules of shared access to files.
  25
  26   The caller needs to provide a file_key, which specifies what file
  27   they are talking about. This needs to be a unique key across all
  28   filesystems, and is usually implemented in terms of a device/inode
  29   pair.
  30
  31   Before any operations can be performed the caller needs to establish
  32   a lock on the record associated with file_key. That is done by
  33   calling odb_lock(). The caller releases this lock by calling
  34   talloc_free() on the returned handle.
  35
  36   All other operations on a record are done by passing the odb_lock()
  37   handle back to this module. The handle contains internal
  38   information about what file_key is being operated on.
  39 */
  40
  41 #include "includes.h"
  42 #include "system/filesys.h"
  43 #include "lib/tdb/include/tdb.h"
  44 #include "messaging/messaging.h"
  45 #include "tdb_wrap.h"
  46 #include "lib/messaging/irpc.h"
  47 #include "librpc/gen_ndr/ndr_opendb.h"
  48 #include "ntvfs/ntvfs.h"
  49 #include "ntvfs/common/ntvfs_common.h"
  50 #include "cluster/cluster.h"
  51 #include "param/param.h"
  52
  53 struct odb_context {
  54         struct tdb_wrap *w;
  55         struct ntvfs_context *ntvfs_ctx;
  56         bool oplocks;
  57 };
  58
  59 /*
  60   an odb lock handle. You must obtain one of these using odb_lock() before doing
  61   any other operations.
  62 */
  63 struct odb_lock {
  64         struct odb_context *odb;
  65         TDB_DATA key;
  66 };
  67
  68 /*
  69   Open up the openfiles.tdb database. Close it down using
  70   talloc_free(). We need the messaging_ctx to allow for pending open
  71   notifications.
  72 */
  73 static struct odb_context *odb_tdb_init(TALLOC_CTX *mem_ctx,
  74                                         struct ntvfs_context *ntvfs_ctx)
  75 {
  76         struct odb_context *odb;
  77
  78         odb = talloc(mem_ctx, struct odb_context);
  79         if (odb == NULL) {
  80                 return NULL;
  81         }
  82
  83         odb->w = cluster_tdb_tmp_open(odb, ntvfs_ctx->lp_ctx, "openfiles.tdb", TDB_DEFAULT);
  84         if (odb->w == NULL) {
  85                 talloc_free(odb);
  86                 return NULL;
  87         }
  88
  89         odb->ntvfs_ctx = ntvfs_ctx;
  90
  91         /* leave oplocks disabled by default until the code is working */
  92         odb->oplocks = lp_parm_bool(ntvfs_ctx->lp_ctx, NULL, "opendb", "oplocks", false);
  93
  94         return odb;
  95 }
  96
  97 /*
  98   destroy a lock on the database
  99 */
 100 static int odb_lock_destructor(struct odb_lock *lck)
 101 {
 102         tdb_chainunlock(lck->odb->w->tdb, lck->key);
 103         return 0;
 104 }
 105
 106 /*
 107   get a lock on a entry in the odb. This call returns a lock handle,
 108   which the caller should unlock using talloc_free().
 109 */
 110 static struct odb_lock *odb_tdb_lock(TALLOC_CTX *mem_ctx,
 111                                      struct odb_context *odb, DATA_BLOB *file_key)
 112 {
 113         struct odb_lock *lck;
 114
 115         lck = talloc(mem_ctx, struct odb_lock);
 116         if (lck == NULL) {
 117                 return NULL;
 118         }
 119
 120         lck->odb = talloc_reference(lck, odb);
 121         lck->key.dptr = talloc_memdup(lck, file_key->data, file_key->length);
 122         lck->key.dsize = file_key->length;
 123         if (lck->key.dptr == NULL) {
 124                 talloc_free(lck);
 125                 return NULL;
 126         }
 127
 128         if (tdb_chainlock(odb->w->tdb, lck->key) != 0) {
 129                 talloc_free(lck);
 130                 return NULL;
 131         }
 132
 133         talloc_set_destructor(lck, odb_lock_destructor);
 134
 135         return lck;
 136 }
 137
 138 static DATA_BLOB odb_tdb_get_key(TALLOC_CTX *mem_ctx, struct odb_lock *lck)
 139 {
 140         return data_blob_talloc(mem_ctx, lck->key.dptr, lck->key.dsize);
 141 }
 142
 143
 144 /*
 145   determine if two odb_entry structures conflict
 146
 147   return NT_STATUS_OK on no conflict
 148 */
 149 static NTSTATUS share_conflict(struct opendb_entry *e1,
 150                                uint32_t stream_id,
 151                                uint32_t share_access,
 152                                uint32_t access_mask)
 153 {
 154         /* if either open involves no read.write or delete access then
 155            it can't conflict */
 156         if (!(e1->access_mask & (SEC_FILE_WRITE_DATA |
 157                                  SEC_FILE_APPEND_DATA |
 158                                  SEC_FILE_READ_DATA |
 159                                  SEC_FILE_EXECUTE |
 160                                  SEC_STD_DELETE))) {
 161                 return NT_STATUS_OK;
 162         }
 163         if (!(access_mask & (SEC_FILE_WRITE_DATA |
 164                              SEC_FILE_APPEND_DATA |
 165                              SEC_FILE_READ_DATA |
 166                              SEC_FILE_EXECUTE |
 167                              SEC_STD_DELETE))) {
 168                 return NT_STATUS_OK;
 169         }
 170
 171         /* data IO access masks. This is skipped if the two open handles
 172            are on different streams (as in that case the masks don't
 173            interact) */
 174         if (e1->stream_id != stream_id) {
 175                 return NT_STATUS_OK;
 176         }
 177
 178 #define CHECK_MASK(am, right, sa, share) \
 179         if (((am) & (right)) && !((sa) & (share))) return NT_STATUS_SHARING_VIOLATION
 180
 181         CHECK_MASK(e1->access_mask, SEC_FILE_WRITE_DATA | SEC_FILE_APPEND_DATA,
 182                    share_access, NTCREATEX_SHARE_ACCESS_WRITE);
 183         CHECK_MASK(access_mask, SEC_FILE_WRITE_DATA | SEC_FILE_APPEND_DATA,
 184                    e1->share_access, NTCREATEX_SHARE_ACCESS_WRITE);
 185
 186         CHECK_MASK(e1->access_mask, SEC_FILE_READ_DATA | SEC_FILE_EXECUTE,
 187                    share_access, NTCREATEX_SHARE_ACCESS_READ);
 188         CHECK_MASK(access_mask, SEC_FILE_READ_DATA | SEC_FILE_EXECUTE,
 189                    e1->share_access, NTCREATEX_SHARE_ACCESS_READ);
 190
 191         CHECK_MASK(e1->access_mask, SEC_STD_DELETE,
 192                    share_access, NTCREATEX_SHARE_ACCESS_DELETE);
 193         CHECK_MASK(access_mask, SEC_STD_DELETE,
 194                    e1->share_access, NTCREATEX_SHARE_ACCESS_DELETE);
 195 #undef CHECK_MASK
 196         return NT_STATUS_OK;
 197 }
 198
 199 /*
 200   pull a record, translating from the db format to the opendb_file structure defined
 201   in opendb.idl
 202 */
 203 static NTSTATUS odb_pull_record(struct odb_lock *lck, struct opendb_file *file)
 204 {
 205         struct odb_context *odb = lck->odb;
 206         TDB_DATA dbuf;
 207         DATA_BLOB blob;
 208         enum ndr_err_code ndr_err;
 209
 210         dbuf = tdb_fetch(odb->w->tdb, lck->key);
 211         if (dbuf.dptr == NULL) {
 212                 return NT_STATUS_OBJECT_NAME_NOT_FOUND;
 213         }
 214
 215         blob.data = dbuf.dptr;
 216         blob.length = dbuf.dsize;
 217
 218         ndr_err = ndr_pull_struct_blob(&blob, lck, lp_iconv_convenience(lck->odb->ntvfs_ctx->lp_ctx), file, (ndr_pull_flags_fn_t)ndr_pull_opendb_file);
 219         free(dbuf.dptr);
 220         if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
 221                 return ndr_map_error2ntstatus(ndr_err);
 222         }
 223
 224         return NT_STATUS_OK;
 225 }
 226
 227 /*
 228   push a record, translating from the opendb_file structure defined in opendb.idl
 229 */
 230 static NTSTATUS odb_push_record(struct odb_lock *lck, struct opendb_file *file)
 231 {
 232         struct odb_context *odb = lck->odb;
 233         TDB_DATA dbuf;
 234         DATA_BLOB blob;
 235         enum ndr_err_code ndr_err;
 236         int ret;
 237
 238         if (file->num_entries == 0) {
 239                 ret = tdb_delete(odb->w->tdb, lck->key);
 240                 if (ret != 0) {
 241                         return NT_STATUS_INTERNAL_DB_CORRUPTION;
 242                 }
 243                 return NT_STATUS_OK;
 244         }
 245
 246         ndr_err = ndr_push_struct_blob(&blob, lck, lp_iconv_convenience(lck->odb->ntvfs_ctx->lp_ctx), file, (ndr_push_flags_fn_t)ndr_push_opendb_file);
 247         if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
 248                 return ndr_map_error2ntstatus(ndr_err);
 249         }
 250
 251         dbuf.dptr = blob.data;
 252         dbuf.dsize = blob.length;
 253
 254         ret = tdb_store(odb->w->tdb, lck->key, dbuf, TDB_REPLACE);
 255         data_blob_free(&blob);
 256         if (ret != 0) {
 257                 return NT_STATUS_INTERNAL_DB_CORRUPTION;
 258         }
 259
 260         return NT_STATUS_OK;
 261 }
 262
 263 /*
 264   send an oplock break to a client
 265 */
 266 static NTSTATUS odb_oplock_break_send(struct odb_context *odb,
 267                                       struct opendb_entry *e,
 268                                       uint8_t level)
 269 {
 270         NTSTATUS status;
 271         struct opendb_oplock_break op_break;
 272         DATA_BLOB blob;
 273
 274         ZERO_STRUCT(op_break);
 275
 276         /* tell the server handling this open file about the need to send the client
 277            a break */
 278         op_break.file_handle    = e->file_handle;
 279         op_break.level          = level;
 280
 281         blob = data_blob_const(&op_break, sizeof(op_break));
 282
 283         status = messaging_send(odb->ntvfs_ctx->msg_ctx, e->server,
 284                                 MSG_NTVFS_OPLOCK_BREAK, &blob);
 285         NT_STATUS_NOT_OK_RETURN(status);
 286
 287         return NT_STATUS_OK;
 288 }
 289
 290 static bool access_attributes_only(uint32_t access_mask,
 291                                    uint32_t open_disposition,
 292                                    bool break_to_none)
 293 {
 294         switch (open_disposition) {
 295         case NTCREATEX_DISP_SUPERSEDE:
 296         case NTCREATEX_DISP_OVERWRITE_IF:
 297         case NTCREATEX_DISP_OVERWRITE:
 298                 return false;
 299         default:
 300                 break;
 301         }
 302
 303         if (break_to_none) {
 304                 return false;
 305         }
 306
 307 #define CHECK_MASK(m,g) ((m) && (((m) & ~(g))==0) && (((m) & (g)) != 0))
 308         return CHECK_MASK(access_mask,
 309                           SEC_STD_SYNCHRONIZE |
 310                           SEC_FILE_READ_ATTRIBUTE |
 311                           SEC_FILE_WRITE_ATTRIBUTE);
 312 #undef CHECK_MASK
 313 }
 314
 315 static NTSTATUS odb_tdb_open_can_internal(struct odb_context *odb,
 316                                           const struct opendb_file *file,
 317                                           uint32_t stream_id, uint32_t share_access,
 318                                           uint32_t access_mask, bool delete_on_close,
 319                                           uint32_t open_disposition, bool break_to_none,
 320                                           bool *_attrs_only)
 321 {
 322         NTSTATUS status;
 323         uint32_t i;
 324         bool attrs_only = false;
 325
 326         /* see if anyone has an oplock, which we need to break */
 327         for (i=0;i<file->num_entries;i++) {
 328                 if (file->entries[i].oplock_level == OPLOCK_BATCH) {
 329                         bool oplock_return = OPLOCK_BREAK_TO_LEVEL_II;
 330                         /* if this is an attribute only access
 331                          * it doesn't conflict with a BACTCH oplock
 332                          * but we'll not grant the oplock below
 333                          */
 334                         attrs_only = access_attributes_only(access_mask,
 335                                                             open_disposition,
 336                                                             break_to_none);
 337                         if (attrs_only) {
 338                                 break;
 339                         }
 340                         /* a batch oplock caches close calls, which
 341                            means the client application might have
 342                            already closed the file. We have to allow
 343                            this close to propogate by sending a oplock
 344                            break request and suspending this call
 345                            until the break is acknowledged or the file
 346                            is closed */
 347                         if (break_to_none) {
 348                                 oplock_return = OPLOCK_BREAK_TO_NONE;
 349                         }
 350                         odb_oplock_break_send(odb, &file->entries[i],
 351                                               oplock_return);
 352                         return NT_STATUS_OPLOCK_NOT_GRANTED;
 353                 }
 354         }
 355
 356         if (file->delete_on_close) {
 357                 /* while delete on close is set, no new opens are allowed */
 358                 return NT_STATUS_DELETE_PENDING;
 359         }
 360
 361         if (file->num_entries != 0 && delete_on_close) {
 362                 return NT_STATUS_SHARING_VIOLATION;
 363         }
 364
 365         /* check for sharing violations */
 366         for (i=0;i<file->num_entries;i++) {
 367                 status = share_conflict(&file->entries[i], stream_id,
 368                                         share_access, access_mask);
 369                 NT_STATUS_NOT_OK_RETURN(status);
 370         }
 371
 372         /* we now know the open could succeed, but we need to check
 373            for any exclusive oplocks. We can't grant a second open
 374            till these are broken. Note that we check for batch oplocks
 375            before checking for sharing violations, and check for
 376            exclusive oplocks afterwards. */
 377         for (i=0;i<file->num_entries;i++) {
 378                 if (file->entries[i].oplock_level == OPLOCK_EXCLUSIVE) {
 379                         odb_oplock_break_send(odb, &file->entries[i],
 380                                               OPLOCK_BREAK_TO_NONE);
 381                         return NT_STATUS_OPLOCK_NOT_GRANTED;
 382                 }
 383         }
 384
 385         if (_attrs_only) {
 386                 *_attrs_only = attrs_only;
 387         }
 388         return NT_STATUS_OK;
 389 }
 390
 391 /*
 392   register an open file in the open files database. This implements the share_access
 393   rules
 394
 395   Note that the path is only used by the delete on close logic, not
 396   for comparing with other filenames
 397 */
 398 static NTSTATUS odb_tdb_open_file(struct odb_lock *lck,
 399                                   void *file_handle, const char *path,
 400                                   uint32_t stream_id, uint32_t share_access,
 401                                   uint32_t access_mask, bool delete_on_close,
 402                                   uint32_t open_disposition, bool break_to_none,
 403                                   uint32_t oplock_level, uint32_t *oplock_granted)
 404 {
 405         struct odb_context *odb = lck->odb;
 406         struct opendb_entry e;
 407         struct opendb_file file;
 408         NTSTATUS status;
 409         bool attrs_only = false;
 410
 411         if (odb->oplocks == false) {
 412                 oplock_level = OPLOCK_NONE;
 413         }
 414
 415         status = odb_pull_record(lck, &file);
 416         if (NT_STATUS_EQUAL(status, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
 417                 /* initialise a blank structure */
 418                 ZERO_STRUCT(file);
 419                 file.path = path;
 420         } else {
 421                 NT_STATUS_NOT_OK_RETURN(status);
 422         }
 423
 424         /* see if it conflicts */
 425         status = odb_tdb_open_can_internal(odb, &file, stream_id,
 426                                            share_access, access_mask,
 427                                            delete_on_close, open_disposition,
 428                                            break_to_none, &attrs_only);
 429         NT_STATUS_NOT_OK_RETURN(status);
 430
 431         /* see if it conflicts */
 432         e.server          = odb->ntvfs_ctx->server_id;
 433         e.file_handle     = file_handle;
 434         e.stream_id       = stream_id;
 435         e.share_access    = share_access;
 436         e.access_mask     = access_mask;
 437         e.delete_on_close = delete_on_close;
 438         e.oplock_level    = OPLOCK_NONE;
 439
 440         /*
 441           possibly grant an exclusive, batch or level2 oplock
 442         */
 443         if (oplock_granted) {
 444                 if (attrs_only) {
 445                         e.oplock_level  = OPLOCK_NONE;
 446                         *oplock_granted = NO_OPLOCK_RETURN;
 447                 } else if (oplock_level == OPLOCK_EXCLUSIVE) {
 448                         if (file.num_entries == 0) {
 449                                 e.oplock_level  = OPLOCK_EXCLUSIVE;
 450                                 *oplock_granted = EXCLUSIVE_OPLOCK_RETURN;
 451                         } else {
 452                                 e.oplock_level  = OPLOCK_NONE;
 453                                 *oplock_granted = NO_OPLOCK_RETURN;
 454                         }
 455                 } else if (oplock_level == OPLOCK_BATCH) {
 456                         if (file.num_entries == 0) {
 457                                 e.oplock_level  = OPLOCK_BATCH;
 458                                 *oplock_granted = BATCH_OPLOCK_RETURN;
 459                         } else {
 460                                 e.oplock_level  = OPLOCK_LEVEL_II;
 461                                 *oplock_granted = LEVEL_II_OPLOCK_RETURN;
 462                         }
 463                 } else if (oplock_level == OPLOCK_LEVEL_II) {
 464                         e.oplock_level  = OPLOCK_LEVEL_II;
 465                         *oplock_granted = LEVEL_II_OPLOCK_RETURN;
 466                 } else {
 467                         e.oplock_level  = OPLOCK_NONE;
 468                         *oplock_granted = NO_OPLOCK_RETURN;
 469                 }
 470         }
 471
 472         /* it doesn't conflict, so add it to the end */
 473         file.entries = talloc_realloc(lck, file.entries, struct opendb_entry,
 474                                       file.num_entries+1);
 475         NT_STATUS_HAVE_NO_MEMORY(file.entries);
 476
 477         file.entries[file.num_entries] = e;
 478         file.num_entries++;
 479
 480         return odb_push_record(lck, &file);
 481 }
 482
 483
 484 /*
 485   register a pending open file in the open files database
 486 */
 487 static NTSTATUS odb_tdb_open_file_pending(struct odb_lock *lck, void *private)
 488 {
 489         struct odb_context *odb = lck->odb;
 490         struct opendb_file file;
 491         NTSTATUS status;
 492
 493         status = odb_pull_record(lck, &file);
 494         NT_STATUS_NOT_OK_RETURN(status);
 495
 496         file.pending = talloc_realloc(lck, file.pending, struct opendb_pending,
 497                                       file.num_pending+1);
 498         NT_STATUS_HAVE_NO_MEMORY(file.pending);
 499
 500         file.pending[file.num_pending].server = odb->ntvfs_ctx->server_id;
 501         file.pending[file.num_pending].notify_ptr = private;
 502
 503         file.num_pending++;
 504
 505         return odb_push_record(lck, &file);
 506 }
 507
 508
 509 /*
 510   remove a opendb entry
 511 */
 512 static NTSTATUS odb_tdb_close_file(struct odb_lock *lck, void *file_handle)
 513 {
 514         struct odb_context *odb = lck->odb;
 515         struct opendb_file file;
 516         int i;
 517         NTSTATUS status;
 518
 519         status = odb_pull_record(lck, &file);
 520         NT_STATUS_NOT_OK_RETURN(status);
 521
 522         /* find the entry, and delete it */
 523         for (i=0;i<file.num_entries;i++) {
 524                 if (file_handle == file.entries[i].file_handle &&
 525                     cluster_id_equal(&odb->ntvfs_ctx->server_id, &file.entries[i].server)) {
 526                         if (file.entries[i].delete_on_close) {
 527                                 file.delete_on_close = true;
 528                         }
 529                         if (i < file.num_entries-1) {
 530                                 memmove(file.entries+i, file.entries+i+1,
 531                                         (file.num_entries - (i+1)) *
 532                                         sizeof(struct opendb_entry));
 533                         }
 534                         break;
 535                 }
 536         }
 537
 538         if (i == file.num_entries) {
 539                 return NT_STATUS_UNSUCCESSFUL;
 540         }
 541
 542         /* send any pending notifications, removing them once sent */
 543         for (i=0;i<file.num_pending;i++) {
 544                 messaging_send_ptr(odb->ntvfs_ctx->msg_ctx, file.pending[i].server,
 545                                    MSG_PVFS_RETRY_OPEN,
 546                                    file.pending[i].notify_ptr);
 547         }
 548         file.num_pending = 0;
 549
 550         file.num_entries--;
 551
 552         return odb_push_record(lck, &file);
 553 }
 554
 555 /*
 556   update the oplock level of the client
 557 */
 558 static NTSTATUS odb_tdb_update_oplock(struct odb_lock *lck, void *file_handle,
 559                                       uint32_t oplock_level)
 560 {
 561         struct odb_context *odb = lck->odb;
 562         struct opendb_file file;
 563         int i;
 564         NTSTATUS status;
 565
 566         status = odb_pull_record(lck, &file);
 567         NT_STATUS_NOT_OK_RETURN(status);
 568
 569         /* find the entry, and update it */
 570         for (i=0;i<file.num_entries;i++) {
 571                 if (file_handle == file.entries[i].file_handle &&
 572                     cluster_id_equal(&odb->ntvfs_ctx->server_id, &file.entries[i].server)) {
 573                         file.entries[i].oplock_level = oplock_level;
 574                         break;
 575                 }
 576         }
 577
 578         if (i == file.num_entries) {
 579                 return NT_STATUS_UNSUCCESSFUL;
 580         }
 581
 582         /* send any pending notifications, removing them once sent */
 583         for (i=0;i<file.num_pending;i++) {
 584                 messaging_send_ptr(odb->ntvfs_ctx->msg_ctx,
 585                                    file.pending[i].server,
 586                                    MSG_PVFS_RETRY_OPEN,
 587                                    file.pending[i].notify_ptr);
 588         }
 589         file.num_pending = 0;
 590
 591         return odb_push_record(lck, &file);
 592 }
 593
 594 /*
 595   send oplocks breaks to none to all level2 holders
 596 */
 597 static NTSTATUS odb_tdb_break_oplocks(struct odb_lock *lck)
 598 {
 599         struct odb_context *odb = lck->odb;
 600         NTSTATUS status;
 601         struct opendb_file file;
 602         int i;
 603         bool modified = true;
 604
 605         status = odb_pull_record(lck, &file);
 606         if (NT_STATUS_EQUAL(status, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
 607                 return NT_STATUS_OK;
 608         }
 609         NT_STATUS_NOT_OK_RETURN(status);
 610
 611         /* see if anyone has an oplock, which we need to break */
 612         for (i=0;i<file.num_entries;i++) {
 613                 if (file.entries[i].oplock_level == OPLOCK_LEVEL_II) {
 614                         /*
 615                          * there could be multiple level2 oplocks
 616                          * and we just send a break to none to all of them
 617                          * without waiting for a release
 618                          */
 619                         odb_oplock_break_send(odb, &file.entries[i],
 620                                               OPLOCK_BREAK_TO_NONE);
 621                         file.entries[i].oplock_level = OPLOCK_NONE;
 622                         modified = true;
 623                 }
 624         }
 625
 626         if (modified) {
 627                 return odb_push_record(lck, &file);
 628         }
 629         return NT_STATUS_OK;
 630 }
 631
 632 /*
 633   remove a pending opendb entry
 634 */
 635 static NTSTATUS odb_tdb_remove_pending(struct odb_lock *lck, void *private)
 636 {
 637         struct odb_context *odb = lck->odb;
 638         int i;
 639         NTSTATUS status;
 640         struct opendb_file file;
 641
 642         status = odb_pull_record(lck, &file);
 643         NT_STATUS_NOT_OK_RETURN(status);
 644
 645         /* find the entry, and delete it */
 646         for (i=0;i<file.num_pending;i++) {
 647                 if (private == file.pending[i].notify_ptr &&
 648                     cluster_id_equal(&odb->ntvfs_ctx->server_id, &file.pending[i].server)) {
 649                         if (i < file.num_pending-1) {
 650                                 memmove(file.pending+i, file.pending+i+1,
 651                                         (file.num_pending - (i+1)) *
 652                                         sizeof(struct opendb_pending));
 653                         }
 654                         break;
 655                 }
 656         }
 657
 658         if (i == file.num_pending) {
 659                 return NT_STATUS_UNSUCCESSFUL;
 660         }
 661
 662         file.num_pending--;
 663
 664         return odb_push_record(lck, &file);
 665 }
 666
 667
 668 /*
 669   rename the path in a open file
 670 */
 671 static NTSTATUS odb_tdb_rename(struct odb_lock *lck, const char *path)
 672 {
 673         struct opendb_file file;
 674         NTSTATUS status;
 675
 676         status = odb_pull_record(lck, &file);
 677         if (NT_STATUS_EQUAL(NT_STATUS_OBJECT_NAME_NOT_FOUND, status)) {
 678                 /* not having the record at all is OK */
 679                 return NT_STATUS_OK;
 680         }
 681         NT_STATUS_NOT_OK_RETURN(status);
 682
 683         file.path = path;
 684         return odb_push_record(lck, &file);
 685 }
 686
 687 /*
 688   update delete on close flag on an open file
 689 */
 690 static NTSTATUS odb_tdb_set_delete_on_close(struct odb_lock *lck, bool del_on_close)
 691 {
 692         NTSTATUS status;
 693         struct opendb_file file;
 694
 695         status = odb_pull_record(lck, &file);
 696         NT_STATUS_NOT_OK_RETURN(status);
 697
 698         file.delete_on_close = del_on_close;
 699
 700         return odb_push_record(lck, &file);
 701 }
 702
 703 /*
 704   return the current value of the delete_on_close bit, and how many
 705   people still have the file open
 706 */
 707 static NTSTATUS odb_tdb_get_delete_on_close(struct odb_context *odb,
 708                                             DATA_BLOB *key, bool *del_on_close,
 709                                             int *open_count, char **path)
 710 {
 711         NTSTATUS status;
 712         struct opendb_file file;
 713         struct odb_lock *lck;
 714
 715         lck = odb_lock(odb, odb, key);
 716         NT_STATUS_HAVE_NO_MEMORY(lck);
 717
 718         status = odb_pull_record(lck, &file);
 719         if (NT_STATUS_EQUAL(NT_STATUS_OBJECT_NAME_NOT_FOUND, status)) {
 720                 talloc_free(lck);
 721                 (*del_on_close) = false;
 722                 return NT_STATUS_OK;
 723         }
 724         if (!NT_STATUS_IS_OK(status)) {
 725                 talloc_free(lck);
 726                 return status;
 727         }
 728
 729         (*del_on_close) = file.delete_on_close;
 730         if (open_count != NULL) {
 731                 (*open_count) = file.num_entries;
 732         }
 733         if (path != NULL) {
 734                 *path = talloc_strdup(odb, file.path);
 735                 NT_STATUS_HAVE_NO_MEMORY(*path);
 736                 if (file.num_entries == 1 && file.entries[0].delete_on_close) {
 737                         (*del_on_close) = true;
 738                 }
 739         }
 740
 741         talloc_free(lck);
 742
 743         return NT_STATUS_OK;
 744 }
 745
 746
 747 /*
 748   determine if a file can be opened with the given share_access,
 749   create_options and access_mask
 750 */
 751 static NTSTATUS odb_tdb_can_open(struct odb_lock *lck,
 752                                  uint32_t stream_id, uint32_t share_access,
 753                                  uint32_t access_mask, bool delete_on_close,
 754                                  uint32_t open_disposition, bool break_to_none)
 755 {
 756         struct odb_context *odb = lck->odb;
 757         NTSTATUS status;
 758         struct opendb_file file;
 759         bool attrs_only = false;
 760
 761         status = odb_pull_record(lck, &file);
 762         if (NT_STATUS_EQUAL(status, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
 763                 return NT_STATUS_OK;
 764         }
 765         NT_STATUS_NOT_OK_RETURN(status);
 766
 767         status = odb_tdb_open_can_internal(odb, &file, stream_id,
 768                                            share_access, access_mask,
 769                                            delete_on_close, open_disposition,
 770                                            break_to_none, &attrs_only);
 771         NT_STATUS_NOT_OK_RETURN(status);
 772
 773         return NT_STATUS_OK;
 774 }
 775
 776
 777 static const struct opendb_ops opendb_tdb_ops = {
 778         .odb_init                = odb_tdb_init,
 779         .odb_lock                = odb_tdb_lock,
 780         .odb_get_key             = odb_tdb_get_key,
 781         .odb_open_file           = odb_tdb_open_file,
 782         .odb_open_file_pending   = odb_tdb_open_file_pending,
 783         .odb_close_file          = odb_tdb_close_file,
 784         .odb_remove_pending      = odb_tdb_remove_pending,
 785         .odb_rename              = odb_tdb_rename,
 786         .odb_set_delete_on_close = odb_tdb_set_delete_on_close,
 787         .odb_get_delete_on_close = odb_tdb_get_delete_on_close,
 788         .odb_can_open            = odb_tdb_can_open,
 789         .odb_update_oplock       = odb_tdb_update_oplock,
 790         .odb_break_oplocks       = odb_tdb_break_oplocks
 791 };
 792
 793
 794 void odb_tdb_init_ops(void)
 795 {
 796         odb_set_ops(&opendb_tdb_ops);
 797 }