chore: DebugCommand.tsubakuroTransactionClose(): Added message log

FOLLOW UP: b9832d7
project-tsurugi · Jun 14, 2024 · affd6d9 · affd6d9
1 parent b9832d7
commit affd6d9
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...ng-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java b/...ng-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);