Skip to content

Commit

Permalink
Remove unconstrained
Browse files Browse the repository at this point in the history
  • Loading branch information
akiradeveloper committed Nov 2, 2024
1 parent 00a21fd commit ab1e6e9
Show file tree
Hide file tree
Showing 6 changed files with 0 additions and 6 deletions.
1 change: 0 additions & 1 deletion sorock/src/process/thread/advance_commit.rs
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ impl Thread {
self.run_once().await.ok();
}
};
let fut = tokio::task::unconstrained(fut);
let hdl = tokio::spawn(fut).abort_handle();
ThreadHandle(hdl)
}
Expand Down
1 change: 0 additions & 1 deletion sorock/src/process/thread/advance_kern.rs
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ impl Thread {
}
}
};
let fut = tokio::task::unconstrained(fut);
let hdl = tokio::spawn(fut).abort_handle();
ThreadHandle(hdl)
}
Expand Down
1 change: 0 additions & 1 deletion sorock/src/process/thread/election.rs
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ impl Thread {
self.run_once().await.ok();
}
};
let fut = tokio::task::unconstrained(fut);
let hdl = tokio::spawn(fut).abort_handle();
ThreadHandle(hdl)
}
Expand Down
1 change: 0 additions & 1 deletion sorock/src/process/thread/heartbeat.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ impl Thread {
self.run_once().await.ok();
}
};
let fut = tokio::task::unconstrained(fut);
let hdl = tokio::spawn(fut).abort_handle();
ThreadHandle(hdl)
}
Expand Down
1 change: 0 additions & 1 deletion sorock/src/process/thread/replication.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@ impl Thread {
}
}
};
let fut = tokio::task::unconstrained(fut);
let hdl = tokio::spawn(fut).abort_handle();
ThreadHandle(hdl)
}
Expand Down
1 change: 0 additions & 1 deletion sorock/src/service/raft/communicator/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@ impl RaftConnection {
let heartbeat_buffer = Arc::new(HeartbeatBuffer::new());

let fut = heartbeat_multiplex::run(heartbeat_buffer.clone(), client.clone(), self_node_id);
let fut = tokio::task::unconstrained(fut);
let abort_hdl = tokio::spawn(fut).abort_handle();

Self {
Expand Down

0 comments on commit ab1e6e9

Please sign in to comment.