save

ryoqun · Nov 30, 2023 · e3d3436 · e3d3436
1 parent 5085593
commit e3d3436
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/scheduler-pool/src/lib.rs b/scheduler-pool/src/lib.rs
@@ -717,6 +717,7 @@ where
                 tid_sender
                     .send(rustix::thread::gettid().as_raw_nonzero().get())
                     .unwrap();
+                let (ready_to_retry, never_to_retry) = (&ready(), &never());
 
                 while !end_thread {
                     loop {
@@ -753,7 +754,7 @@ where
                                     }
                                 }
                             },
-                            recv(if state_machine.has_retryable_task() { ready() } else { never() }) -> now => {
+                            recv(if state_machine.has_retryable_task() { ready_to_retry } else { never_to_retry }) -> now => {
                                 assert!(now.is_ok());
                                 if let Some(task) = state_machine.schedule_retryable_task() {
                                     blocked_transaction_sessioned_sender

diff --git a/scheduler/src/lib.rs b/scheduler/src/lib.rs
@@ -71,6 +71,7 @@ impl TaskStatus {
 
 #[derive(Debug)]
 pub struct TaskInner {
+    // put this field out of this struct for maximum space efficiency?
     unique_weight: UniqueWeight,
     transaction: SanitizedTransaction, // actually should be Bundle
     task_status: SchedulerCell<TaskStatus>,