@@ -267,7 +267,7 @@ void handleWakeUp() {
267267 requestPeers ();
268268 }
269269 } else {
270- logger .trace ("{} no longer connected to {}" , this , discoveryNode );
270+ logger .trace ("{} no longer connected to {}" , this );
271271 removePeer ();
272272 }
273273 }
@@ -314,7 +314,7 @@ private void requestPeers() {
314314 final DiscoveryNode discoveryNode = getDiscoveryNode ();
315315 assert discoveryNode != null : "cannot request peers without first connecting" ;
316316
317- logger .trace ("{} requesting peers from {} " , this , discoveryNode );
317+ logger .trace ("{} requesting peers" , this );
318318 peersRequestInFlight = true ;
319319
320320 List <DiscoveryNode > knownNodes = getFoundPeersUnderLock ();
@@ -330,7 +330,7 @@ public PeersResponse read(StreamInput in) throws IOException {
330330
331331 @ Override
332332 public void handleResponse (PeersResponse response ) {
333- logger .trace ("{} received {} from {} " , Peer .this , response , discoveryNode );
333+ logger .trace ("{} received {}" , Peer .this , response );
334334 synchronized (mutex ) {
335335 if (active == false ) {
336336 return ;
@@ -352,7 +352,7 @@ public void handleResponse(PeersResponse response) {
352352 @ Override
353353 public void handleException (TransportException exp ) {
354354 peersRequestInFlight = false ;
355- logger .debug ("PeersRequest failed" , exp );
355+ logger .debug (new ParameterizedMessage ( "{} peers request failed", this ) , exp );
356356 }
357357
358358 @ Override
@@ -364,7 +364,11 @@ public String executor() {
364364
365365 @ Override
366366 public String toString () {
367- return "Peer{" + transportAddress + " peersRequestInFlight=" + peersRequestInFlight + "}" ;
367+ return "Peer{" +
368+ "transportAddress=" + transportAddress +
369+ ", discoveryNode=" + discoveryNode .get () +
370+ ", peersRequestInFlight=" + peersRequestInFlight +
371+ '}' ;
368372 }
369373 }
370374}
0 commit comments