You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/11/29 11:40:19 UTC
[iotdb] 01/04: Add server rt for old interface
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch ty/tsbs
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 069dc241bc1863c88ba25f553a88ace4c855c468
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Nov 29 10:38:01 2022 +0800
Add server rt for old interface
---
.../iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
index 102fa3457f..379acd9c24 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
@@ -900,7 +900,12 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
@Override
public TSExecuteStatementResp executeQueryStatement(TSExecuteStatementReq req) {
- return executeStatement(req);
+ long startTime = System.nanoTime();
+ try {
+ return executeStatement(req);
+ } finally {
+ QueryStatistics.getInstance().addCost(SERVER_RPC_RT, System.nanoTime() - startTime);
+ }
}
@Override
@@ -911,6 +916,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
@Override
public TSFetchResultsResp fetchResults(TSFetchResultsReq req) {
boolean finished = false;
+ long startTimeNanos = System.nanoTime();
long startTime = System.currentTimeMillis();
try {
if (!SESSION_MANAGER.checkLogin(SESSION_MANAGER.getCurrSession())) {
@@ -946,6 +952,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
if (finished) {
COORDINATOR.cleanupQueryExecution(req.queryId);
}
+ QueryStatistics.getInstance().addCost(SERVER_RPC_RT, System.nanoTime() - startTimeNanos);
}
}