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/incubator-iotdb.git.
from 7418ed6 fix after merge
add 1991cb2 add unit test
No new revisions were added by this update.
Summary of changes:
.../cluster/client/async/AsyncDataClient.java | 6 +-
.../TimeoutChangeableTFastFramedTransport.java | 7 +
.../cluster/client/sync/SyncClientAdaptor.java | 210 ++++++++-----
.../iotdb/cluster/client/sync/SyncClientPool.java | 2 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 7 +
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 13 +-
.../iotdb/cluster/client/AsyncClientPoolTest.java | 131 --------
.../cluster/client/DataClientProviderTest.java | 54 ++++
.../cluster/client/async/AsyncClientPoolTest.java | 188 +++++++++++
.../cluster/client/async/AsyncDataClientTest.java | 60 ++++
.../async/AsyncDataHeartbeatClientTest.java} | 47 ++-
.../cluster/client/async/AsyncMetaClientTest.java | 60 ++++
.../client/async/AsyncMetaHeartbeatClientTest.java | 44 +--
.../TimeoutChangeableTFastFramedTransportTest.java | 24 ++
.../cluster/client/sync/SyncClientAdaptorTest.java | 345 +++++++++++++++++++++
.../cluster/client/sync/SyncClientPoolTest.java | 157 ++++++++++
.../cluster/client/sync/SyncDataClientTest.java | 80 +++++
.../client/sync/SyncDataHeartbeatClientTest.java | 63 ++++
.../cluster/client/sync/SyncMetaClientTest.java | 62 ++++
.../client/sync/SyncMetaHeartbeatClientTest.java | 63 ++++
.../{TestClient.java => TestAsyncClient.java} | 8 +-
.../cluster/common/TestAsyncClientFactory.java | 2 +-
.../{TestClient.java => TestSyncClient.java} | 19 +-
...ientFactory.java => TestSyncClientFactory.java} | 55 +++-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 4 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 4 +-
.../log/catchup/SnapshotCatchUpTaskTest.java | 4 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 4 +-
.../server/heartbeat/HeartbeatThreadTest.java | 4 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 4 +-
.../tests/tools/importCsv/AbstractScript.java | 4 +-
32 files changed, 1422 insertions(+), 317 deletions(-)
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/AsyncClientPoolTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/DataClientProviderTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncClientPoolTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncDataClientTest.java
copy cluster/src/test/java/org/apache/iotdb/cluster/{common/TestClient.java =>
client/async/AsyncDataHeartbeatClientTest.java} (52%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaClientTest.java
copy tsfile/src/test/java/org/apache/iotdb/tsfile/common/LRUCacheTest.java =>
cluster/src/test/java/org/apache/iotdb/cluster/client/async/AsyncMetaHeartbeatClientTest.java
(54%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/rpcutils/TimeoutChangeableTFastFramedTransportTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptorTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncClientPoolTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncDataClientTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncDataHeartbeatClientTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncMetaClientTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/client/sync/SyncMetaHeartbeatClientTest.java
copy cluster/src/test/java/org/apache/iotdb/cluster/common/{TestClient.java =>
TestAsyncClient.java} (87%)
rename cluster/src/test/java/org/apache/iotdb/cluster/common/{TestClient.java
=> TestSyncClient.java} (64%)
copy
cluster/src/test/java/org/apache/iotdb/cluster/common/{TestAsyncClientFactory.java
=> TestSyncClientFactory.java} (50%)
