Initial Maven Conversion

1 files changed, 0 insertions, 374 deletions

diff --git a/source/com/c2kernel/persistency/RemoteMap.java b/source/com/c2kernel/persistency/RemoteMap.java
deleted file mode 100644
index 2147047..0000000
--- a/source/com/c2kernel/persistency/RemoteMap.java
+++ /dev/null
@@ -1,374 +0,0 @@
-package com.c2kernel.persistency;

-

-import java.util.AbstractSet;

-import java.util.Collection;

-import java.util.Comparator;

-import java.util.Iterator;

-import java.util.Set;

-import java.util.TreeMap;

-

-import com.c2kernel.common.ObjectNotFoundException;

-import com.c2kernel.entity.C2KLocalObject;

-import com.c2kernel.entity.proxy.EntityProxy;

-import com.c2kernel.entity.proxy.EntityProxyObserver;

-import com.c2kernel.entity.proxy.MemberSubscription;

-import com.c2kernel.lookup.EntityPath;

-import com.c2kernel.process.Gateway;

-import com.c2kernel.utils.Logger;

-

-/**

- * Maps a storage cluster onto a java.util.Map

- *

- * @author Andrew Branson

- * $Revision: 1.22 $

- * $Date: 2006/03/03 13:52:21 $

- *

- * Copyright (C) 2003 CERN - European Organization for Nuclear Research

- * All rights reserved.

- */

