Convert dbwrap_trans_store to NTSTATUS
authorVolker Lendecke <vl@samba.org>
Fri, 28 Mar 2008 10:53:00 +0000 (11:53 +0100)
committerStefan Metzmacher <metze@samba.org>
Tue, 1 Apr 2008 12:04:22 +0000 (14:04 +0200)
Signed-off-by: Stefan Metzmacher <metze@samba.org>
(This used to be commit 5f4de856af1abe63b13059bbe1615cb5877770d0)

source3/groupdb/mapping_tdb.c
source3/lib/dbwrap_util.c
source3/lib/sharesec.c
source3/passdb/secrets.c
source3/registry/reg_backend_db.c

index e2aa06c8ffd022b803433cef30ac1fbd8fb17ab4..718804b1e5731dc6e6d2d5b89ce4c4fc044af7e0 100644 (file)
@@ -123,7 +123,7 @@ static bool add_mapping_entry(GROUP_MAP *map, int flag)
 {
        char *key, *buf;
        int len;
 {
        char *key, *buf;
        int len;
-       int res;
+       NTSTATUS status;
 
        key = group_mapping_key(talloc_tos(), &map->sid);
        if (key == NULL) {
 
        key = group_mapping_key(talloc_tos(), &map->sid);
        if (key == NULL) {
@@ -141,13 +141,13 @@ static bool add_mapping_entry(GROUP_MAP *map, int flag)
        len = tdb_pack((uint8 *)buf, len, "ddff", map->gid,
                       map->sid_name_use, map->nt_name, map->comment);
 
        len = tdb_pack((uint8 *)buf, len, "ddff", map->gid,
                       map->sid_name_use, map->nt_name, map->comment);
 
-       res = dbwrap_trans_store(
+       status = dbwrap_trans_store(
                db, string_term_tdb_data(key),
                make_tdb_data((uint8_t *)buf, len), flag);
 
        TALLOC_FREE(key);
 
                db, string_term_tdb_data(key),
                make_tdb_data((uint8_t *)buf, len), flag);
 
        TALLOC_FREE(key);
 
-       return (res == 0);
+       return NT_STATUS_IS_OK(status);
 }
 
 
 }
 
 
index 01d70556d825d7296506f2b253804b063b6a359a..1a636cc8a6fc834bb508e479eb5e1df4213f942b 100644 (file)
@@ -156,8 +156,8 @@ int32 dbwrap_change_int32_atomic(struct db_context *db, const char *keystr,
        return 0;
 }
 
        return 0;
 }
 
-int dbwrap_trans_store(struct db_context *db, TDB_DATA key, TDB_DATA dbuf,
-                      int flag)
+NTSTATUS dbwrap_trans_store(struct db_context *db, TDB_DATA key, TDB_DATA dbuf,
+                           int flag)
 {
        int res;
        struct db_record *rec;
 {
        int res;
        struct db_record *rec;
@@ -166,12 +166,13 @@ int dbwrap_trans_store(struct db_context *db, TDB_DATA key, TDB_DATA dbuf,
        res = db->transaction_start(db);
        if (res != 0) {
                DEBUG(5, ("transaction_start failed\n"));
        res = db->transaction_start(db);
        if (res != 0) {
                DEBUG(5, ("transaction_start failed\n"));
-               return res;
+               return NT_STATUS_INTERNAL_DB_CORRUPTION;
        }
 
        rec = db->fetch_locked(db, talloc_tos(), key);
        if (rec == NULL) {
                DEBUG(5, ("fetch_locked failed\n"));
        }
 
        rec = db->fetch_locked(db, talloc_tos(), key);
        if (rec == NULL) {
                DEBUG(5, ("fetch_locked failed\n"));
+               status = NT_STATUS_NO_MEMORY;
                goto cancel;
        }
 
                goto cancel;
        }
 
@@ -186,15 +187,17 @@ int dbwrap_trans_store(struct db_context *db, TDB_DATA key, TDB_DATA dbuf,
        res = db->transaction_commit(db);
        if (res != 0) {
                DEBUG(5, ("tdb_transaction_commit failed\n"));
        res = db->transaction_commit(db);
        if (res != 0) {
                DEBUG(5, ("tdb_transaction_commit failed\n"));
+               status = NT_STATUS_INTERNAL_DB_CORRUPTION;
+               goto cancel;
        }
 
        }
 
-       return res;
+       return NT_STATUS_OK;
 
  cancel:
        if (db->transaction_cancel(db) != 0) {
                smb_panic("Cancelling transaction failed");
        }
 
  cancel:
        if (db->transaction_cancel(db) != 0) {
                smb_panic("Cancelling transaction failed");
        }
-       return -1;
+       return status;
 }
 
 int dbwrap_trans_delete(struct db_context *db, TDB_DATA key)
 }
 
 int dbwrap_trans_delete(struct db_context *db, TDB_DATA key)
@@ -237,17 +240,15 @@ int dbwrap_trans_delete(struct db_context *db, TDB_DATA key)
        return -1;
 }
 
        return -1;
 }
 
-int dbwrap_trans_store_int32(struct db_context *db, const char *keystr, int32_t v)
+NTSTATUS dbwrap_trans_store_int32(struct db_context *db, const char *keystr,
+                                 int32_t v)
 {
 {
-       int ret;
        int32 v_store;
 
        SIVAL(&v_store, 0, v);
 
        int32 v_store;
 
        SIVAL(&v_store, 0, v);
 
-       ret = dbwrap_trans_store(db, string_term_tdb_data(keystr),
-                                make_tdb_data((const uint8 *)&v_store,
+       return dbwrap_trans_store(db, string_term_tdb_data(keystr),
+                                 make_tdb_data((const uint8 *)&v_store,
                                                sizeof(v_store)),
                                                sizeof(v_store)),
-                                TDB_REPLACE);
-
-       return ret;
+                                 TDB_REPLACE);
 }
 }
index 3d9e6083874431a9c08b536ea91690f90526bf20..33141a967174d17f0e039b22137387ae1f1f4698 100644 (file)
@@ -229,10 +229,11 @@ bool set_share_security(const char *share_name, SEC_DESC *psd)
                goto out;
        }
 
                goto out;
        }
 
