You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by li...@apache.org on 2019/11/14 05:44:12 UTC
[incubator-iotdb] branch 0.8.1-quick-fix updated:
fix(TSServiceImpl): increase request count in every jdbc API
This is an automated email from the ASF dual-hosted git repository.
liurui pushed a commit to branch 0.8.1-quick-fix
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/0.8.1-quick-fix by this push:
new 2bc60f8 fix(TSServiceImpl): increase request count in every jdbc API
2bc60f8 is described below
commit 2bc60f861654b1f3c7f326c1675d788b5a5fee0d
Author: liuruiyiyang <24...@qq.com>
AuthorDate: Thu Nov 14 13:43:53 2019 +0800
fix(TSServiceImpl): increase request count in every jdbc API
---
server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 79de7ea..61a3287 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -502,6 +502,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext, IStatisti
@Override
public TSExecuteStatementResp executeStatement(TSExecuteStatementReq req) {
+ totalRequestNum.incrementAndGet();
try {
if (!checkLogin()) {
logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
@@ -554,6 +555,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext, IStatisti
@Override
public TSExecuteStatementResp executeQueryStatement(TSExecuteStatementReq req) {
long t1 = System.currentTimeMillis();
+ totalRequestNum.incrementAndGet();
try {
if (!checkLogin()) {
logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
@@ -743,6 +745,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext, IStatisti
@Override
public TSExecuteStatementResp executeUpdateStatement(TSExecuteStatementReq req) {
+ totalRequestNum.incrementAndGet();
try {
if (!checkLogin()) {
return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS, ERROR_NOT_LOGIN);
@@ -919,6 +922,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext, IStatisti
@Override
public TSExecuteStatementResp executeInsertion(TSInsertionReq req) {
+ totalRequestNum.incrementAndGet();
if (!checkLogin()) {
logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
return getTSExecuteStatementResp(TS_StatusCode.ERROR_STATUS, ERROR_NOT_LOGIN);