From c79ed3bf04244cdc0ca70e59b1cda5f75f7cfbee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=80=E4=B8=AA=E4=B8=8D=E7=9F=A5=E5=90=8D=E7=9A=84Java?= =?UTF-8?q?=E9=9D=93=E4=BB=94?= Date: Fri, 3 Feb 2023 15:11:57 +0800 Subject: [PATCH] optimized sync on channel write (#11440) --- .../java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java | 2 +- .../org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java index 0b17c2b05a..6e0265942e 100644 --- a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java +++ b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java @@ -265,7 +265,7 @@ public class TripleInvoker extends AbstractInvoker { if (!super.isAvailable()) { return false; } - return connectionClient.isAvailable(); + return connectionClient.isConnected(); } @Override diff --git a/dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java b/dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java index 5b21e55c34..976d1941c7 100644 --- a/dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java +++ b/dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java @@ -53,7 +53,7 @@ class TripleInvokerTest { .thenReturn(connectionClient); when(connectionClient.getChannel(true)) .thenReturn(channel); - when(connectionClient.isAvailable()).thenReturn(true); + when(connectionClient.isConnected()).thenReturn(true); ExecutorService executorService = ExecutorRepository.getInstance(url.getOrDefaultApplicationModel()) .createExecutorIfAbsent(url);