s4-repl: added a preiodic notification check to the repl task

[ira/wip.git] / source4 / dsdb / repl / drepl_out_pull.c

diff --git a/source4/dsdb/repl/drepl_out_pull.c b/source4/dsdb/repl/drepl_out_pull.c
index 54dbd297304212367b4e98920f393e87d323509b..b073d265c333f912b95a5b446b71fb272e50bdc2 100644 (file)
--- a/source4/dsdb/repl/drepl_out_pull.c
+++ b/source4/dsdb/repl/drepl_out_pull.c
@@ -125,6 +125,7 @@ done:
        talloc_free(op);
        s->ops.current = NULL;
        dreplsrv_run_pending_ops(s);
+       dreplsrv_notify_run_ops(s);
 }
 
 static void dreplsrv_pending_op_callback_creq(struct composite_context *creq)
@@ -140,7 +141,7 @@ void dreplsrv_run_pending_ops(struct dreplsrv_service *s)
        time_t t;
        NTTIME now;
 
-       if (s->ops.current) {
+       if (s->ops.current || s->ops.n_current) {
                /* if there's still one running, we're done */
                return;
        }