This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 7dd3722 [IOTDB-8] Fix filenode restore deserialization (#96)
add 96f3710 rename postback to sync and reconstruct sync client
add 2f2e1d8 reconstruct thrift sync service
add ab830f9 reconstruct sync server
add 47dcea4 test sync function and modify the implementation of singleton
add c165a8f modify shell scripts about sync
add 0a46869 remove author mark
add 0bbf2f3 fix sonar issues
new 59d1ae8 Merge pull request #101 from apache/Sync-Reconstruct
The 1 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:
...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 +-
...Exception.java => SyncConnectionException.java} | 14 +-
.../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 +++++++++++++++
.../ILogReader.java => utils/FilePathUtils.java} | 26 +-
.../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, 1855 insertions(+), 1727 deletions(-)
rename iotdb/iotdb/bin/{start-postBackClient.bat => start-sync-client.bat}
(94%)
rename iotdb/iotdb/bin/{start-postBackClient.sh => start-sync-client.sh} (90%)
rename iotdb/iotdb/bin/{stop-postBackClient.bat => stop-sync-client.bat} (82%)
rename iotdb/iotdb/bin/{stop-postBackClient.sh => stop-sync-client.sh} (84%)
rename iotdb/iotdb/conf/{iotdb-postbackClient.properties =>
iotdb-sync-client.properties} (91%)
copy iotdb/src/main/java/org/apache/iotdb/db/exception/{SysCheckException.java
=> SyncConnectionException.java} (75%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/postback/receiver/ServerServiceImpl.java
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/postback/sender/FileSenderImpl.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/conf/Constans.java
rename
iotdb/src/main/java/org/apache/iotdb/db/{postback/conf/PostBackSenderConfig.java
=> sync/conf/SyncSenderConfig.java} (54%)
rename
iotdb/src/main/java/org/apache/iotdb/db/{postback/conf/PostBackSenderDescriptor.java
=> sync/conf/SyncSenderDescriptor.java} (52%)
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/receiver/ServerManager.java (74%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/receiver/ServerServiceImpl.java
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileManager.java (67%)
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileSender.java (59%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/sender/FileSenderImpl.java
copy iotdb/src/main/java/org/apache/iotdb/db/{writelog/io/ILogReader.java =>
utils/FilePathUtils.java} (65%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/utils/PostbackUtils.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/SyncUtils.java
rename iotdb/src/test/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileManagerTest.java (81%)
rename
iotdb/src/test/java/org/apache/iotdb/db/{postback/sender/MultipleClientPostBackTest.java
=> sync/sender/MultipleClientSyncTest.java} (96%)
rename
iotdb/src/test/java/org/apache/iotdb/db/{postback/sender/IoTDBSingleClientPostBackTest.java
=> sync/sender/SingleClientSyncTest.java} (88%)
rename iotdb/src/{main/java/org/apache/iotdb/db/postback/utils =>
test/java/org/apache/iotdb/db/sync/test}/RandomNum.java (97%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender1.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient1.java} (95%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender2.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient2.java} (95%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender3.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient3.java} (95%)
rename iotdb/src/{main/java/org/apache/iotdb/db/postback/utils =>
test/java/org/apache/iotdb/db/sync/test}/Utils.java (94%)
rename iotdb/src/test/resources/{start-postBackTest.sh => start-sync-test.sh}
(100%)
rename iotdb/src/test/resources/{stop-postBackTest.sh => stop-sync-test.sh}
(100%)
rename iotdb/src/main/thrift/ServerService.thrift =>
service-rpc/src/main/thrift/sync.thrift (64%)
