Merge pull request ceph#60102 from MaxKellermann/dispatch_notify_one

SrinivasaBharath · web-flow · commit d5a269d5e5cb · 2025-02-06T18:54:44.000+05:30
msg/DispatchQueue: wake up only one dispatch thread
diff --git a/src/msg/DispatchQueue.cc b/src/msg/DispatchQueue.cc
@@ -93,7 +93,7 @@ void DispatchQueue::enqueue(const ref_t<Message>& m, int priority, uint64_t id)
   } else {
     mqueue.enqueue(id, priority, m->get_cost(), QueueItem(m));
   }
-  cond.notify_all();
+  cond.notify_one();
 }
 
 void DispatchQueue::local_delivery(const ref_t<Message>& m, int priority)

Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,7 @@ void DispatchQueue::enqueue(const ref_t<Message>& m, int priority, uint64_t id)`
`93`	`93`	`} else {`
`94`	`94`	`mqueue.enqueue(id, priority, m->get_cost(), QueueItem(m));`
`95`	`95`	`}`
`96`		`- cond.notify_all();`
	`96`	`+ cond.notify_one();`
`97`	`97`	`}`
`98`	`98`
`99`	`99`	`void DispatchQueue::local_delivery(const ref_t<Message>& m, int priority)`