natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

optimized sync on channel write (#11440)

This commit is contained in:
一个不知名的Java靓仔 2023-02-03 15:11:57 +08:00 committed by GitHub
parent db8dee1165
commit c79ed3bf04
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java
View File

@ -265,7 +265,7 @@ public class TripleInvoker<T> extends AbstractInvoker<T> {
if (!super.isAvailable()) {
return false;
}
return connectionClient.isAvailable();
return connectionClient.isConnected();
}
@Override

2
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java
View File

@ -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);