gCubeSystem
/
storage-manager-core
16
0
Fork 0
Code Issues Releases 2 Wiki Activity

clean mongoobjects into forceClose operation

This commit is contained in:
Roberto Cirillo 2021-08-06 14:39:24 +02:00
parent 46e20d5f6e
commit 4f8a65e348
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/gcube/contentmanagement/blobstorage/transport/backend/MongoIOManager.java
View File

@ -1067,11 +1067,11 @@ public class MongoIOManager {
public void close() { public void close() {
// if(mongo!=null) // if(mongo!=null)
// mongo.close(); // mongo.close();
logger.debug(" try to close backend but the close operation is not implemented"); logger.debug(" cleaning mongo objects");
// logger.info("Mongo has been closed"); // logger.info("Mongo has been closed");
// mongo=null; // mongo=null;
// gfs=null; gfs=null;
// db=null; db=null;
} }
@ -1079,6 +1079,8 @@ public class MongoIOManager {
if(mongo!=null) if(mongo!=null)
mongo.close(); mongo.close();
logger.info("Mongo pool closed"); logger.info("Mongo pool closed");
close();
mongo=null;
} }
public void removeGFSFile(GridFSDBFile f, ObjectId idF){ public void removeGFSFile(GridFSDBFile f, ObjectId idF){

7
src/main/java/org/gcube/contentmanagement/blobstorage/transport/backend/MongoOperationManager.java
View File

@ -11,6 +11,7 @@ import java.util.HashMap;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects;
import org.gcube.contentmanagement.blobstorage.resource.MemoryType; import org.gcube.contentmanagement.blobstorage.resource.MemoryType;
import org.gcube.contentmanagement.blobstorage.resource.RequestObject; import org.gcube.contentmanagement.blobstorage.resource.RequestObject;
@ -134,8 +135,10 @@ public class MongoOperationManager extends TransportManager{
} }
public void forceClose() { public void forceClose() {
mongoPrimaryInstance.forceClose(); if(Objects.nonNull(mongoPrimaryInstance))
mongoSecondaryInstance.forceClose(); mongoPrimaryInstance.forceClose();
if(Objects.nonNull(mongoSecondaryInstance))
mongoSecondaryInstance.forceClose();
} }
/** /**