summaryrefslogtreecommitdiff
path: root/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java
diff options
context:
space:
mode:
authorAndrew Branson <andrew.branson@cern.ch>2014-10-07 09:18:11 +0200
committerAndrew Branson <andrew.branson@cern.ch>2014-10-07 09:18:11 +0200
commit0ed2c1124cf1b9e49a2ec1fa0126a8df09f9e758 (patch)
treee3a56cee83865f8c703deb790c15d3e79e871a82 /src/main/java/com/c2kernel/utils/DescriptionObjectCache.java
parent50aa8aaab42fa62267aa1ae6a6070013096f5082 (diff)
Repackage to org.cristalise
Diffstat (limited to 'src/main/java/com/c2kernel/utils/DescriptionObjectCache.java')
-rw-r--r--src/main/java/com/c2kernel/utils/DescriptionObjectCache.java104
1 files changed, 0 insertions, 104 deletions
diff --git a/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java b/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java
deleted file mode 100644
index d3eb5ec..0000000
--- a/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java
+++ /dev/null
@@ -1,104 +0,0 @@
-/**
- * This file is part of the CRISTAL-iSE kernel.
- * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.
- *
- * This library is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as published
- * by the Free Software Foundation; either version 3 of the License, or (at
- * your option) any later version.
- *
- * This library is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
- * License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this library; if not, write to the Free Software Foundation,
- * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
- *
- * http://www.fsf.org/licensing/licenses/lgpl.html
- */
-/**
- *
- */
-package com.c2kernel.utils;
-
-import com.c2kernel.common.InvalidDataException;
-import com.c2kernel.common.ObjectNotFoundException;
-import com.c2kernel.entity.proxy.ProxyObserver;
-import com.c2kernel.entity.proxy.ItemProxy;
-import com.c2kernel.entity.proxy.MemberSubscription;
-import com.c2kernel.persistency.ClusterStorage;
-import com.c2kernel.persistency.outcome.Viewpoint;
-
-public abstract class DescriptionObjectCache<D extends DescriptionObject> {
-
- SoftCache<String, CacheEntry<D>> cache = new SoftCache<String, CacheEntry<D>>();
-
- public D get(String name, int version) throws ObjectNotFoundException, InvalidDataException {
- D thisDef;
- synchronized(cache) {
- CacheEntry<D> thisDefEntry = cache.get(name+"_"+version);
- if (thisDefEntry == null) {
- Logger.msg(6, name+" v"+version+" not found in cache. Retrieving.");
- ItemProxy defItem = LocalObjectLoader.loadLocalObjectDef(getDefRoot(), name);
- thisDef = loadObject(name, version, defItem);
- cache.put(name+"_"+version, new CacheEntry<D>(thisDef, defItem, this));
- }
- else {
- Logger.msg(6, name+" v"+version+" found in cache.");
- thisDef = thisDefEntry.def;
- }
- }
- return thisDef;
- }
-
- public abstract String getDefRoot();
-
- public abstract D loadObject(String name, int version, ItemProxy proxy) throws ObjectNotFoundException, InvalidDataException;
-
- public void removeObject(String id) {
- synchronized(cache) {
- if (cache.keySet().contains(id)) {
- Logger.msg(7, "ActDefCache: Removing activity def "+id+" from cache");
- cache.remove(id);
- }
- }
- }
-
- public class CacheEntry<E extends DescriptionObject> implements ProxyObserver<Viewpoint> {
- public String id;
- public ItemProxy proxy;
- public E def;
- public DescriptionObjectCache<E> parent;
- public CacheEntry(E def, ItemProxy proxy, DescriptionObjectCache<E> parent) {
- this.id = def.getName()+"_"+def.getVersion();
- this.def = def;
- this.parent = parent;
- this.proxy = proxy;
- proxy.subscribe(new MemberSubscription<Viewpoint>(this, ClusterStorage.VIEWPOINT, false));
- }
- @Override
- public void finalize() {
- parent.removeObject(id);
- proxy.unsubscribe(this);
- }
- @Override
- public void add(Viewpoint contents) {
- parent.removeObject(id);
- }
-
- @Override
- public void remove(String oldId) {
- parent.removeObject(oldId);
- }
-
- @Override
- public String toString() {
- return "Cache entry: "+id;
- }
- @Override
- public void control(String control, String msg) {
- }
- }
-} \ No newline at end of file