sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-23 17:34:34 +03:00
Code

s3: test dbwrap_ctdb

Browse Source 
Reviewed-by: Michael Adam <obnox@samba.org>
This commit is contained in:
Volker Lendecke 2012-11-07 21:24:27 +01:00 committed by Michael Adam
parent 8300791a67
commit 24c36e7484
5 changed files with 153 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source3/Makefile.in
View File

@ -1267,6 +1267,7 @@ SMBTORTURE_OBJ1 = torture/torture.o torture/nbio.o torture/scanner.o torture/uta
torture/test_notify.o \
torture/test_dbwrap_watch.o \
torture/test_idmap_tdb_common.o \
torture/test_dbwrap_ctdb.o \
torture/t_strappend.o
SMBTORTURE_OBJ = $(SMBTORTURE_OBJ1) $(PARAM_OBJ) $(TLDAP_OBJ) \

1
source3/torture/proto.h
View File

@ -110,5 +110,6 @@ bool run_notify_bench2(int dummy);
bool run_notify_bench3(int dummy);
bool run_dbwrap_watch1(int dummy);
bool run_idmap_tdb_common_test(int dummy);
bool run_local_dbwrap_ctdb(int dummy);
#endif /* __TORTURE_H__ */

149
source3/torture/test_dbwrap_ctdb.c Normal file
View File

@ -0,0 +1,149 @@
/*
* Unix SMB/CIFS implementation.
* Test dbwrap_ctdb API
* Copyright (C) Volker Lendecke 2012
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "includes.h"
#include "torture/proto.h"
#include "system/filesys.h"
#include "lib/dbwrap/dbwrap.h"
#include "lib/dbwrap/dbwrap_ctdb.h"
bool run_local_dbwrap_ctdb(int dummy)
{
struct db_context *db;
int res;
bool ret = false;
NTSTATUS status;
uint32_t val;
db = db_open_ctdb(talloc_tos(), "torture.tdb", 0, TDB_DEFAULT,
O_RDWR, 0755, DBWRAP_LOCK_ORDER_1);
if (db == NULL) {
perror("db_open_ctdb failed");
goto fail;
}
res = dbwrap_transaction_start(db);
if (res != 0) {
fprintf(stderr, "dbwrap_transaction_start failed");
goto fail;
}
res = dbwrap_transaction_cancel(db);
if (res != 0) {
fprintf(stderr, "dbwrap_transaction_cancel failed");
goto fail;
}
res = dbwrap_transaction_start(db);
if (res != 0) {
fprintf(stderr, "dbwrap_transaction_start failed");
goto fail;
}
status = dbwrap_store_uint32_bystring(db, "foo", 1);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "store_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
status = dbwrap_fetch_uint32_bystring(db, "foo", &val);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "fetch_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
if (val != 1) {
fprintf(stderr, "fetch_uint32 gave %u, expected 1",
(unsigned)val);
goto fail;
}
status = dbwrap_store_uint32_bystring(db, "bar", 5);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "store_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
status = dbwrap_fetch_uint32_bystring(db, "bar", &val);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "fetch_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
if (val != 5) {
fprintf(stderr, "fetch_uint32 gave %u, expected 5",
(unsigned)val);
goto fail;
}
status = dbwrap_store_uint32_bystring(db, "foo", 2);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "store_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
status = dbwrap_fetch_uint32_bystring(db, "foo", &val);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "fetch_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
if (val != 2) {
fprintf(stderr, "fetch_uint32 gave %u, expected 2",
(unsigned)val);
goto fail;
}
res = dbwrap_transaction_commit(db);
if (res != 0) {
fprintf(stderr, "dbwrap_transaction_commit failed");
goto fail;
}
/*
* check that the values have reached the disk
*/
status = dbwrap_fetch_uint32_bystring(db, "foo", &val);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "fetch_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
if (val != 2) {
fprintf(stderr, "fetch_uint32 gave %u, expected 1",
(unsigned)val);
goto fail;
}
status = dbwrap_fetch_uint32_bystring(db, "bar", &val);
if (!NT_STATUS_IS_OK(status)) {
fprintf(stderr, "fetch_uint32 failed: %s\n",
nt_errstr(status));
goto fail;
}
if (val != 5) {
fprintf(stderr, "fetch_uint32 gave %u, expected 1",
(unsigned)val);
goto fail;
}
ret = true;
fail:
TALLOC_FREE(db);
return ret;
}

1
source3/torture/torture.c
View File

@ -9150,6 +9150,7 @@ static struct {
{ "LOCAL-remove_duplicate_addrs2", run_local_remove_duplicate_addrs2, 0},
{ "local-tdb-opener", run_local_tdb_opener, 0 },
{ "local-tdb-writer", run_local_tdb_writer, 0 },
{ "LOCAL-DBWRAP-CTDB", run_local_dbwrap_ctdb, 0 },
{NULL, NULL, 0}};

1
source3/wscript_build
View File

@ -557,6 +557,7 @@ SMBTORTURE_SRC1 = '''torture/torture.c torture/nbio.c torture/scanner.c torture/
lib/tevent_barrier.c
torture/test_dbwrap_watch.c
torture/test_idmap_tdb_common.c
torture/test_dbwrap_ctdb.c
torture/t_strappend.c'''
SMBTORTURE_SRC = '''${SMBTORTURE_SRC1}