From affd6d910aceaa1c116f5bf892d21769e98dfa52 Mon Sep 17 00:00:00 2001
From: Hishida Masato <hishida@nautilus-technologies.com>
Date: Fri, 14 Jun 2024 17:18:12 +0900
Subject: [PATCH] chore: DebugCommand.tsubakuroTransactionClose(): Added
 message log FOLLOW UP: b9832d70a4a67814eca05529aec5a848ca3e2828

---
 .../benchmark/costaccounting/debug/DebugCommand.java     | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java b/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java
index 279b694..0c5a2be 100755
--- a/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java
+++ b/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java
@@ -203,11 +203,15 @@ private void tsubakuroResultSetClose() throws Exception {
                     }
                 } catch (ServerException | IOException | InterruptedException e) {
                     var message = e.getMessage();
+                    LOG.info("{}.message={}", e.getClass().getSimpleName(), message);
                     if (message.contains("already closed")) {
                         return;
                     }
                     LOG.error("thread error", e);
                     throw new RuntimeException(e);
+                } catch (Throwable e) {
+                    LOG.error("thread error", e);
+                    throw e;
                 }
             });
             threadList.add(thread);
@@ -288,6 +292,7 @@ private void tsubakuroTransactionClose() throws Exception {
                         }
                     } catch (IOException e) {
                         var message = e.getMessage();
+                        LOG.info("IOException.message={}", message);
                         if (message.contains("The wire was closed before receiving a response to this request")) {
                             return;
                         }
@@ -307,6 +312,7 @@ private void tsubakuroTransactionClose() throws Exception {
                         throw new RuntimeException(e);
                     } catch (ServerException e) {
                         var message = e.getMessage();
+                        LOG.info("ServerException.message={}", message);
                         if (message.contains("Current transaction is inactive (maybe aborted already.)")) {
                             return;
                         }
@@ -318,6 +324,9 @@ private void tsubakuroTransactionClose() throws Exception {
                     } catch (InterruptedException e) {
                         LOG.error("thread error", e);
                         throw new RuntimeException(e);
+                    } catch (Throwable e) {
+                        LOG.error("thread error", e);
+                        throw e;
                     }
                 });
                 threadList.add(thread);