X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.layer0%2Fsrc%2Forg%2Fsimantics%2Fdb%2Flayer0%2Futil%2FSessionGarbageCollection.java;fp=bundles%2Forg.simantics.db.layer0%2Fsrc%2Forg%2Fsimantics%2Fdb%2Flayer0%2Futil%2FSessionGarbageCollection.java;h=26e049db67d5d95c87e47e56d81b9ad843ac4572;hb=44984b07d8a3827c0feee4ef3bc9e953e7b4607c;hp=3fceebea2827b6cdcc7ea0b4a3514f545fc4de8f;hpb=287c8e8582649f0efa17705f7b358cfe75c40511;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.layer0/src/org/simantics/db/layer0/util/SessionGarbageCollection.java b/bundles/org.simantics.db.layer0/src/org/simantics/db/layer0/util/SessionGarbageCollection.java index 3fceebea2..26e049db6 100644 --- a/bundles/org.simantics.db.layer0/src/org/simantics/db/layer0/util/SessionGarbageCollection.java +++ b/bundles/org.simantics.db.layer0/src/org/simantics/db/layer0/util/SessionGarbageCollection.java @@ -63,13 +63,17 @@ public class SessionGarbageCollection { long took = gc(monitor, session, sync, errorCallback, DEFAULT_ALLOWED_TIME, DEFAULT_CLUSTER_TARGET); return ((16*took) / DEFAULT_ALLOWED_TIME) > 15; } - + public static void gc(ReadGraph graph, final int allowedTimeInMs, final int clusterTarget) throws DatabaseException { - doIt(null, graph, allowedTimeInMs, clusterTarget); + doIt(null, graph, allowedTimeInMs, clusterTarget); + } + + public static void gc(IProgressMonitor monitor, ReadGraph graph, final int allowedTimeInMs, final int clusterTarget) throws DatabaseException { + doIt(monitor, graph, allowedTimeInMs, clusterTarget); } private static void doIt(IProgressMonitor _monitor, ReadGraph graph, final int allowedTimeInMs, final int clusterTarget) { - if(_monitor == null) _monitor = new NullProgressMonitor(); + if(_monitor == null) _monitor = new NullProgressMonitor(); QueryControl qc = graph.getService(QueryControl.class); ClusterControl cc = graph.getService(ClusterControl.class); _monitor.beginTask("Collect clusters", IProgressMonitor.UNKNOWN); @@ -77,7 +81,7 @@ public class SessionGarbageCollection { _monitor.beginTask("Collect queries", IProgressMonitor.UNKNOWN); qc.gc(graph, allowedTimeInMs); } - + /** * @param monitor * @param session