do flush() after writing a request to outStream

project-tsurugi · Sep 4, 2023 · 741368a · 741368a
1 parent b5aea9c
commit 741368a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/modules/stream/src/main/java/com/tsurugidb/tsubakuro/channel/stream/StreamLink.java b/modules/stream/src/main/java/com/tsurugidb/tsubakuro/channel/stream/StreamLink.java
@@ -210,6 +210,7 @@ private void send(byte i, int s) throws IOException {  // SESSION_HELLO, RESULT_
                 throw new IOException("socket is already closed");
             }
             outStream.write(header, 0, header.length);
+            outStream.flush();
         }
         LOG.trace("send {}, slot = {}", ((i == REQUEST_SESSION_HELLO) ? "SESSION_HELLO" : "RESULT_SET_BYE_OK"), s); //$NON-NLS-1$
     }
@@ -239,6 +240,7 @@ public void send(int s, byte[] frameHeader, byte[] payload, ChannelResponse chan
                     outStream.write(frameHeader, 0, frameHeader.length);
                     outStream.write(payload, 0, payload.length);
                 }
+                outStream.flush();
             } catch (IOException e) {
                 channelResponse.setMainResponse(e);
                 return;