X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.acorn%2Fsrc%2Forg%2Fsimantics%2Facorn%2Flru%2FLRU.java;h=690ba426f209afd52035ac875530b1f7e2b3d763;hb=refs%2Fchanges%2F17%2F517%2F1;hp=323d66d3df12ea34d2d429293801eeacfc95a23b;hpb=28418dc0f3cc153ba631c201c900b99e45fa03d1;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.acorn/src/org/simantics/acorn/lru/LRU.java b/bundles/org.simantics.acorn/src/org/simantics/acorn/lru/LRU.java index 323d66d3d..690ba426f 100644 --- a/bundles/org.simantics.acorn/src/org/simantics/acorn/lru/LRU.java +++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/lru/LRU.java @@ -16,16 +16,19 @@ import org.simantics.acorn.ClusterManager; import org.simantics.acorn.GraphClientImpl2; import org.simantics.acorn.exception.AcornAccessVerificationException; import org.simantics.acorn.exception.IllegalAcornStateException; -import org.simantics.db.common.utils.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /* * The order rule of synchronization for LRU and LRUObject is: - * § Always lock LRUObject first! + * � Always lock LRUObject first! * */ public class LRU> { - + + private static final Logger LOGGER = LoggerFactory.getLogger(LRU.class); + public static boolean VERIFY = true; final private long swapTime = 5L*1000000000L; @@ -148,6 +151,12 @@ public class LRU> { } } + + + public MapValue purge(MapKey id) { + return map.remove(id); + } + public MapValue get(MapKey key) throws AcornAccessVerificationException { if(VERIFY) verifyAccess(); @@ -513,7 +522,7 @@ public class LRU> { manager.notSafeToMakeSnapshot(new IllegalAcornStateException(t)); } t.printStackTrace(); - Logger.defaultLogError(t); + LOGGER.error("Exception happened in WriteRunnable.run", t); } } @@ -547,14 +556,18 @@ public class LRU> { boolean gotMutex = impl.tryAcquireMutex(); boolean done = false; + // TODO: fix this properly pleease + int count = 0; while (!done) { if (gotMutex || borrowMutex) { runWithMutex(); done = true; } else { - System.err.println("Retry mutex acquire"); + if (count % 100 == 0) + LOGGER.warn("Retry mutex acquire"); gotMutex = impl.tryAcquireMutex(); + count++; } }