diff --git a/safekeeper/src/receive_wal.rs b/safekeeper/src/receive_wal.rs index 934dda10b2..9ce9b049ba 100644 --- a/safekeeper/src/receive_wal.rs +++ b/safekeeper/src/receive_wal.rs @@ -111,7 +111,7 @@ impl WalReceivers { .count() } - /// Unregister walsender. + /// Unregister walreceiver. fn unregister(self: &Arc, id: WalReceiverId) { let mut shared = self.mutex.lock(); shared.slots[id] = None; @@ -138,8 +138,8 @@ pub enum WalReceiverStatus { Streaming, } -/// Scope guard to access slot in WalSenders registry and unregister from it in -/// Drop. +/// Scope guard to access slot in WalReceivers registry and unregister from +/// it in Drop. pub struct WalReceiverGuard { id: WalReceiverId, walreceivers: Arc,