diff --git a/substrate/network/src/protocol.rs b/substrate/network/src/protocol.rs
index a9e09a36d1bc8..6bc20af5b86a0 100644
--- a/substrate/network/src/protocol.rs
+++ b/substrate/network/src/protocol.rs
@@ -393,7 +393,7 @@ impl<B: BlockT, S: Specialization<B>> Protocol<B, S> {
 
 		self.specialization.write().maintain_peers(&mut ProtocolContext::new(&self.context_data, io));
 		for p in aborting {
-			self.on_peer_disconnected(io, p);
+			io.disconnect_peer(p);
 		}
 	}
 
diff --git a/substrate/telemetry/src/lib.rs b/substrate/telemetry/src/lib.rs
index dd5a30936d42c..62d16c1a81d7a 100644
--- a/substrate/telemetry/src/lib.rs
+++ b/substrate/telemetry/src/lib.rs
@@ -115,9 +115,11 @@ impl TelemetryWriter {
 		};
 
 		drop(client);
-		if just_connected && !controlled_disconnect {
+		if just_connected {
+			if !controlled_disconnect {
+				info!("Reconnected to telemetry server: {}", self.config.url);
+			}
 			self.last_time = Some(time::Instant::now());
-			info!("Reconnected to telemetry server: {}", self.config.url);
 			(self.config.on_connect)();
 		}
 	}