You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/08/05 09:59:33 UTC
[iotdb] branch issue-3690 created (now bda7b81)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch issue-3690
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at bda7b81 [ISSUE-3690] Memory leaks on the server when cpp client invokes checkTimeseriesExists
This branch includes the following new commits:
new bda7b81 [ISSUE-3690] Memory leaks on the server when cpp client invokes checkTimeseriesExists
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: [ISSUE-3690] Memory leaks on the server when cpp
client invokes checkTimeseriesExists
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch issue-3690
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bda7b815d011200845b576ed400f83f828e2d3de
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Thu Aug 5 17:57:15 2021 +0800
[ISSUE-3690] Memory leaks on the server when cpp client invokes checkTimeseriesExists
---
client-cpp/src/main/Session.cpp | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/client-cpp/src/main/Session.cpp b/client-cpp/src/main/Session.cpp
index 75713b2..71a936e 100644
--- a/client-cpp/src/main/Session.cpp
+++ b/client-cpp/src/main/Session.cpp
@@ -1019,8 +1019,10 @@ void Session::createMultiTimeseries(vector <string> paths, vector <TSDataType::T
bool Session::checkTimeseriesExists(string path) {
try {
- string sql = "SHOW TIMESERIES " + path;
- return executeQueryStatement(sql)->hasNext();
+ std::unique_ptr <SessionDataSet> dataset = executeQueryStatement("SHOW TIMESERIES " + path);
+ bool isExisted = dataset->hasNext();
+ dataset->closeOperationHandle();
+ return isExisted;
}
catch (exception e) {
throw IoTDBConnectionException(e.what());