From 97be3cf4ce14348cc7d1a8c09c64f969f19c507d Mon Sep 17 00:00:00 2001 From: alemi Date: Thu, 20 Apr 2023 04:27:11 +0200 Subject: [PATCH] fix: send mock values to unlock and stop workers --- src/lib/operation/controller.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/lib/operation/controller.rs b/src/lib/operation/controller.rs index dbe2ce6..3dfaad8 100644 --- a/src/lib/operation/controller.rs +++ b/src/lib/operation/controller.rs @@ -60,7 +60,11 @@ impl OperationController { pub fn stop(&self) -> bool { match self.stop.send(false) { - Ok(()) => true, + Ok(()) => { + ignore_and_log(self.changed_notifier.send(0..0), "unlocking downstream for stop"); + ignore_and_log(self.notifier.send(OperationSeq::default()), "unlocking upstream for stop"); + true + }, Err(e) => { error!("could not send stop signal to workers: {}", e); false