You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/10/28 09:13:44 UTC

[incubator-iotdb] branch reimpl_sync updated (6c01bf3 -> d5d8ede)

This is an automated email from the ASF dual-hosted git repository.

lta pushed a change to branch reimpl_sync
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


    from 6c01bf3  fix ut
     add d5d8ede  add reject policy while there are two sender sync data of the same device to the same receiver

No new revisions were added by this update.

Summary of changes:
 .../UserGuide/9-System Tools/1-Sync Tool.md        |   3 +
 .../UserGuide/9-System Tools/1-Sync Tool.md        |   3 +
 ....java => SyncDeviceOwnerConflictException.java} |  13 +--
 .../db/sync/{sender => }/conf/SyncConstant.java    |   8 +-
 .../sync/{sender => }/conf/SyncSenderConfig.java   |   4 +-
 .../{sender => }/conf/SyncSenderDescriptor.java    |   2 +-
 .../iotdb/db/sync/receiver/load/FileLoader.java    |   9 +-
 .../db/sync/receiver/load/FileLoaderManager.java   | 126 ++++++++++++++++++++-
 .../receiver/recover/SyncReceiverLogAnalyzer.java  |   2 +-
 .../db/sync/receiver/transfer/SyncServiceImpl.java |  22 +++-
 .../db/sync/sender/manage/SyncFileManager.java     |   2 +-
 .../sync/sender/recover/SyncSenderLogAnalyzer.java |   2 +-
 .../sync/sender/transfer/DataTransferManager.java  |  40 ++++---
 .../sync/sender/transfer/IDataTransferManager.java |   3 +-
 .../java/org/apache/iotdb/db/utils/SyncUtils.java  |   2 +-
 .../db/sync/receiver/load/FileLoaderTest.java      |   2 +-
 .../recover/SyncReceiverLogAnalyzerTest.java       |   2 +-
 .../receiver/recover/SyncReceiverLoggerTest.java   |   2 +-
 .../db/sync/sender/manage/SyncFileManagerTest.java |   4 +-
 .../sender/recover/SyncSenderLogAnalyzerTest.java  |   6 +-
 .../sync/sender/recover/SyncSenderLoggerTest.java  |   6 +-
 .../sender/transfer/DataTransferManagerTest.java   |   4 +-
 service-rpc/src/main/thrift/sync.thrift            |   4 +-
 23 files changed, 210 insertions(+), 61 deletions(-)
 copy server/src/main/java/org/apache/iotdb/db/exception/{FlushRunTimeException.java => SyncDeviceOwnerConflictException.java} (73%)
 rename server/src/main/java/org/apache/iotdb/db/sync/{sender => }/conf/SyncConstant.java (90%)
 rename server/src/main/java/org/apache/iotdb/db/sync/{sender => }/conf/SyncSenderConfig.java (97%)
 rename server/src/main/java/org/apache/iotdb/db/sync/{sender => }/conf/SyncSenderDescriptor.java (98%)