You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by do...@apache.org on 2019/04/24 08:56:14 UTC
[incubator-iotdb] branch cluster_read updated: remove disconnect
function
This is an automated email from the ASF dual-hosted git repository.
dope pushed a commit to branch cluster_read
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster_read by this push:
new ac17966 remove disconnect function
ac17966 is described below
commit ac17966077e052f5424a7b29ecae6eef9259b6ba
Author: MyXOF <xu...@163.com>
AuthorDate: Wed Apr 24 16:56:02 2019 +0800
remove disconnect function
---
.../apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
index c5e563b..9e99d7f 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/rpc/raft/impl/RaftNodeAsClientManager.java
@@ -257,7 +257,6 @@ public class RaftNodeAsClientManager {
@Override
public void onResponse(Object result) {
BasicResponse response = (BasicResponse) result;
- boltClientService.disconnect(leader.getEndpoint());
releaseClient(RaftNodeAsClient.this);
qpTask.run(response);
}
@@ -266,7 +265,6 @@ public class RaftNodeAsClientManager {
public void onException(Throwable e) {
LOGGER.error("Bolt rpc client occurs errors when handling Request", e);
qpTask.setTaskState(TaskState.EXCEPTION);
- boltClientService.disconnect(leader.getEndpoint());
releaseClient(RaftNodeAsClient.this);
qpTask.run(null);
}
@@ -278,7 +276,6 @@ public class RaftNodeAsClientManager {
}, TASK_TIMEOUT_MS);
} catch (RemotingException | InterruptedException e) {
LOGGER.error(e.getMessage());
- boltClientService.disconnect(leader.getEndpoint());
qpTask.setTaskState(TaskState.EXCEPTION);
releaseClient(RaftNodeAsClient.this);
qpTask.run(null);
@@ -295,7 +292,6 @@ public class RaftNodeAsClientManager {
} catch (RemotingException | InterruptedException e) {
return new QueryTask(null, TaskState.EXCEPTION);
} finally {
- boltClientService.disconnect(peerId.getEndpoint());
releaseClient(RaftNodeAsClient.this);
}
}