From 9c3b28f2b2ce1d47241ce2775beda188b6022e7a Mon Sep 17 00:00:00 2001 From: Zihan Liu Date: Sat, 20 Jun 2020 09:58:05 +0800 Subject: [PATCH 1/2] Various tiny refinements --- src/main.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main.rs b/src/main.rs index 5069a62..c0cf15e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -194,14 +194,14 @@ impl Runtime { let mut threads = Vec::with_capacity(4); for i in 0..4 { - let (evt_sender, evt_reciever) = channel::(); + let (task_sender, task_reciever) = channel::(); let event_sender = event_sender.clone(); let handle = thread::Builder::new() .name(format!("pool{}", i)) .spawn(move || { - while let Ok(task) = evt_reciever.recv() { + while let Ok(task) = task_reciever.recv() { print(format!("recived a task of type: {}", task.kind)); if let ThreadPoolTaskKind::Close = task.kind { @@ -219,7 +219,7 @@ impl Runtime { let node_thread = NodeThread { handle, - sender: evt_sender, + sender: task_sender, }; threads.push(node_thread); @@ -575,7 +575,7 @@ impl Http { let token = rt.generate_cb_identity(); rt.epoll_registrator - .register(&mut stream, token, minimio::Interests::READABLE) + .register(&stream, token, minimio::Interests::READABLE) .unwrap(); let wrapped = move |_n| { From 5924e7b0c36c551a19146b4fe45ec4ee0f39fccc Mon Sep 17 00:00:00 2001 From: Zihan Liu Date: Sat, 20 Jun 2020 21:34:37 +0800 Subject: [PATCH 2/2] Update main.rs --- src/main.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main.rs b/src/main.rs index c0cf15e..63412fa 100644 --- a/src/main.rs +++ b/src/main.rs @@ -575,7 +575,7 @@ impl Http { let token = rt.generate_cb_identity(); rt.epoll_registrator - .register(&stream, token, minimio::Interests::READABLE) + .register(&mut stream, token, minimio::Interests::READABLE) .unwrap(); let wrapped = move |_n| {