This is an automated email from the ASF dual-hosted git repository.
HTHou pushed a change to branch codex/trusted-channel-failure-hooks
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 130b1bbe170 Merge remote-tracking branch 'origin/master' into
codex/trusted-channel-failure-hooks
add 230ea2b6bee Limit trusted channel auditing to server endpoints
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/rpc/TElasticFramedTransport.java | 3 +-
.../iotdb/rpc/TElasticFramedTransportTest.java | 68 -----
.../iotdb/session/AbstractSessionBuilder.java | 4 -
.../org/apache/iotdb/session/NodesSupplier.java | 66 +----
.../java/org/apache/iotdb/session/Session.java | 23 +-
.../apache/iotdb/session/SessionConnection.java | 14 -
.../org/apache/iotdb/session/pool/SessionPool.java | 16 +-
.../iotdb/session/SessionConnectionTest.java | 55 +---
.../apache/iotdb/session/pool/SessionPoolTest.java | 23 --
.../iotdb/confignode/audit/CNAuditLogger.java | 6 -
.../async/AsyncAINodeHeartbeatClientPool.java | 34 +--
.../async/AsyncConfigNodeHeartbeatClientPool.java | 18 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 48 +---
.../CnToCnInternalServiceAsyncRequestManager.java | 13 -
.../CnToDnInternalServiceAsyncRequestManager.java | 13 -
.../client/sync/SyncAINodeClientPool.java | 14 -
.../client/sync/SyncConfigNodeClientPool.java | 16 +-
.../client/sync/SyncDataNodeClientPool.java | 15 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 12 -
.../procedure/env/RegionMaintainHandler.java | 4 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 10 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 55 +---
.../iot/client/IoTConsensusClientPool.java | 31 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 35 +--
.../iot/client/TrustedChannelFailureReporter.java | 49 ----
.../iotdb/consensus/pipe/IoTConsensusV2.java | 2 -
.../client/TrustedChannelFailureReporterTest.java | 73 -----
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 16 --
.../client/IoTDBDataNodeSyncClientManager.java | 8 -
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 19 --
.../iotdb/db/protocol/client/ConfigNodeClient.java | 11 -
.../iotdb/db/protocol/client/an/AINodeClient.java | 16 --
.../DnToCnInternalServiceAsyncRequestManager.java | 8 -
.../client/dn/AsyncTSStatusRPCHandler.java | 25 --
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 13 +-
...DataNodeExternalServiceAsyncRequestManager.java | 2 +-
.../client/dn/DataNodeIntraHeartbeatManager.java | 2 +-
.../dn/DataNodeMPPServiceAsyncRequestManager.java | 2 +-
.../DnToDnInternalServiceAsyncRequestManager.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 8 -
.../execution/exchange/source/SourceHandle.java | 11 -
.../iotdb/db/queryengine/plan/Coordinator.java | 6 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 21 +-
.../ConsensusSubscriptionCommitManager.java | 4 +-
.../plan/scheduler/AsyncPlanNodeSenderTest.java | 99 -------
.../iotdb/commons/client/ClientPoolFactory.java | 91 +-----
.../AsyncConfigNodeInternalServiceClient.java | 65 +----
.../async/AsyncDataNodeInternalServiceClient.java | 65 +----
.../async/AsyncIoTConsensusV2ServiceClient.java | 19 +-
.../client/request/AsyncRequestManager.java | 15 -
...nfigNodeInternalServiceAsyncRequestManager.java | 2 +-
.../DataNodeInternalServiceRequestManager.java | 2 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 52 +---
.../sync/SyncDataNodeInternalServiceClient.java | 52 +---
.../sync/SyncIoTConsensusV2ServiceClient.java | 25 +-
.../sync/SyncThriftClientWithErrorHandler.java | 66 +----
.../container/IoTV2GlobalComponentContainer.java | 55 +---
.../pipe/sink/client/IoTDBSyncClientManager.java | 49 +---
.../iotdb/commons/client/ClientManagerTest.java | 313 ---------------------
.../client/request/AsyncRequestManagerTest.java | 43 +--
.../sink/client/IoTDBSyncClientManagerTest.java | 113 --------
61 files changed, 136 insertions(+), 1884 deletions(-)
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/TrustedChannelFailureReporter.java
delete mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/client/TrustedChannelFailureReporterTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/AsyncPlanNodeSenderTest.java
delete mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/client/IoTDBSyncClientManagerTest.java
