From b9832d70a4a67814eca05529aec5a848ca3e2828 Mon Sep 17 00:00:00 2001
From: Hishida Masato <hishida@nautilus-technologies.com>
Date: Thu, 13 Jun 2024 17:06:11 +0900
Subject: [PATCH] fix: DebugCommand: update message

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

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 9ec8ef1..279b694 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
@@ -202,6 +202,10 @@ private void tsubakuroResultSetClose() throws Exception {
                         }
                     }
                 } catch (ServerException | IOException | InterruptedException e) {
+                    var message = e.getMessage();
+                    if (message.contains("already closed")) {
+                        return;
+                    }
                     LOG.error("thread error", e);
                     throw new RuntimeException(e);
                 }
@@ -296,7 +300,7 @@ private void tsubakuroTransactionClose() throws Exception {
                         if (message.contains("already closed")) { // wire
                             return;
                         }
-                        if (message.contains("Server crashed")) {
+                        if (message.contains("lost connection")) {
                             return;
                         }
                         LOG.error("thread error", e);