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/07/18 02:37:24 UTC
[iotdb] branch iotdb-3791-test updated: add more metrics
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch iotdb-3791-test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/iotdb-3791-test by this push:
new 5d974022b8 add more metrics
5d974022b8 is described below
commit 5d974022b858e288e8f0aa635d7f2403b5a716f2
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Mon Jul 18 10:37:13 2022 +0800
add more metrics
---
.../iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 4 ++++
.../main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java | 4 +++-
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
index e5d9c2b6f4..40b51ab7ac 100644
--- a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
+++ b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.consensus.statemachine;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.StepTracker;
import org.apache.iotdb.commons.consensus.DataRegionId;
import org.apache.iotdb.consensus.common.DataSet;
import org.apache.iotdb.consensus.common.request.IConsensusRequest;
@@ -100,6 +101,7 @@ public class DataRegionStateMachine extends BaseStateMachine {
public TSStatus write(IConsensusRequest request) {
TSStatus status;
PlanNode planNode;
+ long writeStartTime = System.nanoTime();
try {
if (request instanceof IndexedConsensusRequest) {
status = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
@@ -125,6 +127,8 @@ public class DataRegionStateMachine extends BaseStateMachine {
} catch (IllegalArgumentException e) {
logger.error(e.getMessage(), e);
return new TSStatus(TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode());
+ } finally {
+ StepTracker.trace("StateMachineWriteOne", 400, writeStartTime, System.nanoTime());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
index 54834733e7..71ab72eab2 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
@@ -19,6 +19,7 @@
package org.apache.iotdb.db.engine.storagegroup;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.StepTracker;
import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
import org.apache.iotdb.commons.concurrent.ThreadName;
import org.apache.iotdb.commons.concurrent.threadpool.ScheduledExecutorUtil;
@@ -1054,7 +1055,7 @@ public class DataRegion {
@SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning
public void insertTablet(InsertTabletNode insertTabletNode)
throws TriggerExecutionException, BatchProcessException, WriteProcessException {
-
+ long insertTabletStartTime = System.nanoTime();
writeLock("insertTablet");
try {
TSStatus[] results = new TSStatus[insertTabletNode.getRowCount()];
@@ -1139,6 +1140,7 @@ public class DataRegion {
// TODO: trigger // fire trigger after insertion
// TriggerEngine.fire(TriggerEvent.AFTER_INSERT, insertTabletPlan, firePosition);
} finally {
+ StepTracker.trace("DataRegionInsertTablet", 400, insertTabletStartTime, System.nanoTime());
writeUnlock();
}
}