Skip to content

Commit 1e4c552

Browse files
authored
Add TCP_NODELAY to proxy connections and PolyphenyTlsClient (#525)
1 parent 606cae7 commit 1e4c552

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

core/src/main/java/org/polypheny/db/docker/DockerContainer.java

+2
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import java.net.ServerSocket;
2525
import java.net.Socket;
2626
import java.net.SocketException;
27+
import java.net.StandardSocketOptions;
2728
import java.nio.charset.StandardCharsets;
2829
import java.util.HashMap;
2930
import java.util.List;
@@ -218,6 +219,7 @@ private ServerSocket startServer( int port ) {
218219
while ( true ) {
219220
try {
220221
Socket local = server.accept();
222+
local.setOption( StandardSocketOptions.TCP_NODELAY, true );
221223
DockerInstance dockerInstance = getDockerInstance().orElseThrow( () -> new IOException( "Not connected to docker host" ) );
222224
startProxyForConnection( dockerInstance, local, port );
223225
} catch ( IOException e ) {

core/src/main/java/org/polypheny/db/docker/PolyphenyTlsClient.java

+2
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import java.io.OutputStream;
2222
import java.net.InetSocketAddress;
2323
import java.net.Socket;
24+
import java.net.StandardSocketOptions;
2425
import java.security.SecureRandom;
2526
import java.util.Optional;
2627
import lombok.extern.slf4j.Slf4j;
@@ -85,6 +86,7 @@ static PolyphenyTlsClient connect( String context, String hostname, int port ) t
8586
byte[] serverCertificate = PolyphenyCertificateManager.loadServerCertificate( context, hostname );
8687
Socket s = new Socket();
8788
s.connect( new InetSocketAddress( hostname, port ), 5000 );
89+
s.setOption( StandardSocketOptions.TCP_NODELAY, true );
8890
try {
8991
PolyphenyTlsClient client = new PolyphenyTlsClient( kp, serverCertificate, s.getInputStream(), s.getOutputStream() );
9092
client.socket = s;

0 commit comments

Comments
 (0)