sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-01-11 05:18:09 +03:00
Code

dbwrap_watch: Test cleanup of dead watchers

Browse Source 
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
This commit is contained in:
Volker Lendecke 2019-10-15 10:55:25 +02:00 committed by Jeremy Allison
parent 50f69b6054
commit 75433f6052
5 changed files with 110 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
selftest/knownfail
View File

@ -16,6 +16,7 @@
^samba3.smbtorture_s3.crypt_server # expected to give ACCESS_DENIED as SMB1 encryption isn't used
^samba3.smbtorture_s3.*.LOCK12.*\(fileserver\)
^samba3.smbtorture_s3.*.LOCK12.*\(nt4_dc\)
^samba3.smbtorture_s3.LOCAL-DBWRAP-WATCH3
^samba3.nbt.dgram.*netlogon2\(nt4_dc\)
^samba3.*rap.sam.*.useradd # Not provided by Samba 3
^samba3.*rap.sam.*.userdelete # Not provided by Samba 3

1
source3/selftest/tests.py
View File

@ -213,6 +213,7 @@ local_tests = [
"LOCAL-CANONICALIZE-PATH",
"LOCAL-DBWRAP-WATCH1",
"LOCAL-DBWRAP-WATCH2",
"LOCAL-DBWRAP-WATCH3",
"LOCAL-DBWRAP-DO-LOCKED1",
"LOCAL-G-LOCK1",
"LOCAL-G-LOCK2",

1
source3/torture/proto.h
View File

@ -113,6 +113,7 @@ bool run_notify_bench2(int dummy);
bool run_notify_bench3(int dummy);
bool run_dbwrap_watch1(int dummy);
bool run_dbwrap_watch2(int dummy);
bool run_dbwrap_watch3(int dummy);
bool run_dbwrap_do_locked1(int dummy);
bool run_idmap_tdb_common_test(int dummy);
bool run_local_dbwrap_ctdb(int dummy);

103
source3/torture/test_dbwrap_watch.c
View File

@ -175,3 +175,106 @@ fail:
TALLOC_FREE(ev);
return ret;
}
/*
* Test autocleanup of dead watchers
*/
bool run_dbwrap_watch3(int dummy)
{
struct tevent_context *ev = NULL;
struct messaging_context *msg = NULL;
struct db_context *backend = NULL;
struct db_context *db = NULL;
const char *keystr = "key";
TDB_DATA key = string_term_tdb_data(keystr);
NTSTATUS status;
bool ret = false;
pid_t child, waited;
int wstatus, exit_status;
BlockSignals(true, SIGCHLD);
child = fork();
if (child == -1) {
fprintf(stderr,
"fork failed: %s\n",
strerror(errno));
goto fail;
}
ev = samba_tevent_context_init(talloc_tos());
if (ev == NULL) {
fprintf(stderr, "tevent_context_init failed\n");
goto fail;
}
msg = messaging_init(ev, ev);
if (msg == NULL) {
fprintf(stderr, "messaging_init failed\n");
goto fail;
}
backend = db_open(msg, "test_watch.tdb", 0, TDB_CLEAR_IF_FIRST,
O_CREAT|O_RDWR, 0644, DBWRAP_LOCK_ORDER_1,
DBWRAP_FLAG_NONE);
if (backend == NULL) {
fprintf(stderr, "db_open failed: %s\n", strerror(errno));
goto fail;
}
db = db_open_watched(ev, &backend, msg);
if (db == NULL) {
fprintf(stderr, "db_open_watched failed\n");
goto fail;
}
if (child == 0) {
struct db_record *rec = dbwrap_fetch_locked(db, db, key);
struct tevent_req *req = NULL;
if (rec == NULL) {
fprintf(stderr, "dbwrap_fetch_locked failed\n");
exit(1);
}
req = dbwrap_watched_watch_send(
db, ev, rec, (struct server_id) { 0 });
if (req == NULL) {
fprintf(stderr, "dbwrap_watched_watch_send failed\n");
exit(2);
}
exit(0);
}
waited = waitpid(child, &wstatus, 0);
if (waited == -1) {
fprintf(stderr, "waitpid failed: %s\n", strerror(errno));
goto fail;
}
if (!WIFEXITED(wstatus)) {
fprintf(stderr, "child did not exit normally\n");
goto fail;
}
exit_status = WEXITSTATUS(wstatus);
if (exit_status != 0) {
fprintf(stderr, "exit status is %d\n", exit_status);
goto fail;
}
status = dbwrap_store_uint32_bystring(db, keystr, 1);
if (!NT_STATUS_EQUAL(status, NT_STATUS_OK)) {
fprintf(stderr,
"dbwrap_store_uint32 returned %s\n",
nt_errstr(status));
goto fail;
}
(void)unlink("test_watch.tdb");
ret = true;
fail:
TALLOC_FREE(db);
TALLOC_FREE(msg);
TALLOC_FREE(ev);
return ret;
}

4
source3/torture/torture.c
View File

@ -14663,6 +14663,10 @@ static struct {
.name = "LOCAL-DBWRAP-WATCH2",
.fn = run_dbwrap_watch2,
},
{
.name = "LOCAL-DBWRAP-WATCH3",
.fn = run_dbwrap_watch3,
},
{
.name = "LOCAL-DBWRAP-DO-LOCKED1",
.fn = run_dbwrap_do_locked1,