Change-Id: Iccc90e575033c6770a3a499853f31e0684a712e4
Signed-off-by: Tomas Cere <tcere@cisco.com>
completionFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());
+ for (int i = 0; i < futures.size(); i++) {
+ final CheckedFuture<Void, TransactionCommitFailedException> future = futures.get(i);
+ if (!future.isDone()) {
+ LOG.warn("Future #{}/{} possibly hanged.", future, futures.size());
+ }
+ }
+
executor.shutdown();
} finally {
try {
completionFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());
+ for (int i = 0; i < futures.size(); i++) {
+ final CheckedFuture<Void, TransactionCommitFailedException> future = futures.get(i);
+ if (!future.isDone()) {
+ LOG.warn("Future #{}/{} possibly hanged.", future, futures.size());
+ }
+ }
+
executor.shutdown();
}
}