zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Stop do sync when sync is no need. (#5882)

Browse Source
This commit is contained in:
杨翊 SionYang 2021-05-28 14:08:25 +08:00 committed by GitHub
parent 15c71831e7
commit 09c7293085
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
naming/src/main/java/com/alibaba/nacos/naming/consistency/ephemeral/distro/v2/DistroClientTransportAgent.java
View File

@ -87,6 +87,7 @@ public class DistroClientTransportAgent implements DistroTransportAgent {
public void syncData(DistroData data, String targetServer, DistroCallback callback) { public void syncData(DistroData data, String targetServer, DistroCallback callback) {
if (isNoExistTarget(targetServer)) { if (isNoExistTarget(targetServer)) {
callback.onSuccess(); callback.onSuccess();
return;
} }
DistroDataRequest request = new DistroDataRequest(data, data.getType()); DistroDataRequest request = new DistroDataRequest(data, data.getType());
Member member = memberManager.find(targetServer); Member member = memberManager.find(targetServer);
@ -123,6 +124,7 @@ public class DistroClientTransportAgent implements DistroTransportAgent {
public void syncVerifyData(DistroData verifyData, String targetServer, DistroCallback callback) { public void syncVerifyData(DistroData verifyData, String targetServer, DistroCallback callback) {
if (isNoExistTarget(targetServer)) { if (isNoExistTarget(targetServer)) {
callback.onSuccess(); callback.onSuccess();
return;
} }
DistroDataRequest request = new DistroDataRequest(verifyData, DataOperation.VERIFY); DistroDataRequest request = new DistroDataRequest(verifyData, DataOperation.VERIFY);
Member member = memberManager.find(targetServer); Member member = memberManager.find(targetServer);