Add more logs in ListenableFutureUtil (linkedin#324)

* Add more logs in ListenableFuture

Author: junchuanwang

CHANGELOG.md

@@ -1,3 +1,7 @@
+v5.1.10
+------
+* Add more logging in ListenableFutureUtil to log root cause when ListeneableFuture is cancelled.
+
 v5.1.9
 ------
 * Add logging in ListenableFutureUtil to log root cause when ListeneableFuture is cancelled.

gradle.properties

@@ -1,3 +1,3 @@
-version=5.1.9
+version=5.1.10
 group=com.linkedin.parseq
 org.gradle.parallel=true

subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java

@@ -42,10 +42,18 @@ public static <T> Task<T> fromListenableFuture(ListenableFuture<T> future) {
           @Override
           public boolean cancel(Exception rootReason) {
             if (future.isCancelled()) {
-              return super.cancel(rootReason);
+              boolean taskCancelResult = super.cancel(rootReason);
+              LOGGER.warn("Future is cancelled, therefore cancelling task, result: {}", taskCancelResult);
+              return taskCancelResult;
             }
-            LOGGER.warn("gRPC ListenableFuture is cancelled due to " + rootReason.getMessage(), rootReason);
-            return super.cancel(rootReason) && future.cancel(true);
+            boolean taskCancelResult = super.cancel(rootReason);
+            boolean futureCancelResult = future.cancel(true);
+            LOGGER.warn("gRPC ListenableFuture is cancelled due to {}, taskCancelResult: {}, futureCancelResult {}",
+              rootReason.getMessage(),
+              taskCancelResult,
+              futureCancelResult,
+              rootReason);
+            return taskCancelResult && futureCancelResult;
           }
 
           @Override