Skip to content

Commit f2803c3

Browse files
committed
fix: heartbeat connection lacks the assignment of connectionTimeout
1 parent 3953637 commit f2803c3

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/java/com/actiontech/dble/net/connection/AbstractConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -459,7 +459,7 @@ protected void innerWrite(ByteBuffer buffer, @Nonnull EnumSet<WriteFlag> writeFl
459459
if (buffer != null) {
460460
recycle(buffer);
461461
}
462-
this.cleanup(null);
462+
this.cleanup("it will not writeDirectly because connection has been closed.");
463463
return;
464464
}
465465
//filter out useless write

src/main/java/com/actiontech/dble/net/connection/BackendConnection.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ public BackendConnection(NetworkChannel channel, SocketWR socketWR, ReadTimeStat
4040
super(channel, socketWR);
4141
this.instance = instance;
4242
DbInstanceConfig config = instance.getConfig();
43+
this.connectionTimeout = config.getPoolConfig().getConnectionTimeout();
4344
this.host = config.getIp();
4445
this.port = config.getPort();
4546
this.flowLowLevel = config.getPoolConfig().getFlowLowLevel();

0 commit comments

Comments
 (0)