You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/11/13 06:51:34 UTC
[iotdb] branch cluster_new updated (6273154 -> 002d3aa)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 6273154 add missing error message
new 97714fe close the socket when TException occurs
new e86ed5f add TElasticFramedTransport
new 3f95c4a add some debug message
new 3ffe533 revise the log
new 57caca0 remove debug message
new 67702f1 merge cluster_new
new ef795b0 reformat the code
new 002d3aa Merge pull request #2041 from neuyilan/apache_cluster_new_1110_sync_bug
The 5599 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 4 +-
.../cluster/client/rpcutils/AutoScalingBuffer.java | 28 ++---
...rt.java => AutoScalingBufferReadTransport.java} | 29 +++---
.../rpcutils/AutoScalingBufferWriteTransport.java | 84 +++++++++++++++
.../client/rpcutils/TElasticFramedTransport.java | 113 +++++++++++++++++++++
.../TimeoutChangeableTFastFramedTransport.java | 5 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 10 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 1 +
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 2 +-
.../cluster/log/catchup/SnapshotCatchUpTask.java | 13 ++-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 23 +++--
.../cluster/log/snapshot/PullSnapshotTask.java | 11 +-
.../cluster/query/manage/QueryCoordinator.java | 13 ++-
.../apache/iotdb/cluster/server/ClientServer.java | 8 +-
.../iotdb/cluster/server/DataClusterServer.java | 22 ++--
.../apache/iotdb/cluster/server/RaftServer.java | 8 +-
.../cluster/server/heartbeat/HeartbeatServer.java | 4 +-
.../cluster/server/member/MetaGroupMember.java | 19 +++-
.../iotdb/cluster/server/member/RaftMember.java | 7 +-
.../cluster/server/service/BaseSyncService.java | 11 +-
.../cluster/server/service/DataSyncService.java | 48 +++++++--
.../cluster/server/service/MetaSyncService.java | 23 +++--
.../apache/iotdb/cluster/utils/ClusterUtils.java | 6 +-
23 files changed, 387 insertions(+), 105 deletions(-)
copy example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java => cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/AutoScalingBuffer.java (62%)
copy cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/{TimeoutChangeableTFastFramedTransport.java => AutoScalingBufferReadTransport.java} (58%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/AutoScalingBufferWriteTransport.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TElasticFramedTransport.java