|
|
|
@ -340,14 +340,20 @@ public class StorageIDResolver {
|
|
|
|
|
* @return the storage client instance |
|
|
|
|
*/ |
|
|
|
|
protected static IClient getStorageClientInstance(MemoryType memory) { |
|
|
|
|
if ((!Objects.isNull(storageManagerClient)) && (storageManagerClient.getGcubeMemoryType().equals(memory))) |
|
|
|
|
if ((!Objects.isNull(storageManagerClient)) && (storageManagerClient.getGcubeMemoryType().toString() == memory.toString())) { |
|
|
|
|
LOG.debug("reusing the same storage-client object"); |
|
|
|
|
return storageManagerClient; |
|
|
|
|
else { |
|
|
|
|
}else { |
|
|
|
|
if(!Objects.isNull(storageManagerClient)) { |
|
|
|
|
LOG.debug("going to close an old storage-client instance"); |
|
|
|
|
storageManagerClient.forceClose(); |
|
|
|
|
LOG.debug("going to close an old storage-client instance on "+storageManagerClient.getGcubeMemoryType()); |
|
|
|
|
try { |
|
|
|
|
storageManagerClient.forceClose(); |
|
|
|
|
LOG.debug("storage-client closed"); |
|
|
|
|
}catch(Exception e) { |
|
|
|
|
LOG.warn("Some problem occurred during the close operation:"+e.getMessage()+" Going to open another connection"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
LOG.debug("initializing a new storage-client instance"); |
|
|
|
|
LOG.debug("initializing a new storage-client instance on "+memory); |
|
|
|
|
storageManagerClient=new StorageClient(StorageIDResolver.class.getName(), StorageIDResolver.class.getSimpleName(), STORAGEID_RESOLVER, STORAGE_ACCESS_TYPE, memory, STORAGE_BACKEND_TYPE).getClient(); |
|
|
|
|
return storageManagerClient; |
|
|
|
|
} |
|
|
|
|