[misc] socket flushing correction

mariadb-corporation · Sep 7, 2022 · 1e5f510 · 1e5f510
1 parent 9a972b1
commit 1e5f510
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/org/mariadb/jdbc/client/socket/impl/CompressOutputStream.java b/src/main/java/org/mariadb/jdbc/client/socket/impl/CompressOutputStream.java
@@ -131,6 +131,7 @@ public void write(byte[] b, int off, int len) throws IOException {
 
         out.write(header, 0, 7);
         out.write(compressedBytes, 0, compressLen);
+        out.flush();
       }
     }
   }

diff --git a/src/main/java/org/mariadb/jdbc/client/socket/impl/PacketWriter.java b/src/main/java/org/mariadb/jdbc/client/socket/impl/PacketWriter.java
@@ -832,8 +832,7 @@ protected void writeSocket(boolean commandEnd) throws IOException {
       buf[3] = this.sequence.incrementAndGet();
       checkMaxAllowedLength(pos - 4);
       out.write(buf, 0, pos);
-      out.flush();
-
+      if (commandEnd) out.flush();
       cmdLength += pos - 4;
 
       if (logger.isTraceEnabled()) {