public void acquireMutex() throws IllegalAcornStateException {
try {
while(!mutex.tryAcquire(3, TimeUnit.SECONDS)) {
- System.err.println("Mutex is taking a long time to acquire - owner is " + mutexOwner);
+ LOGGER.info("Mutex is taking a long time to acquire - owner is " + mutexOwner);
}
if(VERIFY)
mutexOwner = Thread.currentThread();
public void shutdown() {
if (GraphClientImpl2.DEBUG)
- System.err.println("Shutting down LRU writers " + writers);
+ LOGGER.info("Shutting down LRU writers " + writers);
writers.shutdown();
try {
writers.awaitTermination(60, TimeUnit.SECONDS);
}
});
if (GraphClientImpl2.DEBUG)
- System.err.println("Resuming LRU writers " + writers);
+ LOGGER.info("Resuming LRU writers " + writers);
}
/*
if(valueToSwap.tryAcquireMutex()) {
try {
if(valueToSwap.canBePersisted()) {
- valueToSwap.persist();
- return true;
+ boolean persist = valueToSwap.persist();
+ if (!persist) {
+ LOGGER.error("\n Somehow valueToSwap {} could not be persisted even though canBePersisted returned true\n", valueToSwap);
+ LOGGER.error("priorityQueue.size() {}", priorityQueue.size());
+ if (priorityQueue.size() > 0) {
+ LOGGER.error("priorityQueue first entry {}", priorityQueue.entrySet().iterator().next());
+ }
+ LOGGER.error("map.size() {}", map.size());
+ if (map.size() > 0) {
+ LOGGER.error("map first entry {}", map.entrySet().iterator().next());
+ }
+ }
+ return persist;
}
} catch (Throwable t) {
throw new IllegalAcornStateException(t);