-       if (dbwrap_trans_store(share_db, string_term_tdb_data(key), blob,
-                              TDB_REPLACE) == -1) {
-               DEBUG(1,("set_share_security: Failed to store secdesc for "
-                        "%s\n", share_name ));
+       status = dbwrap_trans_store(share_db, string_term_tdb_data(key), blob,
+                                   TDB_REPLACE);
+       if (!NT_STATUS_IS_OK(status)) {
+               DEBUG(1, ("set_share_security: Failed to store secdesc for "
+                         "%s: %s\n", share_name, nt_errstr(status)));
                goto out;
        }
 
                goto out;
        }
 
index 8d08d90dcf78b2adfda5b4f8b049e1e637724bd0..71db81c0e42fd22ac126189892f19342e9c89a18 100644 (file)
@@ -140,13 +140,16 @@ void *secrets_fetch(const char *key, size_t *size)
  */
 bool secrets_store(const char *key, const void *data, size_t size)
 {
  */
 bool secrets_store(const char *key, const void *data, size_t size)
 {
+       NTSTATUS status;
+
        if (!secrets_init()) {
                return false;
        }
 
        if (!secrets_init()) {
                return false;
        }
 
-       return dbwrap_trans_store(db_ctx, string_tdb_data(key),
-                                 make_tdb_data((const uint8 *)data, size),
-                                 TDB_REPLACE) == 0;
+       status = dbwrap_trans_store(db_ctx, string_tdb_data(key),
+                                   make_tdb_data((const uint8 *)data, size),
+                                   TDB_REPLACE);
+       return NT_STATUS_IS_OK(status);
 }
 
 
 }
 
 
