Explicitly clear waiting task queues in PriorityMultiLock::kill().

2022-11-15 10:18:07 -08:00 · 2022-11-15 10:18:07 -08:00 · d5f7cd862c
parent 391776ab38
commit d5f7cd862c
1 changed files with 3 additions and 0 deletions
--- a/flow/include/flow/PriorityMultiLock.actor.h
+++ b/flow/include/flow/PriorityMultiLock.actor.h
@ -144,6 +144,9 @@ public:
 		available = 0;

 		waitingPriorities.clear();
+		for (auto& p : priorities) {
+			p.queue.clear();
+		}
 	}

 	std::string toString() const {