in src/Apache.IoTDB/SessionPool.cs [600:649]
public async Task<int> DeleteDataAsync(List<string> tsPathLst, long startTime, long endTime)
{
var client = _clients.Take();
var req = new TSDeleteDataReq(client.SessionId, tsPathLst, startTime, endTime);
try
{
var status = await client.ServiceClient.deleteDataAsync(req);
if (_debugMode)
{
_logger.LogInformation(
"delete data from {0}, server message is {1}",
tsPathLst,
status.Message);
}
return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);
}
catch (TException e)
{
await Open(_enableRpcCompression);
client = _clients.Take();
req.SessionId = client.SessionId;
try
{
var status = await client.ServiceClient.deleteDataAsync(req);
if (_debugMode)
{
_logger.LogInformation(
"delete data from {0}, server message is {1}",
tsPathLst,
status.Message);
}
return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);
}
catch (TException ex)
{
throw new TException("Error occurs when deleting data", ex);
}
}
finally
{
_clients.Add(client);
}
}