workers: minimal error handling and async module loading (#3665)

1 files changed, 2 insertions, 0 deletions

diff --git a/cli/state.rs b/cli/state.rs
index a4974958b..ed7b8e438 100644
--- a/cli/state.rs
+++ b/cli/state.rs
@@ -53,6 +53,7 @@ pub struct State {
   pub metrics: Metrics,
   pub global_timer: Mutex<GlobalTimer>,
   pub workers: Mutex<HashMap<u32, Worker>>,
+  pub loading_workers: Mutex<HashMap<u32, mpsc::Receiver<Result<(), ErrBox>>>>,
   pub next_worker_id: AtomicUsize,
   pub start_time: Instant,
   pub seeded_rng: Option<Mutex<StdRng>>,
@@ -248,6 +249,7 @@ impl ThreadSafeState {
       metrics: Metrics::default(),
       global_timer: Mutex::new(GlobalTimer::new()),
       workers: Mutex::new(HashMap::new()),
+      loading_workers: Mutex::new(HashMap::new()),
       next_worker_id: AtomicUsize::new(0),
       start_time: Instant::now(),
       seeded_rng,