disconnect IPC connection at IpcLink.closeNative()

modules/ipc/src/main/native/include/udf_wires.h

@@ -155,9 +155,7 @@ class session_wire_container
         }
     }
 
-    ~session_wire_container() {
-        request_wire_.disconnect();
-    }
+    ~session_wire_container() = default;
 
     bool is_deletable() {
         std::lock_guard<std::mutex> lock(mtx_set_);

modules/ipc/src/main/native/src/wireJNI.cpp

@@ -177,6 +177,7 @@ JNIEXPORT void JNICALL Java_com_tsurugidb_tsubakuro_channel_ipc_IpcLink_destroyN
 
     if (swc != nullptr) {
         if (swc->is_deletable()) {
+            swc->get_request_wire().disconnect();
             delete swc;
         }
     }
@@ -284,10 +285,11 @@ JNIEXPORT void JNICALL Java_com_tsurugidb_tsubakuro_channel_ipc_sql_ResultSetWir
     session_wire_container::resultset_wires_container* rwc = reinterpret_cast<session_wire_container::resultset_wires_container*>(static_cast<std::uintptr_t>(handle));
 
     if (rwc != nullptr) {
-        session_wire_container* envelope = rwc->get_envelope();
-        if (envelope != nullptr) {
-            if (envelope->dispose_resultset_wire(rwc)) {
-                delete envelope;
+        session_wire_container* swc = rwc->get_envelope();
+        if (swc != nullptr) {
+            if (swc->dispose_resultset_wire(rwc)) {
+                swc->get_request_wire().disconnect();
+                delete swc;
             } 
         }
     }

modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/SqlServiceStub.java

@@ -67,6 +67,8 @@ public class SqlServiceStub implements SqlService {
 
     private Timeout closeTimeout = Timeout.DISABLED;
 
+    private boolean resourcesClosed = false;
+
     /**
      * Creates a new instance.
      * @param session the current session
@@ -132,7 +134,13 @@ public Transaction process(ByteBuffer payload) throws IOException, ServerExcepti
             }
             var transactionImpl = new TransactionImpl(detailResponse.getSuccess(), SqlServiceStub.this, resources);
             transactionImpl.setCloseTimeout(closeTimeout);
-            return resources.register(transactionImpl);
+            synchronized (resources) {
+                if (resourcesClosed) {
+                    transactionImpl.close();
+                    throw new IOException("session already closed");
+                }
+                return resources.register(transactionImpl);
+            }
         }
     }
 
@@ -247,7 +255,13 @@ public PreparedStatement process(ByteBuffer payload) throws IOException, ServerE
             }
             var preparedStatementImpl = new PreparedStatementImpl(detailResponse.getPreparedStatementHandle(), SqlServiceStub.this, resources, request);
             preparedStatementImpl.setCloseTimeout(closeTimeout);
-            return resources.register(preparedStatementImpl);
+            synchronized (resources) {
+                if (resourcesClosed) {
+                    preparedStatementImpl.close();
+                    throw new IOException("session already closed");
+                }
+                return resources.register(preparedStatementImpl);
+            }
         }
     }
 
@@ -511,7 +525,13 @@ public ResultSet process(Response response, Timeout timeout) throws IOException,
                 }
                 var resultSetImpl = new ResultSetImpl(resources, metadata, cursor, owner.release(), this, resultSetName, request);
                 resultSetImpl.setCloseTimeout(closeTimeout);
-                return resources.register(resultSetImpl);
+                synchronized (resources) {
+                    if (resourcesClosed) {
+                        resultSetImpl.close();
+                        throw new IOException("session already closed");
+                    }
+                    return resources.register(resultSetImpl);
+                }
             }
         }
 
@@ -830,7 +850,10 @@ public void setCloseTimeout(Timeout timeout) {
     @Override
     public void close() throws ServerException, IOException, InterruptedException {
         LOG.trace("closing underlying resources"); //$NON-NLS-1$
-        resources.close();
+        synchronized (resources) {
+            resources.close();
+            resourcesClosed = true;
+        }
         session.remove(this);
     }