summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorManos Pitsidianakis <el13635@mail.ntua.gr>2019-09-11 17:57:55 +0300
committerManos Pitsidianakis <el13635@mail.ntua.gr>2019-09-15 13:21:14 +0300
commitf394fde1434429aa7ff750665516097f946f1c1f (patch)
tree4d80440d9638b9ae0a3d012b3fac96d0bf2cb319 /src
parentfd38dbed48e03eaf75c2c87e2949040c7d46a6de (diff)
add priority and info to jobs and workers
jobs now have a priority given to them, in order to parse some mailboxes (eg INBOX, Sent) first. worker threads now can set their names and status
Diffstat (limited to 'src')
-rw-r--r--src/bin.rs9
1 files changed, 3 insertions, 6 deletions
diff --git a/src/bin.rs b/src/bin.rs
index 5c159fbb..b00be789 100644
--- a/src/bin.rs
+++ b/src/bin.rs
@@ -188,8 +188,6 @@ fn main() -> std::result::Result<(), std::io::Error> {
let receiver = state.receiver();
- let worker_receiver = state.worker_receiver();
-
/* Register some reasonably useful interfaces */
let window = Box::new(Tabbed::new(vec![
Box::new(listing::Listing::new(&state.context.accounts)),
@@ -298,6 +296,9 @@ fn main() -> std::result::Result<(), std::io::Error> {
state.rcv_event(e);
state.render();
},
+ ThreadEvent::Pulse => {
+ state.redraw();
+ },
ThreadEvent::ThreadJoin(id) => {
state.join(id);
},
@@ -315,10 +316,6 @@ fn main() -> std::result::Result<(), std::io::Error> {
_ => {}
}
},
- recv(worker_receiver) -> _ => {
- /* Some worker thread finished their job, acknowledge
- * it and move on*/
- },
}
} // end of 'inner