summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--source3/include/messages.h3
-rw-r--r--source3/lib/messages_local.c10
2 files changed, 13 insertions, 0 deletions
diff --git a/source3/include/messages.h b/source3/include/messages.h
index 2161a77d28..4b45901afd 100644
--- a/source3/include/messages.h
+++ b/source3/include/messages.h
@@ -98,6 +98,9 @@ NTSTATUS messaging_tdb_init(struct messaging_context *msg_ctx,
bool messaging_tdb_parent_init(TALLOC_CTX *mem_ctx);
+void *messaging_tdb_event(TALLOC_CTX *mem_ctx, struct messaging_context *msg,
+ struct tevent_context *ev);
+
NTSTATUS messaging_ctdbd_init(struct messaging_context *msg_ctx,
TALLOC_CTX *mem_ctx,
struct messaging_backend **presult);
diff --git a/source3/lib/messages_local.c b/source3/lib/messages_local.c
index b398870e1f..e20024ae59 100644
--- a/source3/lib/messages_local.c
+++ b/source3/lib/messages_local.c
@@ -77,6 +77,16 @@ static void messaging_tdb_signal_handler(struct tevent_context *ev_ctx,
message_dispatch(ctx->msg_ctx);
}
+void *messaging_tdb_event(TALLOC_CTX *mem_ctx, struct messaging_context *msg,
+ struct tevent_context *ev)
+{
+ struct messaging_tdb_context *msg_tdb = talloc_get_type_abort(
+ msg->local->private_data, struct messaging_tdb_context);
+
+ return tevent_add_signal(ev, mem_ctx, SIGUSR1, 0,
+ messaging_tdb_signal_handler, msg_tdb);
+}
+
/****************************************************************************
Initialise the messaging functions.
****************************************************************************/