Fix unix transport

polypheny · Apr 3, 2024 · 21fe730 · 21fe730
1 parent cb624ab
commit 21fe730
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/plugins/proto-interface/src/main/java/org/polypheny/db/protointerface/PIServer.java b/plugins/proto-interface/src/main/java/org/polypheny/db/protointerface/PIServer.java
@@ -145,7 +145,6 @@ private void acceptLoop( ServerSocketChannel server, ClientManager clientManager
         while ( true ) {
             try {
                 SocketChannel s = server.accept();
-                s.socket().setTcpNoDelay( true );
                 long connectionId = ID_COUNTER.getAndIncrement();
                 Thread t = new Thread( () -> acceptConnection( s, name, connectionId, createTransport, clientManager ), String.format( "ProtoInterface" + name + "ClientConnection%d", connectionId ) );
                 t.start();

diff --git a/...oto-interface/src/main/java/org/polypheny/db/protointerface/transport/PlainTransport.java b/...oto-interface/src/main/java/org/polypheny/db/protointerface/transport/PlainTransport.java
@@ -18,6 +18,7 @@
 
 import java.io.EOFException;
 import java.io.IOException;
+import java.net.StandardSocketOptions;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.nio.channels.SocketChannel;
@@ -98,6 +99,7 @@ public void close() {
 
     public static Transport accept( SocketChannel con ) {
         try {
+            con.setOption( StandardSocketOptions.TCP_NODELAY, true );
             return new PlainTransport( con );
         } catch ( IOException e ) {
             throw new GenericRuntimeException( e );