NTSTATUS g_lock_write_data(struct g_lock_ctx *ctx, TDB_DATA key,
const uint8_t *buf, size_t buflen);
-NTSTATUS g_lock_do(const char *name, enum g_lock_type lock_type,
+NTSTATUS g_lock_do(TDB_DATA key, enum g_lock_type lock_type,
struct timeval timeout,
void (*fn)(void *private_data), void *private_data);
return false;
}
-NTSTATUS g_lock_do(const char *name, enum g_lock_type lock_type,
+NTSTATUS g_lock_do(TDB_DATA key, enum g_lock_type lock_type,
struct timeval timeout,
void (*fn)(void *private_data), void *private_data)
{
goto done;
}
- status = g_lock_lock(g_ctx, string_term_tdb_data(name), lock_type,
- timeout);
+ status = g_lock_lock(g_ctx, key, lock_type, timeout);
if (!NT_STATUS_IS_OK(status)) {
goto done;
}
fn(private_data);
- g_lock_unlock(g_ctx, string_term_tdb_data(name));
+ g_lock_unlock(g_ctx, key);
done:
TALLOC_FREE(g_ctx);
#include "lib/util/server_id.h"
#include "g_lock.h"
#include "messages.h"
+#include "lib/util/util_tdb.h"
static bool net_g_lock_init(TALLOC_CTX *mem_ctx,
struct tevent_context **pev,
state.cmd = cmd;
state.result = -1;
- status = g_lock_do(name, G_LOCK_WRITE,
+ status = g_lock_do(string_term_tdb_data(name), G_LOCK_WRITE,
timeval_set(timeout / 1000, timeout % 1000),
net_g_lock_do_fn, &state);
if (!NT_STATUS_IS_OK(status)) {
#include "../libcli/registry/util_reg.h"
#include "passdb/machine_sid.h"
#include "net_registry_check.h"
+#include "lib/util/util_tdb.h"
/*
*
state.increment = strtoul(argv[2], NULL, 10);
}
- status = g_lock_do("registry_increment_lock", G_LOCK_WRITE,
- timeval_set(600, 0),
+ status = g_lock_do(string_term_tdb_data("registry_increment_lock"),
+ G_LOCK_WRITE, timeval_set(600, 0),
net_registry_increment_fn, &state);
if (!NT_STATUS_IS_OK(status)) {
d_fprintf(stderr, _("g_lock_do failed: %s\n"),