add toString()

Author: ywelsch

server/src/main/java/org/elasticsearch/cluster/coordination/JoinHelper.java

@@ -93,6 +93,11 @@ public void onFailure(Exception e) {
                         logger.warn("failed to send back failure on join request", inner);
                     }
                 }
+
+                @Override
+                public String toString() {
+                    return "JoinCallback{request=" + request + "}";
+                }
             }));
     }
 
@@ -115,8 +120,10 @@ public void clearAndFailPendingJoins(String reason) {
 
     public void clearAndSubmitPendingJoins() {
         final Map<JoinTaskExecutor.Task, ClusterStateTaskListener> pendingAsTasks = new HashMap<>();
-        joinRequestAccumulator.forEach((key, value) -> pendingAsTasks.put(new JoinTaskExecutor.Task(key, "elect leader"),
-            new JoinTaskListener(value)));
+        joinRequestAccumulator.forEach((key, value) -> {
+            final JoinTaskExecutor.Task task = new JoinTaskExecutor.Task(key, "elect leader");
+            pendingAsTasks.put(task, new JoinTaskListener(task, value));
+        });
         joinRequestAccumulator.clear();
 
         pendingAsTasks.put(JoinTaskExecutor.BECOME_MASTER_TASK, (source, e) -> {});
@@ -127,9 +134,9 @@ public void clearAndSubmitPendingJoins() {
 
     public void joinLeader(JoinRequest joinRequest, JoinCallback joinCallback) {
         // submit as cluster state update task
-        masterService.submitStateUpdateTask("node-join",
-            new JoinTaskExecutor.Task(joinRequest.getSourceNode(), "join existing leader"), ClusterStateTaskConfig.build(Priority.URGENT),
-            joinTaskExecutor, new JoinTaskListener(joinCallback));
+        final JoinTaskExecutor.Task task = new JoinTaskExecutor.Task(joinRequest.getSourceNode(), "join existing leader");
+        masterService.submitStateUpdateTask("node-join", task, ClusterStateTaskConfig.build(Priority.URGENT),
+            joinTaskExecutor, new JoinTaskListener(task, joinCallback));
     }
 
     public interface JoinCallback {
@@ -139,9 +146,11 @@ public interface JoinCallback {
     }
 
     static class JoinTaskListener implements ClusterStateTaskListener {
+        private final JoinTaskExecutor.Task task;
         private final JoinCallback joinCallback;
 
-        JoinTaskListener(JoinCallback joinCallback) {
+        JoinTaskListener(JoinTaskExecutor.Task task, JoinCallback joinCallback) {
+            this.task = task;
             this.joinCallback = joinCallback;
         }
 
@@ -154,6 +163,11 @@ public void onFailure(String source, Exception e) {
         public void clusterStateProcessed(String source, ClusterState oldState, ClusterState newState) {
             joinCallback.onSuccess();
         }
+
+        @Override
+        public String toString() {
+            return "JoinTaskListener{task=" + task + "}";
+        }
     }
 
 }