in src/Apache.IoTDB/SessionPool.cs [437:484]
public async Task<int> DeleteStorageGroupsAsync(List<string> groupNames)
{
var client = _clients.Take();
try
{
var status = await client.ServiceClient.deleteStorageGroupsAsync(client.SessionId, groupNames);
if (_debugMode)
{
_logger.LogInformation(
"delete storage group(s) {0} successfully, server message is {1}",
groupNames,
status.Message);
}
return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);
}
catch (TException e)
{
await Open(_enableRpcCompression);
client = _clients.Take();
try
{
var status = await client.ServiceClient.deleteStorageGroupsAsync(client.SessionId, groupNames);
if (_debugMode)
{
_logger.LogInformation(
"delete storage group(s) {0} successfully, server message is {1}",
groupNames,
status.Message);
}
return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);
}
catch (TException ex)
{
throw new TException("Error occurs when deleting storage group(s)", ex);
}
}
finally
{
_clients.Add(client);
}
}