save

anza-xyz · Apr 20, 2024 · 12fb68b · 12fb68b
1 parent c203d3f
commit 12fb68b
Showing 1 changed file with 21 additions and 19 deletions.
diff --git a/unified-scheduler-pool/src/lib.rs b/unified-scheduler-pool/src/lib.rs
@@ -1217,25 +1217,27 @@ where
 
                 while !thread_suspending {
                     match new_task_receiver.recv() {
-                    Ok(NewTaskPayload::OpenSubchannel(context)) => {
-                        info!("received context");
-                        slot = context.bank().slot();
-                        // signal about new SchedulingContext to handler threads
-                        runnable_task_sender
-                            .send_chained_channel(context, handler_count)
-                            .unwrap();
-                        retired_task_sender
-                            .send(RetiredTaskPayload::OpenSubchannel(()))
-                            .unwrap();
-                        log_scheduler!("S:started");
-                    }
-                    aa => {
-                        info!("received other: {aa:?}");
-                        assert!(!thread_suspending);
-                        thread_suspending = true;
-                        log_scheduler!("T:suspending1");
-                        continue;
-                    }
+                        Ok(NewTaskPayload::OpenSubchannel(context)) => {
+                            info!("received context");
+                            slot = context.bank().slot();
+                            // signal about new SchedulingContext to handler threads
+                            runnable_task_sender
+                                .send_chained_channel(context, handler_count)
+                                .unwrap();
+                            retired_task_sender
+                                .send(RetiredTaskPayload::OpenSubchannel(()))
+                                .unwrap();
+                            log_scheduler!("S:started");
+                        }
+                        Err(_) => {
+                            assert!(!thread_suspending);
+                            thread_suspending = true;
+                            log_scheduler!("T:suspending1");
+                            continue;
+                        }
+                        Ok(_) => {
+                            unreachable!();
+                        }
                     }
 
                     let mut is_finished = false;