messaging3: Add messaging_dgm_register_tevent_context

Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>

diff --git a/source3/include/messages.h b/source3/include/messages.h
index 7801dfb3d7053eb9f0ce2c2031d2bf8a1bec664b..852e8a10b24402a2d66b813a12d1193f336fed8f 100644 (file)
--- a/source3/include/messages.h
+++ b/source3/include/messages.h
@@ -99,6 +99,9 @@ NTSTATUS messaging_dgm_init(struct messaging_context *msg_ctx,
                            struct messaging_backend **presult);
 NTSTATUS messaging_dgm_cleanup(struct messaging_context *msg_ctx, pid_t pid);
 NTSTATUS messaging_dgm_wipe(struct messaging_context *msg_ctx);
+void *messaging_dgm_register_tevent_context(TALLOC_CTX *mem_ctx,
+                                           struct messaging_context *msg_ctx,
+                                           struct tevent_context *ev);
 
 NTSTATUS messaging_ctdbd_init(struct messaging_context *msg_ctx,
                              TALLOC_CTX *mem_ctx,

diff --git a/source3/lib/messages_dgm.c b/source3/lib/messages_dgm.c
index 56643b1ffd606a868b262470ca431bbba079b4e3..55a6fcfac21a7e53cb860e1f7da144394a5da541 100644 (file)
--- a/source3/lib/messages_dgm.c
+++ b/source3/lib/messages_dgm.c
@@ -473,3 +473,12 @@ NTSTATUS messaging_dgm_wipe(struct messaging_context *msg_ctx)
 
        return NT_STATUS_OK;
 }
+
+void *messaging_dgm_register_tevent_context(TALLOC_CTX *mem_ctx,
+                                           struct messaging_context *msg_ctx,
+                                           struct tevent_context *ev)
+{
+       struct messaging_dgm_context *ctx = talloc_get_type_abort(
+               msg_ctx->local->private_data, struct messaging_dgm_context);
+       return poll_funcs_tevent_register(mem_ctx, ctx->msg_callbacks, ev);
+}