diff --git a/modules/ipc/src/main/native/include/udf_wires.h b/modules/ipc/src/main/native/include/udf_wires.h index 0a31f48b..9a231035 100644 --- a/modules/ipc/src/main/native/include/udf_wires.h +++ b/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 lock(mtx_set_); diff --git a/modules/ipc/src/main/native/src/wireJNI.cpp b/modules/ipc/src/main/native/src/wireJNI.cpp index 86ffe54e..354105b5 100644 --- a/modules/ipc/src/main/native/src/wireJNI.cpp +++ b/modules/ipc/src/main/native/src/wireJNI.cpp @@ -161,6 +161,7 @@ JNIEXPORT void JNICALL Java_com_tsurugidb_tsubakuro_channel_ipc_IpcLink_closeNat session_wire_container* swc = reinterpret_cast(static_cast(handle)); if (swc != nullptr) { + swc->get_request_wire().disconnect(); swc->get_response_wire().close(); } }