Rename AutoSerialize into SimpleMessage and refactor a bit

1 files changed, 6 insertions, 6 deletions

diff --git a/src/peering/fullmesh.rs b/src/peering/fullmesh.rs
index 5b489ae..3eeebb3 100644
--- a/src/peering/fullmesh.rs
+++ b/src/peering/fullmesh.rs
@@ -40,7 +40,7 @@ impl Message for PingMessage {
 	type Response = PingMessage;
 }
 
-impl AutoSerialize for PingMessage {}
+impl SimpleMessage for PingMessage {}
 
 #[derive(Serialize, Deserialize, Clone)]
 struct PeerListMessage {
@@ -51,7 +51,7 @@ impl Message for PeerListMessage {
 	type Response = PeerListMessage;
 }
 
-impl AutoSerialize for PeerListMessage {}
+impl SimpleMessage for PeerListMessage {}
 
 // -- Algorithm data structures --
 
@@ -379,7 +379,7 @@ impl FullMeshPeeringStrategy {
 			ping_time
 		);
 		let ping_response = select! {
-			r = self.ping_endpoint.call(&id, &ping_msg, PRIO_HIGH) => r,
+			r = self.ping_endpoint.call(&id, ping_msg, PRIO_HIGH) => r,
 			_ = tokio::time::sleep(PING_TIMEOUT) => Err(Error::Message("Ping timeout".into())),
 		};
 
@@ -431,7 +431,7 @@ impl FullMeshPeeringStrategy {
 		let pex_message = PeerListMessage { list: peer_list };
 		match self
 			.peer_list_endpoint
-			.call(id, &pex_message, PRIO_BACKGROUND)
+			.call(id, pex_message, PRIO_BACKGROUND)
 			.await
 		{
 			Err(e) => warn!("Error doing peer exchange: {}", e),
@@ -587,7 +587,7 @@ impl FullMeshPeeringStrategy {
 
 #[async_trait]
 impl EndpointHandler<PingMessage> for FullMeshPeeringStrategy {
-	async fn handle(self: &Arc<Self>, ping: &PingMessage, from: NodeID) -> PingMessage {
+	async fn handle(self: &Arc<Self>, ping: PingMessage, from: NodeID) -> PingMessage {
 		let ping_resp = PingMessage {
 			id: ping.id,
 			peer_list_hash: self.known_hosts.read().unwrap().hash,
@@ -601,7 +601,7 @@ impl EndpointHandler<PingMessage> for FullMeshPeeringStrategy {
 impl EndpointHandler<PeerListMessage> for FullMeshPeeringStrategy {
 	async fn handle(
 		self: &Arc<Self>,
-		peer_list: &PeerListMessage,
+		peer_list: PeerListMessage,
 		_from: NodeID,
 	) -> PeerListMessage {
 		self.handle_peer_list(&peer_list.list[..]);