s4-repl: ensure we don't starve pending replication ops

when there was a continuous sequence of notify ops, we could leave the
replication ops starving. This ensures we run whichever was queued
first

1 files changed, 3 insertions, 3 deletions

diff --git a/source4/dsdb/repl/drepl_out_pull.c b/source4/dsdb/repl/drepl_out_pull.c
index 3e59ee95ac..0af232c67f 100644
--- a/source4/dsdb/repl/drepl_out_pull.c
+++ b/source4/dsdb/repl/drepl_out_pull.c
@@ -52,6 +52,7 @@ WERROR dreplsrv_schedule_partition_pull_source(struct dreplsrv_service *s,
 	op->fsmo_info   = fsmo_info;
 	op->callback    = callback;
 	op->cb_data	= cb_data;
+	op->schedule_time = time(NULL);
 
 	DLIST_ADD_END(s->ops.pending, op, struct dreplsrv_out_operation *);
 
@@ -126,17 +127,16 @@ done:
 	talloc_free(op);
 	s->ops.current = NULL;
 	dreplsrv_run_pending_ops(s);
-	dreplsrv_notify_run_ops(s);
 }
 
-void dreplsrv_run_pending_ops(struct dreplsrv_service *s)
+void dreplsrv_run_pull_ops(struct dreplsrv_service *s)
 {
 	struct dreplsrv_out_operation *op;
 	time_t t;
 	NTTIME now;
 	struct tevent_req *subreq;
 
-	if (s->ops.current || s->ops.n_current) {
+	if (s->ops.current) {
 		/* if there's still one running, we're done */
 		return;
 	}