source4/dsdb/samdb/ldb_modules/lazy_commit.c

   1 /*
   2    ldb database library
   3
   4    Copyright (C) Andrew Bartlett <abartlet@samba.org> 2009
   5
   6    This program is free software; you can redistribute it and/or modify
   7    it under the terms of the GNU General Public License as published by
   8    the Free Software Foundation; either version 3 of the License, or
   9    (at your option) any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  15
  16    You should have received a copy of the GNU General Public License
  17    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18 */
  19
  20 /*
  21  *  Name: ldb
  22  *
  23  *  Component: ldb lazy_commit module
  24  *
  25  *  Description: module to pretend to support the 'lazy commit' control
  26  *
  27  *  Author: Andrew Bartlett
  28  */
  29
  30 #include "includes.h"
  31 #include "ldb_module.h"
  32 #include "dsdb/samdb/ldb_modules/util.h"
  33
  34 static int unlazy_op(struct ldb_module *module, struct ldb_request *req)
  35 {
  36         int ret;
  37         struct ldb_request *new_req;
  38         struct ldb_control *control = ldb_request_get_control(req, LDB_CONTROL_SERVER_LAZY_COMMIT);
  39         if (!control) {
  40                 return ldb_next_request(module, req);
  41         }
  42
  43         switch (req->operation) {
  44         case LDB_SEARCH:
  45                 ret = ldb_build_search_req_ex(&new_req, ldb_module_get_ctx(module),
  46                                               req,
  47                                               req->op.search.base,
  48                                               req->op.search.scope,
  49                                               req->op.search.tree,
  50                                               req->op.search.attrs,
  51                                               req->controls,
  52                                               req, dsdb_next_callback,
  53                                               req);
  54                 ldb_req_mark_trusted(new_req);
  55                 LDB_REQ_SET_LOCATION(new_req);
  56                 break;
  57         case LDB_ADD:
  58                 ret = ldb_build_add_req(&new_req, ldb_module_get_ctx(module), req,
  59                                         req->op.add.message,
  60                                         req->controls,
  61                                         req, dsdb_next_callback,
  62                                         req);
  63                 LDB_REQ_SET_LOCATION(new_req);
  64                 break;
  65         case LDB_MODIFY:
  66                 ret = ldb_build_mod_req(&new_req, ldb_module_get_ctx(module), req,
  67                                         req->op.mod.message,
  68                                         req->controls,
  69                                         req, dsdb_next_callback,
  70                                         req);
  71                 LDB_REQ_SET_LOCATION(new_req);
  72                 break;
  73         case LDB_DELETE:
  74                 ret = ldb_build_del_req(&new_req, ldb_module_get_ctx(module), req,
  75                                         req->op.del.dn,
  76                                         req->controls,
  77                                         req, dsdb_next_callback,
  78                                         req);
  79                 LDB_REQ_SET_LOCATION(new_req);
  80                 break;
  81         case LDB_RENAME:
  82                 ret = ldb_build_rename_req(&new_req, ldb_module_get_ctx(module), req,
  83                                            req->op.rename.olddn,
  84                                            req->op.rename.newdn,
  85                                            req->controls,
  86                                            req, dsdb_next_callback,
  87                                            req);
  88                 LDB_REQ_SET_LOCATION(new_req);
  89                 break;
  90         case LDB_EXTENDED:
  91                 ret = ldb_build_extended_req(&new_req, ldb_module_get_ctx(module),
  92                                              req,
  93                                              req->op.extended.oid,
  94                                              req->op.extended.data,
  95                                              req->controls,
  96                                              req, dsdb_next_callback,
  97                                              req);
  98                 LDB_REQ_SET_LOCATION(new_req);
  99                 break;
 100         default:
 101                 ldb_set_errstring(ldb_module_get_ctx(module),
 102                                   "Unsupported request type!");
 103                 ret = LDB_ERR_UNWILLING_TO_PERFORM;
 104         }
 105
 106         if (ret != LDB_SUCCESS) {
 107                 return ret;
 108         }
 109
 110         control->critical = 0;
 111         return ldb_next_request(module, new_req);
 112 }
 113
 114 static const struct ldb_module_ops ldb_lazy_commit_module_ops = {
 115         .name              = "lazy_commit",
 116         .search            = unlazy_op,
 117         .add               = unlazy_op,
 118         .modify            = unlazy_op,
 119         .del               = unlazy_op,
 120         .rename            = unlazy_op,
 121         .request           = unlazy_op,
 122         .extended          = unlazy_op,
 123 };
 124
 125 int ldb_lazy_commit_module_init(const char *version)
 126 {
 127         LDB_MODULE_CHECK_VERSION(version);
 128         return ldb_register_module(&ldb_lazy_commit_module_ops);
 129 }