-public class RemoteMap<V extends C2KLocalObject> extends TreeMap<String, V> implements C2KLocalObject  {

-

-	private int mID=-1;

-	private String mName;

-	protected int mSysKey;

-	private String mPath = "";

-    Object keyLock = null;

-	TransactionManager storage;

-    EntityProxyObserver<V> listener;

-    Comparator<String> comp;

-    EntityProxy source;

-	Object mLocker; // if this remote map will participate in a transaction

-

-	public RemoteMap(int sysKey, String path, Object locker) {

-		

-		super(new Comparator<String>() {

-			@Override

-			public int compare(String o1, String o2) {

-				Integer i1 = null, i2 = null;

-				try { 

-					i1 = Integer.valueOf(o1); 

-					i2 = Integer.valueOf(o2);

-					return i1.compareTo(i2);

-					} catch (NumberFormatException ex) { }

-				return o1.compareTo(o2);

-			}

-		});

-		

-		mSysKey = sysKey;

-		mLocker = locker;

-

-		// split the path into path/name

-		int lastSlash = path.lastIndexOf("/");

-		mName = path.substring(lastSlash+1);

-		if (lastSlash>0) mPath = path.substring(0,lastSlash);

-

-		// see if the name is also a suitable id

-		try {

-			mID = Integer.parseInt(mName);

-		} catch (NumberFormatException e) {}

-		storage = Gateway.getStorage();

-		

-        listener = new EntityProxyObserver<V>() {

-            @Override

-			public void add(V obj) {

-                synchronized (this) {

-                    putLocal(obj.getName(), obj);

-                }

-            }

-

-            @Override

-			public void remove(String id) {

-                synchronized (this) {

-                    removeLocal(id);

-                }

-            }

-

-			@Override

-			public void control(String control, String msg) { }

-        };

-

-        try {

-            source = Gateway.getProxyManager().getProxy(new EntityPath(sysKey));

-            source.subscribe(new MemberSubscription<V>(listener, path, false));

-        } catch (Exception ex) {

-            Logger.error("Error subscribing to remote map. Changes will not be received");

-            Logger.error(ex);

-        }

-	}

-

-	protected void loadKeys() {

-		if (keyLock != null) return;

-		clear();

-		keyLock = new Object();

-        synchronized(this) {

-    		String[] keys;

-			try {

-				keys = storage.getClusterContents(mSysKey, mPath+mName);

-				for (String key : keys) super.put(key, null);

-			} catch (ClusterStorageException e) {

-				Logger.error(e);

-			}

-

-        }

-	}

-

-    public synchronized int getLastId() {

-    	loadKeys();

-    	if (size() == 0) return -1;

-    	try {

-    		return Integer.parseInt(lastKey());

-    	} catch (NumberFormatException ex) {

-    		return -1;

-    	}

-    }

-

-

-	// c2kLocalObject methods

-	public void setID(int id) { mID = id; }

-

-	public int getID() { return mID; }

-

-	@Override

-	public void setName(String name) { mName = name; }

-

-	@Override

-	public String getName() { return mName; }

-

-	/**

-	 * Cannot be stored

-	 */

-	@Override

-	public String getClusterType() {

-		return null;

-	}

-	/**

-	 * @see java.util.Map#clear()

-	 */

-	@Override

-	public synchronized void clear() {

-		synchronized (this) {

-			super.clear();

-		}

-		keyLock = null;

-	}

-

-

-

-	/**

-	 * @see java.util.Map#containsKey(Object)

-	 */

-	@Override

-	public synchronized boolean containsKey(Object key) {

-		if (keyLock == null) loadKeys();

-		return super.containsKey(key);

-	}

-

-	/**

-	 * This must retrieve all the values until a match is made.

-	 * Very expensive, but if you must, you must.

-	 * @see java.util.Map#containsValue(Object)

-	 */

-	@Override

-	public synchronized boolean containsValue(Object value) {

-		loadKeys();

-        synchronized(this) {

-    		for (String key: keySet()) {

-   				if (get(key).equals(value)) return true;

-    		}

-        }

-		return false;

-	}

-

-

-	/**

-	 * @see java.util.Map#get(Object)

-	 */

-	@Override

-	public synchronized V get(Object objKey) {

-		loadKeys();

-		String key;

-		if (objKey instanceof Integer)

-			key = ((Integer)objKey).toString();

-		else if (objKey instanceof String)

-			key = (String)objKey;

-		else 

-			return null;

-		

-        synchronized(this) {

-    		try {

-    			V value = super.get(key);

-    			if (value == null) {

-    				value = (V)storage.get(mSysKey, mPath+mName+"/"+key, mLocker);

-    				super.put(key, value);

-    			}

-    			return value;

-    		} catch (ClusterStorageException e) {

-    				Logger.error(e);

-    		} catch (ObjectNotFoundException e) {

-                Logger.error(e);

-            }

-        }

-		return null;

-	}

-

-	/**

-	 * @see java.util.Map#isEmpty()

-	 */

-	@Override

-	public synchronized boolean isEmpty() {

-		loadKeys();

-		return super.isEmpty();

-	}

-

-	/**

-	 * @see java.util.Map#keySet()

-	 */

-	@Override

-	public synchronized Set<String> keySet() {

-		loadKeys();

-		return super.keySet();

-	}

-

-	/**

-	 * Inserts the given object into the storage

-	 * the key is ignored - it can be fetched from the value.

-	 * @see java.util.Map#put(Object, Object)

-	 */

-	@Override

-	public synchronized V put(String key, V value) {

-		try {

-            synchronized(this) {

-                storage.put(mSysKey, value, mLocker);

-                return putLocal(key, value);

-            }

-		} catch (ClusterStorageException e) {

-			Logger.error(e);

-			return null;

-		}

-	}

-	

-	protected synchronized V putLocal(String key, V value) {

-		return super.put(key, value);

-	}

-

-	/**

-	 * @see java.util.Map#remove(Object)

-	 */

-	@Override

-	public synchronized V remove(Object key) {

-		loadKeys();

-		if (containsKey(key)) try {

-            synchronized(keyLock) {

-			    storage.remove(mSysKey, mPath+mName+"/"+key, mLocker);

-			    return super.remove(key);

-            }

-		} catch (ClusterStorageException e) {

-			Logger.error(e);

-		}

-		return null;

-	}

-	

-	protected synchronized V removeLocal(Object key) {

-		return super.remove(key);

-	}

-

-	/**

-	 * @see java.util.Map#size()

-	 */

-	@Override

-	public synchronized int size() {

-		loadKeys();

-		return super.size();

-	}

-

-	/**

-	 * @see java.util.Map#values()

-	 */

-	@Override

-	public synchronized Collection<V> values() {

-		return new RemoteSet<V>(this);

-	}

-

-	/**

-	 * Basic implementation of Set and Collection to bridge to the Iterator

-	 * Disallows all writes.

-	 */

-

-	private class RemoteSet<E extends C2KLocalObject> extends AbstractSet<E> {

-		RemoteMap<E> mParent;

-

-		public RemoteSet(RemoteMap<E> parent) {

-			mParent = parent;

-		}

-

-		// no modifications allowed

-		@Override

-		public boolean add(E o) {

-			throw new UnsupportedOperationException();

-		}

-		@Override

-		public boolean addAll(Collection<? extends E> c) {

-			throw new UnsupportedOperationException();

-		}

-		@Override

-		public void clear() {

-			throw new UnsupportedOperationException();

-		}

-		@Override

-		public boolean remove(Object o) {

-			throw new UnsupportedOperationException();

-		}

-		@Override

-		public boolean removeAll(Collection<?> c) {

-			throw new UnsupportedOperationException();

-		}

-		@Override

-		public boolean retainAll(Collection<?> c) {

-			throw new UnsupportedOperationException();

-		}

-

-		@Override

-		public Iterator<E> iterator() {

-			return new RemoteIterator<E>(mParent);

-		}

-

-		@Override

-		public int size() {

-			return mParent.size();

-		}

-

-	}

-	/**

-	 * Iterator view on RemoteMap data. Doesn't preload anything.

-	 * REVISIT: Will go strange if the RemoteMap is modified. Detect this and throw ConcurrentMod ex

-	 */

-	private class RemoteIterator<C extends C2KLocalObject> implements Iterator<C> {

-		RemoteMap<C> mParent;

-		Iterator<String> iter;

-

-		public RemoteIterator(RemoteMap<C> parent) {

-			mParent = parent;

-			iter = mParent.keySet().iterator();

-		}

-

-		@Override

-		public boolean hasNext() {

-			return iter.hasNext();

-		}

-

-		@Override

-		public C next() {

-			return mParent.get(iter.next());

-		}

-

-		@Override

-		public void remove() {

-			throw new UnsupportedOperationException();

-		}

-

-	}

-

-

-

-

-}