RPCTask: add log about which request failed
Change-Id: I43d83b9695338d4eb1674a58134a398038b8ae0b
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java
index 582e00c..976fbcf 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java
@@ -109,10 +109,12 @@
private class RPCTask<I, O> implements Runnable {
+ private final I request;
private final ClusterMessage message;
private final CompletableFuture<O> future;
public RPCTask(I request, CompletableFuture<O> future) {
+ this.request = request;
this.message =
new ClusterMessage(
null,
@@ -139,6 +141,7 @@
RETRY_INTERVAL_MILLIS,
TimeUnit.MILLISECONDS);
} else {
+ log.warn("RPCTask for {} failed.", request, e);
future.completeExceptionally(e);
}
} catch (Exception e) {