You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/13 09:50:14 UTC
[iotdb] branch xingtanzjr/modification_pr updated (1fe96960fa -> b9a8098146)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/modification_pr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1fe96960fa make intercal_ip as default 127.0.0.1
add 9e1a508be4 [IOTDB-2897] Fix wal recover deadlock (#5499)
add f60c584f4d New sync framework with TsFileSync (#5353)
add 47e2af285a [IOTDB-2871] Data node client to connect with config node (#5488)
add b9a8098146 Merge branch 'master' into xingtanzjr/modification_pr
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 67 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 -
.../apache/iotdb/cluster/utils/StatusUtils.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 10 +-
.../iotdb/confignode/manager/ConsensusManager.java | 4 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 396 +++++++---
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 493 ++++++++++---
.../sync/IoTDBSyncReceiverCollectorIT.java | 513 +++++++++++++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 357 +++++++++
.../sync/IoTDBSyncReceiverLoaderIT.java | 210 ++++++
.../db/integration/sync/IoTDBSyncSenderIT.java | 304 ++++++++
.../iotdb/db/integration/sync/SyncTestUtil.java | 203 ++++++
.../db/integration/sync/TransportClientMock.java | 69 ++
.../src/test/resources/iotdb-engine.properties | 3 +-
integration/src/test/resources/logback-test.xml | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 14 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +
.../apache/iotdb/commons/utils/StatusUtils.java | 3 -
.../resources/conf/iotdb-engine.properties | 19 +-
.../resources/conf/iotdb-sync-client.properties | 35 -
.../assembly/resources/tools/start-sync-client.bat | 71 --
.../assembly/resources/tools/start-sync-client.sh | 54 --
.../assembly/resources/tools/stop-sync-client.bat | 23 -
.../assembly/resources/tools/stop-sync-client.sh | 30 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 309 ++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 65 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 43 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 16 +-
.../iotdb/db/engine/modification/Deletion.java | 23 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 63 +-
.../db/engine/storagegroup/TsFileManager.java | 38 +
.../db/engine/storagegroup/TsFileProcessor.java | 23 +
.../dataregion/StorageGroupManager.java | 10 +
.../sync/PipeDataLoadBearableException.java} | 10 +-
.../sync/PipeDataLoadException.java} | 10 +-
.../sync/PipeDataLoadUnbearableException.java} | 10 +-
.../sync/PipeException.java} | 21 +-
.../sync/PipeServerException.java} | 21 +-
.../PipeSinkException.java} | 24 +-
.../apache/iotdb/db/metadata/LocalConfigNode.java | 11 +
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1 +
.../traverser/collector/MeasurementCollector.java | 4 +
.../db/metadata/schemaregion/SchemaRegion.java | 20 +
.../apache/iotdb/db/qp/constant/SQLConstant.java | 26 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 189 ++++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 14 +-
.../db/qp/logical/sys/CreatePipeOperator.java | 69 ++
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 61 ++
.../logical/sys/DropPipeOperator.java} | 32 +-
.../logical/sys/DropPipeSinkOperator.java} | 33 +-
.../logical/sys/ShowPipeOperator.java} | 33 +-
.../logical/sys/ShowPipeServerOperator.java} | 26 +-
.../logical/sys/ShowPipeSinkOperator.java} | 33 +-
.../logical/sys/ShowPipeSinkTypeOperator.java} | 27 +-
.../logical/sys/StartPipeOperator.java} | 32 +-
.../logical/sys/StartPipeServerOperator.java} | 28 +-
.../logical/sys/StopPipeOperator.java} | 32 +-
.../logical/sys/StopPipeServerOperator.java} | 28 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 10 +
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 15 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 +++
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 +++
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 10 +
.../physical/sys/DropPipeSinkPlan.java} | 28 +-
.../physical/sys/OperatePipePlan.java} | 28 +-
.../physical/sys/ShowPipePlan.java} | 22 +-
.../physical/sys/ShowPipeServerPlan.java} | 11 +-
.../physical/sys/ShowPipeSinkPlan.java} | 23 +-
.../physical/sys/ShowPipeSinkTypePlan.java} | 11 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
.../db/qp/physical/sys/StartPipeServerPlan.java | 56 ++
.../db/qp/physical/sys/StopPipeServerPlan.java | 56 ++
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 190 ++++-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 15 +
.../java/org/apache/iotdb/db/service/DataNode.java | 67 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 7 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 85 +--
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 100 +++
.../iotdb/db/sync/conf/SyncSenderConfig.java | 127 ----
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 124 ----
.../org/apache/iotdb/db/sync/package-info.java | 38 -
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 85 +++
.../apache/iotdb/db/sync/pipedata/PipeData.java | 96 +++
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 98 +++
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 177 +++++
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 438 +++++++++++
.../queue/PipeDataQueue.java} | 21 +-
.../sync/pipedata/queue/PipeDataQueueFactory.java | 57 ++
.../iotdb/db/sync/receiver/ReceiverService.java | 278 +++++++
.../db/sync/receiver/collector/Collector.java | 170 +++++
.../db/sync/receiver/load/DeletionLoader.java | 48 ++
.../iotdb/db/sync/receiver/load/FileLoader.java | 203 ------
.../db/sync/receiver/load/FileLoaderManager.java | 213 ------
.../iotdb/db/sync/receiver/load/IFileLoader.java | 50 --
.../iotdb/db/sync/receiver/load/ILoadLogger.java | 57 --
.../receiver/load/{LoadType.java => ILoader.java} | 12 +-
.../iotdb/db/sync/receiver/load/LoadLogger.java | 72 --
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 60 ++
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 ++
.../iotdb/db/sync/receiver/manager/PipeInfo.java | 85 +++
.../db/sync/receiver/manager/PipeMessage.java | 76 ++
.../db/sync/receiver/manager/ReceiverManager.java | 216 ++++++
.../sync/receiver/recover/ISyncReceiverLogger.java | 50 --
.../receiver/recover/SyncReceiverLogAnalyzer.java | 154 ----
.../sync/receiver/recover/SyncReceiverLogger.java | 72 --
.../db/sync/receiver/recovery/ReceiverLog.java | 127 ++++
.../receiver/recovery/ReceiverLogAnalyzer.java | 157 ++++
.../db/sync/receiver/transfer/SyncServiceImpl.java | 370 ----------
.../db/sync/sender/manage/ISyncFileManager.java | 72 --
.../db/sync/sender/manage/SyncFileManager.java | 291 --------
.../db/sync/sender/manager/SchemaSyncManager.java | 163 +++++
.../db/sync/sender/manager/TsFileSyncManager.java | 118 +++
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 97 +++
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 106 +++
.../pipe/PipeSink.java} | 30 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 334 +++++++++
.../sender/recover/ISyncSenderLogAnalyzer.java | 47 --
.../db/sync/sender/recover/ISyncSenderLogger.java | 67 --
.../sync/sender/recover/SyncSenderLogAnalyzer.java | 128 ----
.../db/sync/sender/recover/SyncSenderLogger.java | 72 --
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 172 +++++
.../db/sync/sender/recovery/SenderLogger.java | 141 ++++
.../db/sync/sender/recovery/TsFilePipeLogger.java | 150 ++++
.../db/sync/sender/service/SenderService.java | 417 +++++++++++
.../db/sync/sender/service/TransportHandler.java | 127 ++++
.../iotdb/db/sync/sender/transfer/ISyncClient.java | 95 ---
.../iotdb/db/sync/sender/transfer/SyncClient.java | 810 ---------------------
.../client/ITransportClient.java} | 20 +-
.../db/sync/transport/client/TransportClient.java | 527 ++++++++++++++
.../conf/TransportConfig.java} | 26 +-
.../conf/TransportConstant.java} | 21 +-
.../server/TransportServerManager.java} | 80 +-
.../server/TransportServerManagerMBean.java} | 6 +-
.../server/TransportServerThriftHandler.java} | 30 +-
.../transport/server/TransportServiceImpl.java | 385 ++++++++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 8 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 ---
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 4 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 28 +
.../sync/pipedata/BufferedPipeDataQueueTest.java | 542 ++++++++++++++
.../iotdb/db/sync/pipedata/PipeDataTest.java | 86 +++
.../db/sync/receiver/load/FileLoaderTest.java | 405 -----------
.../sync/receiver/manager/ReceiverManagerTest.java | 98 +++
.../recover/SyncReceiverLogAnalyzerTest.java | 229 ------
.../receiver/recover/SyncReceiverLoggerTest.java | 115 ---
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 124 ++++
.../db/sync/sender/manage/SyncFileManagerTest.java | 350 ---------
.../sender/recover/SyncSenderLogAnalyzerTest.java | 201 -----
.../sync/sender/recover/SyncSenderLoggerTest.java | 112 ---
.../db/sync/sender/transfer/SyncClientTest.java | 161 ----
.../db/sync/transport/TransportServiceTest.java | 205 ++++++
server/src/test/resources/iotdb-engine.properties | 3 +-
server/src/test/resources/logback-test.xml | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
thrift-sync/src/main/thrift/sync.thrift | 51 --
thrift-sync/src/main/thrift/transport.thrift | 90 +++
159 files changed, 10665 insertions(+), 5846 deletions(-)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverCollectorIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverLoaderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncSenderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/SyncTestUtil.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/TransportClientMock.java
delete mode 100644 server/src/assembly/resources/conf/iotdb-sync-client.properties
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.sh
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => exception/sync/PipeDataLoadBearableException.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => exception/sync/PipeDataLoadException.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => exception/sync/PipeDataLoadUnbearableException.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => exception/sync/PipeException.java} (63%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => exception/sync/PipeServerException.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/exception/{SyncDeviceOwnerConflictException.java => sync/PipeSinkException.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeSinkOperator.java
copy server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/DropPipeOperator.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/DropPipeSinkOperator.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/ShowPipeOperator.java} (51%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/SyncServerManagerMBean.java => qp/logical/sys/ShowPipeServerOperator.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/ShowPipeSinkOperator.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => qp/logical/sys/ShowPipeSinkTypeOperator.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/StartPipeOperator.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/SyncServerManagerMBean.java => qp/logical/sys/StartPipeServerOperator.java} (54%)
rename server/src/main/java/org/apache/iotdb/db/{exception/SyncDeviceOwnerConflictException.java => qp/logical/sys/StopPipeOperator.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/SyncServerManagerMBean.java => qp/logical/sys/StopPipeServerOperator.java} (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipeSinkPlan.java
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => qp/physical/sys/DropPipeSinkPlan.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => qp/physical/sys/OperatePipePlan.java} (57%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => qp/physical/sys/ShowPipePlan.java} (68%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => qp/physical/sys/ShowPipeServerPlan.java} (82%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/SyncServerManagerMBean.java => qp/physical/sys/ShowPipeSinkPlan.java} (71%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => qp/physical/sys/ShowPipeSinkTypePlan.java} (81%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StartPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StopPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncPathUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderConfig.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderDescriptor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/package-info.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/DeletionPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/PipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/SchemaPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/TsFilePipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/BufferedPipeDataQueue.java
copy server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManagerMBean.java => pipedata/queue/PipeDataQueue.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueueFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/ReceiverService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/collector/Collector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/DeletionLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/IFileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoadLogger.java
rename server/src/main/java/org/apache/iotdb/db/sync/receiver/load/{LoadType.java => ILoader.java} (77%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/SchemaLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/TsFileLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeMessage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/ISyncReceiverLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLog.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/ISyncFileManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/IoTDBPipeSink.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/Pipe.java
copy server/src/main/java/org/apache/iotdb/db/sync/{receiver/recover/ISyncReceiverLogAnalyzer.java => sender/pipe/PipeSink.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/TsFilePipe.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/TsFilePipeLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/SenderService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/TransportHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/ISyncClient.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
copy server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManagerMBean.java => transport/client/ITransportClient.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/TransportClient.java
copy server/src/main/java/org/apache/iotdb/db/sync/{receiver/recover/ISyncReceiverLogAnalyzer.java => transport/conf/TransportConfig.java} (53%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/recover/ISyncReceiverLogAnalyzer.java => transport/conf/TransportConstant.java} (62%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManager.java => transport/server/TransportServerManager.java} (58%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManagerMBean.java => transport/server/TransportServerManagerMBean.java} (91%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerThriftHandler.java => transport/server/TransportServerThriftHandler.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/SyncUtils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/BufferedPipeDataQueueTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/PipeDataTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLoggerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/transport/TransportServiceTest.java
delete mode 100755 thrift-sync/src/main/thrift/sync.thrift
create mode 100644 thrift-sync/src/main/thrift/transport.thrift