index 716207dbaab754bc4029a4595f89f3f1426d5a46..4b8a4b4c374becd8a49678feb25795056beb2188 100644 (file)
@@ -349,12 +349,14 @@ bool regdb_init(void)
        vers_id = dbwrap_fetch_int32(regdb, vstring);
 
        if ( vers_id != REGVER_V1 ) {
        vers_id = dbwrap_fetch_int32(regdb, vstring);
 
        if ( vers_id != REGVER_V1 ) {
+               NTSTATUS status;
                /* any upgrade code here if needed */
                DEBUG(10, ("regdb_init: got %s = %d != %d\n", vstring,
                           vers_id, REGVER_V1));
                /* any upgrade code here if needed */
                DEBUG(10, ("regdb_init: got %s = %d != %d\n", vstring,
                           vers_id, REGVER_V1));
-               if (dbwrap_trans_store_int32(regdb, vstring, REGVER_V1) != 0) {
-                       DEBUG(0, ("regdb_init: error storing %s = %d\n",
-                                 vstring, REGVER_V1));
+               status = dbwrap_trans_store_int32(regdb, vstring, REGVER_V1);
+               if (!NT_STATUS_IS_OK(status)) {
+                       DEBUG(0, ("regdb_init: error storing %s = %d: %s\n",
+                                 vstring, REGVER_V1, nt_errstr(status)));
                        return false;
                } else {
                        DEBUG(10, ("regdb_init: stored %s = %d\n",
                        return false;
                } else {
                        DEBUG(10, ("regdb_init: stored %s = %d\n",
@@ -881,7 +883,8 @@ bool regdb_store_values( const char *key, REGVAL_CTR *values )
        TDB_DATA old_data, data;
        char *keystr = NULL;
        TALLOC_CTX *ctx = talloc_stackframe();
        TDB_DATA old_data, data;
        char *keystr = NULL;
        TALLOC_CTX *ctx = talloc_stackframe();
-       int len, ret;
+       int len;
+       NTSTATUS status;
        bool result = false;
 
        DEBUG(10,("regdb_store_values: Looking for value of key [%s] \n", key));
        bool result = false;
 
        DEBUG(10,("regdb_store_values: Looking for value of key [%s] \n", key));
@@ -920,9 +923,10 @@ bool regdb_store_values( const char *key, REGVAL_CTR *values )
                goto done;
        }
 
                goto done;
        }
 
-       ret = dbwrap_trans_store(regdb, string_term_tdb_data(keystr), data,
-                                TDB_REPLACE);
-       result = (ret != -1);
+       status = dbwrap_trans_store(regdb, string_term_tdb_data(keystr), data,
+                                   TDB_REPLACE);
+
+       result = NT_STATUS_IS_OK(status);
 
 done:
        TALLOC_FREE(ctx);
 
 done:
        TALLOC_FREE(ctx);
@@ -972,6 +976,7 @@ static WERROR regdb_set_secdesc(const char *key,
 {
        TALLOC_CTX *mem_ctx = talloc_stackframe();
        char *tdbkey;
 {
        TALLOC_CTX *mem_ctx = talloc_stackframe();
        char *tdbkey;
+       NTSTATUS status;
        WERROR err = WERR_NOMEM;
        TDB_DATA tdbdata;
        int tdb_ret;
        WERROR err = WERR_NOMEM;
        TDB_DATA tdbdata;
        int tdb_ret;
@@ -1001,10 +1006,10 @@ static WERROR regdb_set_secdesc(const char *key,
                goto done;
        }
 
                goto done;
        }
 
-       tdb_ret = dbwrap_trans_store(regdb, string_term_tdb_data(tdbkey),
-                                    tdbdata, 0);
-       if (tdb_ret != 0) {
-               err = ntstatus_to_werror(map_nt_error_from_unix(errno));
+       status = dbwrap_trans_store(regdb, string_term_tdb_data(tdbkey),
+                                   tdbdata, 0);
+       if (!NT_STATUS_IS_OK(status)) {
+               err = ntstatus_to_werror(status);
                goto done;
        }
 
                goto done;
        }