Skip to content

Commit 147bb9e

Browse files
committed
use tcp no delay
1 parent 8989f98 commit 147bb9e

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

core/src/main/java/tech/ydb/core/impl/pool/NettyChannelFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,7 @@ public ManagedChannel newManagedChannel(String host, int port, String sslHostOve
7676
channelBuilder
7777
.maxInboundMessageSize(INBOUND_MESSAGE_SIZE)
7878
.withOption(ChannelOption.ALLOCATOR, ByteBufAllocator.DEFAULT)
79+
.withOption(ChannelOption.TCP_NODELAY, true)
7980
.intercept(metadataInterceptor());
8081

8182
if (!useDefaultGrpcResolver) {

core/src/main/java/tech/ydb/core/impl/pool/ShadedNettyChannelFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,7 @@ public ManagedChannel newManagedChannel(String host, int port, String sslHostOve
7676
channelBuilder
7777
.maxInboundMessageSize(INBOUND_MESSAGE_SIZE)
7878
.withOption(ChannelOption.ALLOCATOR, ByteBufAllocator.DEFAULT)
79+
.withOption(ChannelOption.TCP_NODELAY, true)
7980
.intercept(metadataInterceptor());
8081

8182
if (!useDefaultGrpcResolver) {

0 commit comments

Comments
 (0)