Replace SharedSender with the std Sender, which is now Sync.

ditsing · Nov 23, 2023 · 9a192c0 · 9a192c0
1 parent 18699fd
commit 9a192c0
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 61 deletions.
diff --git a/raft/src/sync_log_entries.rs b/raft/src/sync_log_entries.rs
@@ -7,7  7,7 @@ use crate::daemon_env::ErrorKind;
 use crate::heartbeats::HEARTBEAT_INTERVAL;
 use crate::peer_progress::PeerProgress;
 use crate::remote::RemoteContext;
-use crate::utils::{retry_rpc, SharedSender, RPC_DEADLINE};
 use crate::utils::{retry_rpc, RPC_DEADLINE};
 use crate::{
     check_or_record, AppendEntriesArgs, Index, IndexTerm, InstallSnapshotArgs,
     Peer, Raft, RaftState, ReplicableCommand, Term,
@@ -34,7  34,7 @@ impl Event {
 
 #[derive(Clone)]
 pub(crate) struct SyncLogEntriesComms {
-    tx: SharedSender<Event>,
     tx: std::sync::mpsc::Sender<Event>,
 }
 
 impl SyncLogEntriesComms {
@@ -68,7  68,6 @@ pub(crate) fn create(
     peer_size: usize,
 ) -> (SyncLogEntriesComms, SyncLogEntriesDaemon) {
     let (tx, rx) = std::sync::mpsc::channel();
-    let tx = SharedSender::new(tx);
     let peer_progress = (0..peer_size).map(PeerProgress::create).collect();
     (
         SyncLogEntriesComms { tx },

diff --git a/raft/src/utils/mod.rs b/raft/src/utils/mod.rs
@@ -1,7  1,5 @@
 pub use rpcs::{retry_rpc, RPC_DEADLINE};
-pub use shared_sender::SharedSender;
 
 pub mod do_nothing;
 pub mod integration_test;
 mod rpcs;
-mod shared_sender;
diff --git a/raft/src/utils/shared_sender.rs b/raft/src/utils/shared_sender.rs