tdb_wrap: Remove tdb_wrap_open_ again
authorVolker Lendecke <vl@samba.org>
Wed, 26 Mar 2014 14:41:03 +0000 (14:41 +0000)
committerJeremy Allison <jra@samba.org>
Mon, 31 Mar 2014 20:52:14 +0000 (22:52 +0200)
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
15 files changed:
lib/dbwrap/dbwrap_tdb.c
lib/tdb_wrap/tdb_wrap.c
lib/tdb_wrap/tdb_wrap.h
source3/lib/dbwrap/dbwrap_ctdb.c
source3/lib/messages_local.c
source3/lib/server_mutex.c
source3/lib/serverid.c
source3/modules/vfs_posix_eadb.c
source4/dsdb/samdb/ldb_modules/partition_metadata.c
source4/dsdb/samdb/ldb_modules/schema_load.c
source4/lib/messaging/messaging.c
source4/ntvfs/posix/python/pyposix_eadb.c
source4/ntvfs/posix/vfs_posix.c
source4/param/secrets.c
source4/torture/local/dbspeed.c

index 82a9916e2f9c665516acfa5c373210da86f664e7..a76d90f10bc5850b8dd39048746d7a2f6335d30b 100644 (file)
@@ -432,9 +432,9 @@ struct db_context *db_open_tdb(TALLOC_CTX *mem_ctx,
                hash_size = lpcfg_tdb_hash_size(lp_ctx, name);
        }
 
