Rename open_peer() to connected_peers()

substrate/client/network/src/service.rs

@@ -744,12 +744,12 @@ impl<B: BlockT + 'static, H: ExHashT> NetworkService<B, H> {
 	}
 
 	/// Returns a collection of currently connected (open) peers.
-	pub async fn open_peers(&self) -> Result<Vec<PeerId>, ()> {
+	pub async fn connected_peers(&self) -> Result<Vec<PeerId>, ()> {
 		let (tx, rx) = oneshot::channel();
 
 		let _ = self
 			.to_worker
-			.unbounded_send(ServiceToWorkerMsg::OpenPeers { pending_response: tx });
+			.unbounded_send(ServiceToWorkerMsg::ConnectedPeers { pending_response: tx });
 
 		match rx.await {
 			Ok(v) => Ok(v),
@@ -1188,7 +1188,7 @@ enum ServiceToWorkerMsg {
 	NetworkState {
 		pending_response: oneshot::Sender<Result<NetworkState, RequestFailure>>,
 	},
-	OpenPeers {
+	ConnectedPeers {
 		pending_response: oneshot::Sender<Vec<PeerId>>,
 	},
 	DisconnectPeer(PeerId, ProtocolName),
@@ -1333,13 +1333,13 @@ where
 				.behaviour_mut()
 				.user_protocol_mut()
 				.disconnect_peer(&who, protocol_name),
-			ServiceToWorkerMsg::OpenPeers { pending_response } => {
-				let _ = pending_response.send(self.open_peers());
+			ServiceToWorkerMsg::ConnectedPeers { pending_response } => {
+				let _ = pending_response.send(self.connected_peers());
 			},
 		}
 	}
 
-	fn open_peers(&self) -> Vec<PeerId> {
+	fn connected_peers(&self) -> Vec<PeerId> {
 		self.network_service
 			.behaviour()
 			.user_protocol()