package org.xvsm.remote.freepastry;
   
   import java.io.Serializable;
   import java.util.SortedMap;
   
   import rice.Continuation;
   import rice.Continuation.StandardContinuation;
   import rice.p2p.commonapi.Id;
   import rice.p2p.commonapi.IdFactory;
  import rice.p2p.commonapi.IdRange;
  import rice.p2p.commonapi.IdSet;
  import rice.persistence.Cache;
  import rice.persistence.Storage;
  import rice.persistence.StorageManager;
  
  /***
   * overrides the StorageManager class of the FreePastry API and removes the
   * caching functionality, as this functionality is not useful for us.
   * 
   * @author Hannu-Daniel Goiss
   */
  public class MyStorageManagerImpl implements StorageManager {
  	private IdFactory factory;
  	private Storage storage;
  
  	public MyStorageManagerImpl(IdFactory factory, Storage storage) {
  		this.factory = factory;
  		this.storage = storage;
  	}
  
  	public Storage getStorage() {
  		return storage;
  	}
  
  	public boolean exists(Id id) {
  		return storage.exists(id);
  	}
  
  	public void rename(final Id oldId, final Id newId, Continuation c) {
  		storage.rename(oldId, newId, new StandardContinuation(c) {
  			public void receiveResult(Object o) {
  				parent.receiveResult(o);
  			}
  
  			public String toString() {
  				return "rename of " + oldId + " to " + newId;
  			}
  		});
  	}
  
  	public void getObject(final Id id, Continuation c) {
  		storage.getObject(id, new StandardContinuation(c) {
  			public void receiveResult(Object o) {
  				// if (o != null) {
  
  				parent.receiveResult(o);
  				// } else {
  				// throw new Exception("Storage not found");
  				// }
  			}
  
  			public String toString() {
  				return "getObject of " + id;
  			}
  		});
  	}
  
  	public Serializable getMetadata(Id id) {
  		return storage.getMetadata(id);
  	}
  
  	public void setMetadata(final Id id, final Serializable metadata,
  			Continuation command) {
  		storage.setMetadata(id, metadata, new StandardContinuation(command) {
  			public void receiveResult(Object o) {
  				// storage.setMetadata(id, metadata, parent);
  				parent.receiveResult(o);
  			}
  
  			public String toString() {
  				return "setMetadata of " + id;
  			}
  		});
  	}
  
  	public IdSet scan(IdRange range) {
  		return storage.scan(range);
  	}
  
  	public IdSet scan() {
  		return storage.scan();
  	}
  
  	public SortedMap scanMetadata(IdRange range) {
  		return storage.scanMetadata(range);
  	}
  
  	public SortedMap scanMetadata() {
  		return storage.scanMetadata();
 	}
 
 	public SortedMap scanMetadataValuesHead(Object value) {
 		return storage.scanMetadataValuesHead(value);
 	}
 
 	public SortedMap scanMetadataValuesNull() {
 		return storage.scanMetadataValuesNull();
 	}
 
 	public long getTotalSize() {
 		return storage.getTotalSize();
 	}
 
 	public int getSize() {
 		return storage.getSize();
 	}
 
 	public void store(Id id, Serializable metadata, Serializable obj,
 			Continuation c) {
 		storage.store(id, metadata, obj, c);
 	}
 
 	public void unstore(Id id, Continuation c) {
 		storage.unstore(id, c);
 	}
 
 	public void cache(Id id, Serializable metadata, Serializable obj,
 			Continuation c) {
 		c.receiveResult(obj);
 		// cache.cache(id, metadata, obj, c);
 	}
 
 	public void uncache(Id id, Continuation c) {
 		// cache.uncache(id, c);
 	}
 
 	public long getMaximumSize() {
 		return 0;
 		// return cache.getMaximumSize();
 	}
 
 	public void setMaximumSize(int size, Continuation c) {
 		// cache.setMaximumSize(size, c);
 	}
 
 	public void flush(Continuation c) {
 		storage.flush(new StandardContinuation(c) {
 			public void receiveResult(Object o) {
 				// storage.flush(parent);
 				parent.receiveResult(o);
 			}
 		});
 	}
 
 	public Cache getCache() {
 		// TODO Auto-generated method stub
 		return null;
 	}
 }