-       db_tdb->wtdb = tdb_wrap_open_(db_tdb, name, hash_size,
-                                     lpcfg_tdb_flags(lp_ctx, tdb_flags),
-                                     open_flags, mode);
+       db_tdb->wtdb = tdb_wrap_open(db_tdb, name, hash_size,
+                                    lpcfg_tdb_flags(lp_ctx, tdb_flags),
+                                    open_flags, mode);
        if (db_tdb->wtdb == NULL) {
                DEBUG(3, ("Could not open tdb: %s\n", strerror(errno)));
                goto fail;
index cf24b97e796072dd67618ca5089d33252380da16..970c91f1c7269b040ae2cd6afd34618afa44a133 100644 (file)
@@ -123,9 +123,9 @@ fail:
   wrapped connection to a tdb database
   to close just talloc_free() the tdb_wrap pointer
  */
-struct tdb_wrap *tdb_wrap_open_(TALLOC_CTX *mem_ctx,
-                               const char *name, int hash_size, int tdb_flags,
-                               int open_flags, mode_t mode)
+struct tdb_wrap *tdb_wrap_open(TALLOC_CTX *mem_ctx,
+                              const char *name, int hash_size, int tdb_flags,
+                              int open_flags, mode_t mode)
 {
        struct tdb_wrap *result;
        struct tdb_wrap_private *w;
@@ -175,29 +175,3 @@ fail:
        TALLOC_FREE(result);
        return NULL;
 }
-
-struct tdb_wrap *tdb_wrap_open(TALLOC_CTX *mem_ctx,
-                              const char *name, int hash_size, int tdb_flags,
-                              int open_flags, mode_t mode,
-                              struct loadparm_context *lp_ctx)
-{
-       if (!lpcfg_use_mmap(lp_ctx)) {
-               tdb_flags |= TDB_NOMMAP;
-       }
-
-       if ((hash_size == 0) && (name != NULL)) {
-               const char *base;
-               base = strrchr_m(name, '/');
-
-               if (base != NULL) {
-                       base += 1;
-               } else {
-                       base = name;
-               }
-               hash_size = lpcfg_parm_int(lp_ctx, NULL,
-                                          "tdb_hashsize", base, 0);
-       }
-
-       return tdb_wrap_open_(mem_ctx, name, hash_size, tdb_flags, open_flags,
-                             mode);
-}
index 54d9a0a72e66922dafcb99ce4d7c19635e5e2959..e44aed684f62b8bcd49c883d8930d0508d879324 100644 (file)
@@ -37,12 +37,8 @@ struct tdb_wrap {
 
 struct loadparm_context;
 
-struct tdb_wrap *tdb_wrap_open_(TALLOC_CTX *mem_ctx,
-                               const char *name, int hash_size, int tdb_flags,
-                               int open_flags, mode_t mode);
 struct tdb_wrap *tdb_wrap_open(TALLOC_CTX *mem_ctx,
                               const char *name, int hash_size, int tdb_flags,
-                              int open_flags, mode_t mode,
-                              struct loadparm_context *lp_ctx);
+                              int open_flags, mode_t mode);
 
 #endif /* _TDB_WRAP_H_ */
index 32d044628d13e092f2947b8e5ef7a8b0e42539e4..7cf90cebdf885dc5711e0df5f353856fd836a4ef 100644 (file)
@@ -1665,9 +1665,9 @@ struct db_context *db_open_ctdb(TALLOC_CTX *mem_ctx,
                hash_size = lpcfg_tdb_hash_size(lp_ctx, db_path);
        }
 
-       db_ctdb->wtdb = tdb_wrap_open_(db_ctdb, db_path, hash_size,
-                                      lpcfg_tdb_flags(lp_ctx, tdb_flags),
-                                      O_RDWR, 0);
+       db_ctdb->wtdb = tdb_wrap_open(db_ctdb, db_path, hash_size,
+                                     lpcfg_tdb_flags(lp_ctx, tdb_flags),
+                                     O_RDWR, 0);
        talloc_unlink(db_path, lp_ctx);
        if (db_ctdb->wtdb == NULL) {
                DEBUG(0, ("Could not open tdb %s: %s\n", db_path, strerror(errno)));
index 1a3f3b27f24809ff1cabd95bd51b3f46738c681b..1fe89c3bfaacf013a80ff16d938a012a1c264ba7 100644 (file)
@@ -125,7 +125,7 @@ NTSTATUS messaging_tdb_init(struct messaging_context *msg_ctx,
 
        fname = lock_path("messages.tdb");
 
-       ctx->tdb = tdb_wrap_open_(
+       ctx->tdb = tdb_wrap_open(
                ctx, fname, lpcfg_tdb_hash_size(lp_ctx, fname),
                lpcfg_tdb_flags(lp_ctx, TDB_CLEAR_IF_FIRST|TDB_DEFAULT|
                                TDB_VOLATILE| TDB_INCOMPATIBLE_HASH),
@@ -189,7 +189,7 @@ bool messaging_tdb_parent_init(TALLOC_CTX *mem_ctx)
         */
 
        fname = lock_path("messages.tdb");
-       db = tdb_wrap_open_(
+       db = tdb_wrap_open(
                mem_ctx, fname, lpcfg_tdb_hash_size(lp_ctx, fname),
                lpcfg_tdb_flags(lp_ctx, TDB_CLEAR_IF_FIRST|TDB_DEFAULT|
                                TDB_VOLATILE|TDB_INCOMPATIBLE_HASH),
index 24a301bde97a0ddd8b13d5eb754cd604303a192c..43cf77b94d9fabcab1298a97a475e9cfac0004fa 100644 (file)
@@ -72,13 +72,13 @@ struct named_mutex *grab_named_mutex(TALLOC_CTX *mem_ctx, const char *name,
 
        fname = lock_path("mutex.tdb");
 
-       result->tdb = tdb_wrap_open_(result, fname,
-                                    lpcfg_tdb_hash_size(lp_ctx, fname),
-                                    lpcfg_tdb_flags(lp_ctx,
-                                                    TDB_DEFAULT |
-                                                    TDB_CLEAR_IF_FIRST |
-                                                    TDB_INCOMPATIBLE_HASH),
-                                    O_RDWR|O_CREAT, 0600);
+       result->tdb = tdb_wrap_open(result, fname,
+                                   lpcfg_tdb_hash_size(lp_ctx, fname),
+                                   lpcfg_tdb_flags(lp_ctx,
+                                                   TDB_DEFAULT |
+                                                   TDB_CLEAR_IF_FIRST |
+                                                   TDB_INCOMPATIBLE_HASH),
+                                   O_RDWR|O_CREAT, 0600);
        talloc_unlink(result, lp_ctx);
        if (result->tdb == NULL) {
                DEBUG(1, ("Could not open mutex.tdb: %s\n",
index 4253da6378a6813e921f17e5866c067cd32090b9..48b09f71f50ec6172ece7264934bf5c6a36f756f 100644 (file)
@@ -59,12 +59,12 @@ bool serverid_parent_init(TALLOC_CTX *mem_ctx)
 
        fname = lock_path("serverid.tdb");
 
-       db = tdb_wrap_open_(mem_ctx, fname,
-                           lpcfg_tdb_hash_size(lp_ctx, fname),
-                           lpcfg_tdb_flags(lp_ctx,
-                                           TDB_DEFAULT|TDB_CLEAR_IF_FIRST|
-                                           TDB_INCOMPATIBLE_HASH),
-                           O_RDWR|O_CREAT, 0644);
+       db = tdb_wrap_open(mem_ctx, fname,
+                          lpcfg_tdb_hash_size(lp_ctx, fname),
+                          lpcfg_tdb_flags(lp_ctx,
+                                          TDB_DEFAULT|TDB_CLEAR_IF_FIRST|
+                                          TDB_INCOMPATIBLE_HASH),
+                          O_RDWR|O_CREAT, 0644);
        talloc_unlink(mem_ctx, lp_ctx);
        if (db == NULL) {
                DEBUG(1, ("could not open serverid.tdb: %s\n",
index 7f65beafc489852a8f88a5e66b5f7be28415c36e..27996db73db0a9ce4a7cb50fea7ddb292fb27791 100644 (file)
@@ -256,9 +256,9 @@ static bool posix_eadb_init(int snum, struct tdb_wrap **p_db)
        lp_ctx = loadparm_init_s3(NULL, loadparm_s3_helpers());
 
        become_root();
-       db = tdb_wrap_open_(NULL, eadb, 50000,
-                           lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
-                           O_RDWR|O_CREAT, 0600);
+       db = tdb_wrap_open(NULL, eadb, 50000,
+                          lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
+                          O_RDWR|O_CREAT, 0600);
 
        unbecome_root();
        talloc_unlink(NULL, lp_ctx);
index 8441b13d472ab0ed899544b07bcc5b361f404421..1db800ec6af1d8677004877f123024480fb94f84 100644 (file)
@@ -240,7 +240,7 @@ static int partition_metadata_open(struct ldb_module *module, bool create)
        lp_ctx = talloc_get_type_abort(ldb_get_opaque(ldb, "loadparm"),
                                       struct loadparm_context);
 
-       data->metadata->db = tdb_wrap_open_(
+       data->metadata->db = tdb_wrap_open(
                data->metadata, filename, 10,
                lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT), open_flags, 0660);
        if (data->metadata->db == NULL) {
index 2e9eb5cad6e01604d8d115c7eb3abb541139f5f9..25a780150a88b2e87ac1b81116717da847a8da24 100644 (file)
@@ -90,9 +90,9 @@ static int schema_metadata_open(struct ldb_module *module)
        lp_ctx = talloc_get_type_abort(ldb_get_opaque(ldb, "loadparm"),
                                       struct loadparm_context);
 
-       data->metadata = tdb_wrap_open_(data, filename, 10,
-                                       lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
-                                       open_flags, 0660);
+       data->metadata = tdb_wrap_open(data, filename, 10,
+                                      lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
+                                      open_flags, 0660);
        if (data->metadata == NULL) {
                talloc_free(tmp_ctx);
                return LDB_ERR_OPERATIONS_ERROR;
index e182acd83c3672cbd2212f5ef5954d5ba02a780b..ba1c5bd727cc606d10aeb99e96d2d3e24e2fa978 100644 (file)
@@ -899,10 +899,10 @@ static struct tdb_wrap *irpc_namedb_open(struct imessaging_context *msg_ctx)
        if (path == NULL) {
                return NULL;
        }
-       t = tdb_wrap_open_(msg_ctx, path,
-                          lpcfg_tdb_hash_size(msg_ctx->lp_ctx, path),
-                          lpcfg_tdb_flags(msg_ctx->lp_ctx, 0),
-                          O_RDWR|O_CREAT, 0660);
+       t = tdb_wrap_open(msg_ctx, path,
+                         lpcfg_tdb_hash_size(msg_ctx->lp_ctx, path),
+                         lpcfg_tdb_flags(msg_ctx->lp_ctx, 0),
+                         O_RDWR|O_CREAT, 0660);
        talloc_free(path);
        return t;
 }
index c04d329f141e1a5bedc21d10566440030029f08a..9db0ddb770b1b65294bd0809f4eabb2ef81f1d25 100644 (file)
@@ -50,7 +50,7 @@ static PyObject *py_wrap_setxattr(PyObject *self, PyObject *args)
 
        blob.length = blobsize;
        mem_ctx = talloc_new(NULL);
-       eadb = tdb_wrap_open_(
+       eadb = tdb_wrap_open(
                mem_ctx, tdbname, 50000,
                lpcfg_tdb_flags(py_default_loadparm_context(mem_ctx),
                                TDB_DEFAULT),
@@ -85,7 +85,7 @@ static PyObject *py_wrap_getxattr(PyObject *self, PyObject *args)
                return NULL;
 
        mem_ctx = talloc_new(NULL);
-       eadb = tdb_wrap_open_(
+       eadb = tdb_wrap_open(
                mem_ctx, tdbname, 50000,
                lpcfg_tdb_flags(py_default_loadparm_context(mem_ctx),
                                TDB_DEFAULT),
index a9ba44f20bf8b12020ae2e349622e6053d3d6cec..304a9ff8fe58063c12c69c93079fac417dd28fb9 100644 (file)
@@ -120,7 +120,7 @@ static void pvfs_setup_options(struct pvfs_state *pvfs)
        /* allow xattrs to be stored in a external tdb */
        eadb = share_string_option(pvfs, scfg, PVFS_EADB, NULL);
        if (eadb != NULL) {
-               pvfs->ea_db = tdb_wrap_open_(
+               pvfs->ea_db = tdb_wrap_open(
                        pvfs, eadb, 50000,
                        lpcfg_tdb_flags(pvfs->ntvfs->ctx->lp_ctx, TDB_DEFAULT),
                        O_RDWR|O_CREAT, 0600);
index e27524e231b41d80e99fceafa515980051c94ba3..92e338a6baba2b8872f255a763899effc0d418af 100644 (file)
@@ -59,10 +59,10 @@ bool randseed_init(TALLOC_CTX *mem_ctx, struct loadparm_context *lp_ctx)
 
        fname = lpcfg_private_path(mem_ctx, lp_ctx, "randseed.tdb");
 
-       tdb = tdb_wrap_open_(mem_ctx, fname,
-                            lpcfg_tdb_hash_size(lp_ctx, fname),
-                            lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
-                            O_RDWR|O_CREAT, 0600);
+       tdb = tdb_wrap_open(mem_ctx, fname,
+                           lpcfg_tdb_hash_size(lp_ctx, fname),
+                           lpcfg_tdb_flags(lp_ctx, TDB_DEFAULT),
+                           O_RDWR|O_CREAT, 0600);
 
        if (!tdb) {
                DEBUG(0,("Failed to open %s\n", fname));
index 27d1e0ce15ee41c7330c3361125ee66c659e1ea0..185faecd96357d241d21187046384878b6c9978d 100644 (file)
@@ -64,9 +64,9 @@ static bool test_tdb_speed(struct torture_context *torture, const void *_data)
 
        torture_comment(torture, "Testing tdb speed for sidmap\n");
 
-       tdbw = tdb_wrap_open_(tmp_ctx, "test.tdb", 10000,
-                             lpcfg_tdb_flags(torture->lp_ctx, 0),
-                             O_RDWR|O_CREAT|O_TRUNC, 0600);
+       tdbw = tdb_wrap_open(tmp_ctx, "test.tdb", 10000,
+                            lpcfg_tdb_flags(torture->lp_ctx, 0),
+                            O_RDWR|O_CREAT|O_TRUNC, 0600);
        if (!tdbw) {
                torture_result(torture, TORTURE_FAIL, "Failed to open test.tdb");
                goto failed;