refactor

apache · May 24, 2024 · 863d12d · 863d12d
1 parent ff61b62
commit 863d12d
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 13 deletions.
diff --git a/...g/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java b/...g/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionConnector.java
@@ -129,7 +129,6 @@ private void doTransfer(final PipeConfigRegionWritePlanEvent pipeConfigRegionWri
               PipeTransferConfigPlanReq.toTPipeTransferReq(
                   pipeConfigRegionWritePlanEvent.getConfigPhysicalPlan()));
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);
@@ -202,7 +201,6 @@ private void doTransfer(final PipeConfigRegionSnapshotEvent snapshotEvent)
                   snapshotEvent.getFileType(),
                   snapshotEvent.toSealTypeString()));
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);

diff --git a/...a/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataNodeSyncConnector.java b/...a/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataNodeSyncConnector.java
@@ -118,9 +118,7 @@ protected void doTransfer(final PipeSchemaRegionWritePlanEvent pipeSchemaRegionW
           compressIfNeeded(
               PipeTransferPlanNodeReq.toTPipeTransferReq(
                   pipeSchemaRegionWritePlanEvent.getPlanNode()));
-
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);

diff --git a/...org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java b/...org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
@@ -179,7 +179,6 @@ private void doTransfer(Pair<TEndPoint, PipeEventBatch> endPointAndBatch) {
     try {
       final TPipeTransferReq req = compressIfNeeded(batchToTransfer.toTPipeTransferReq());
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);
@@ -246,9 +245,7 @@ private void doTransfer(
               : compressIfNeeded(
                   PipeTransferTabletBinaryReq.toTPipeTransferReq(
                       pipeInsertNodeTabletInsertionEvent.getByteBuffer()));
-
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       if (clientAndStatus != null) {
@@ -308,7 +305,6 @@ private void doTransfer(final PipeRawTabletInsertionEvent pipeRawTabletInsertion
                   pipeRawTabletInsertionEvent.convertToTablet(),
                   pipeRawTabletInsertionEvent.isAligned()));
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);
@@ -369,7 +365,6 @@ private void doTransfer(final PipeTsFileInsertionEvent pipeTsFileInsertionEvent)
                 PipeTransferTsFileSealWithModReq.toTPipeTransferReq(
                     modFile.getName(), modFile.length(), tsFile.getName(), tsFile.length()));
         rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
         resp = clientAndStatus.getLeft().pipeTransfer(req);
       } catch (final Exception e) {
         clientAndStatus.setRight(false);
@@ -386,7 +381,6 @@ private void doTransfer(final PipeTsFileInsertionEvent pipeTsFileInsertionEvent)
             compressIfNeeded(
                 PipeTransferTsFileSealReq.toTPipeTransferReq(tsFile.getName(), tsFile.length()));
         rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
         resp = clientAndStatus.getLeft().pipeTransfer(req);
       } catch (final Exception e) {
         clientAndStatus.setRight(false);

diff --git a/...a/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBSchemaRegionConnector.java b/...a/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBSchemaRegionConnector.java
@@ -111,9 +111,7 @@ private void doTransfer(final PipeSchemaRegionSnapshotEvent snapshotEvent)
                   Objects.nonNull(tagLogSnapshotFile) ? tagLogSnapshotFile.length() : 0,
                   snapshotEvent.getDatabaseName(),
                   snapshotEvent.toSealTypeString()));
-
       rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
       resp = clientAndStatus.getLeft().pipeTransfer(req);
     } catch (final Exception e) {
       clientAndStatus.setRight(false);

diff --git a/...src/main/java/org/apache/iotdb/commons/pipe/connector/protocol/IoTDBSslSyncConnector.java b/...src/main/java/org/apache/iotdb/commons/pipe/connector/protocol/IoTDBSslSyncConnector.java
@@ -168,7 +168,6 @@ protected void transferFilePieces(
                       ? getTransferMultiFilePieceReq(file.getName(), position, payLoad)
                       : getTransferSingleFilePieceReq(file.getName(), position, payLoad));
           rateLimitIfNeeded(clientAndStatus.getLeft().getEndPoint(), req.getBody().length);
-
           resp =
               PipeTransferFilePieceResp.fromTPipeTransferResp(
                   clientAndStatus.getLeft().pipeTransfer(req));