This is an automated email from the ASF dual-hosted git repository. lta pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 59d1ae8d7654d71935f9666acfa0dd9fc711da7f Merge: 7dd3722 0bbf2f3 Author: Tianan Li <[email protected]> AuthorDate: Fri Mar 22 13:58:02 2019 +0800 Merge pull request #101 from apache/Sync-Reconstruct [IOTDB-51]Reimplement post-back module, rename it to synchronization module ...rt-postBackClient.bat => start-sync-client.bat} | 4 +- ...tart-postBackClient.sh => start-sync-client.sh} | 4 +- ...top-postBackClient.bat => stop-sync-client.bat} | 4 +- ...{stop-postBackClient.sh => stop-sync-client.sh} | 6 +- iotdb/iotdb/conf/iotdb-engine.properties | 14 +- ...ent.properties => iotdb-sync-client.properties} | 11 +- .../org/apache/iotdb/db/concurrent/ThreadName.java | 5 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 24 +- .../db/engine/filenode/FileNodeProcessor.java | 12 +- .../db/exception/SyncConnectionException.java} | 72 +- .../db/postback/receiver/ServerServiceImpl.java | 701 ------------------- .../iotdb/db/postback/sender/FileSenderImpl.java | 510 -------------- .../java/org/apache/iotdb/db/service/IoTDB.java | 2 +- .../org/apache/iotdb/db/sync/conf/Constans.java | 47 ++ .../conf/SyncSenderConfig.java} | 74 +- .../conf/SyncSenderDescriptor.java} | 87 ++- .../{postback => sync}/receiver/ServerManager.java | 35 +- .../iotdb/db/sync/receiver/ServerServiceImpl.java | 757 +++++++++++++++++++++ .../db/{postback => sync}/sender/FileManager.java | 91 +-- .../db/{postback => sync}/sender/FileSender.java | 27 +- .../iotdb/db/sync/sender/FileSenderImpl.java | 544 +++++++++++++++ .../org/apache/iotdb/db/utils/FilePathUtils.java} | 72 +- .../org/apache/iotdb/db/utils/PostbackUtils.java | 157 ----- .../java/org/apache/iotdb/db/utils/SyncUtils.java | 126 ++++ .../filenodev2/FileNodeManagerBenchmark.java | 2 +- .../{postback => sync}/sender/FileManagerTest.java | 80 +-- .../sender/MultipleClientSyncTest.java} | 10 +- .../sender/SingleClientSyncTest.java} | 109 ++- .../org/apache/iotdb/db/sync/test}/RandomNum.java | 2 +- .../iotdb/db/sync/test/SyncTestClient1.java} | 15 +- .../iotdb/db/sync/test/SyncTestClient2.java} | 13 +- .../iotdb/db/sync/test/SyncTestClient3.java} | 13 +- .../java/org/apache/iotdb/db/sync/test}/Utils.java | 6 +- .../{start-postBackTest.sh => start-sync-test.sh} | 0 .../{stop-postBackTest.sh => stop-sync-test.sh} | 0 .../src/main/thrift/sync.thrift | 26 +- 37 files changed, 1910 insertions(+), 1776 deletions(-)
