This commit is contained in:
GoodDaisy
2023-10-19 22:05:15 +00:00
parent c6583bb5fa
commit 90f78d141f
12 changed files with 16 additions and 16 deletions

View File

@@ -229,7 +229,7 @@ impl<T: BeaconChainTypes> NetworkService<T> {
)> {
let network_log = executor.log().clone();
// build the channels for external comms
let (network_senders, network_recievers) = NetworkSenders::new();
let (network_senders, network_receivers) = NetworkSenders::new();
#[cfg(feature = "disable-backfill")]
warn!(
@@ -344,7 +344,7 @@ impl<T: BeaconChainTypes> NetworkService<T> {
let NetworkReceivers {
network_recv,
validator_subscription_recv,
} = network_recievers;
} = network_receivers;
// create the network service and spawn the task
let network_log = network_log.new(o!("service" => "network"));
@@ -635,7 +635,7 @@ impl<T: BeaconChainTypes> NetworkService<T> {
id,
reason,
} => {
self.libp2p.send_error_reponse(peer_id, id, error, reason);
self.libp2p.send_error_response(peer_id, id, error, reason);
}
NetworkMessage::UPnPMappingEstablished { mappings } => {
self.upnp_mappings = mappings;

View File

@@ -280,7 +280,7 @@ impl<T: BeaconChainTypes, C: BlockStorage> ChainCollection<T, C> {
old_id = Some(Some(syncing_id));
} else {
// chains have the same number of peers, pick the currently syncing
// chain to avoid unnecesary switchings and try to advance it
// chain to avoid unnecessary switchings and try to advance it
new_id = syncing_id;
old_id = Some(None);
}

View File

@@ -464,7 +464,7 @@ mod tests {
log: slog::Logger,
/// To check what does sync send to the beacon processor.
beacon_processor_rx: mpsc::Receiver<BeaconWorkEvent<E>>,
/// To set up different scenarios where sync is told about known/unkown blocks.
/// To set up different scenarios where sync is told about known/unknown blocks.
chain: Arc<FakeStorage>,
/// Needed by range to handle communication with the network.
cx: SyncNetworkContext<TestBeaconChainType>,