Skip to content

Support strictly unidirectional UDP air-gap transfer - #19063

Merged
jt2594838 merged 5 commits into
masterfrom
feat/air-gap-strict-unidirectional
Nov 2, 2026
Merged

Support strictly unidirectional UDP air-gap transfer#19063
jt2594838 merged 5 commits into
masterfrom
feat/air-gap-strict-unidirectional

Stop air-gap receiver retries when interrupted

358020e
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 2, 2026 in 4m 41s

Quality Gate failed

Failed conditions
C Reliability Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 24 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/airgap/AirGapPseudoTPipeTransferRequest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Override the "equals" method in this class. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafuEHjxf_orAgsFR4&open=AaGafuEHjxf_orAgsFR4&pullRequest=19063

Check failure on line 266 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 17 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvEpjxf_orAgsFR6&open=AaGafvEpjxf_orAgsFR6&pullRequest=19063

Check warning on line 1145 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof AirGapPseudoTPipeTransferRequest airgappseudotpipetransferrequest' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvEpjxf_orAgsFR7&open=AaGafvEpjxf_orAgsFR7&pullRequest=19063

Check warning on line 1165 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use an "AtomicBoolean" for this field; its operations are atomic. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvb5jxf_orAgsFSA&open=AaGafvb5jxf_orAgsFSA&pullRequest=19063

Check warning on line 506 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'try' child has incorrect indentation level 16, expected level should be 14. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvEpjxf_orAgsFR8&open=AaGafvEpjxf_orAgsFR8&pullRequest=19063

Check warning on line 323 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/IoTDBAirGapSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 170). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGLwpYjSWsYDktFsnlQ&open=AaGLwpYjSWsYDktFsnlQ&pullRequest=19063

Check warning on line 148 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvJIjxf_orAgsFR-&open=AaGafvJIjxf_orAgsFR-&pullRequest=19063

Check warning on line 234 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof AirGapPseudoTPipeTransferRequest airgappseudotpipetransferrequest' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvEpjxf_orAgsFR5&open=AaGafvEpjxf_orAgsFR5&pullRequest=19063

Check warning on line 522 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'try' child has incorrect indentation level 18, expected level should be 16. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvEpjxf_orAgsFR9&open=AaGafvEpjxf_orAgsFR9&pullRequest=19063

Check warning on line 432 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/IoTDBAirGapSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 109). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGLwpYjSWsYDktFsnlR&open=AaGLwpYjSWsYDktFsnlR&pullRequest=19063

Check failure on line 567 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/protocol/IoTDBAirGapSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 28 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGLwpYjSWsYDktFsnlP&open=AaGLwpYjSWsYDktFsnlP&pullRequest=19063

Check warning on line 28 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/airgap/AirGapUdpProtocol.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'}' at column 32 should be alone on a line. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGLwpWJSWsYDktFsnlM&open=AaGLwpWJSWsYDktFsnlM&pullRequest=19063

Check warning on line 4796 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof WALNode walnode' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGafvMLjxf_orAgsFR_&open=AaGafvMLjxf_orAgsFR_&pullRequest=19063
View more details on SonarQubeCloud