Skip to content
Snippets Groups Projects

Minor fixes

Merged Yaroslav Dynnikov requested to merge minor-fixes into master
All threads resolved!
Files
4
+ 2
2
@@ -64,12 +64,12 @@ pub struct PoolWorker {
impl PoolWorker {
pub fn run(id: RaftId, storage: PeerStorage, opts: WorkerOptions) -> PoolWorker {
let cond = Rc::new(fiber::Cond::new());
let inbox = Mailbox::with_cond(cond.clone());
let inbox = Mailbox::with_cond(&cond);
let stop_flag = Rc::new(Cell::default());
let handler_name = opts.handler_name;
let fiber = fiber::defer_proc({
let cond = cond.clone();
let inbox = inbox.clone();
let inbox = Mailbox::share(&inbox);
let stop_flag = stop_flag.clone();
move || Self::worker_loop(id, storage, cond, inbox, stop_flag, &opts)
});
Loading