Open Source Repository

Home /hibernate/hibernate-3.2.7.ga | Repository Home


org/hibernate/cache/OSCache.java
//$Id: OSCache.java 6478 2005-04-21 07:57:19Z oneovthafew $
package org.hibernate.cache;

import java.util.Map;

import com.opensymphony.oscache.base.NeedsRefreshException;
import com.opensymphony.oscache.general.GeneralCacheAdministrator;

/**
 @author <a href="mailto:[email protected]">Mathias Bogaert</a>
 */
public class OSCache implements Cache {

  /** 
   * The OSCache 2.0 cache administrator. 
   */
  private GeneralCacheAdministrator cache = new GeneralCacheAdministrator();

  private final int refreshPeriod;
  private final String cron;
  private final String regionName;
  
  private String toString(Object key) {
    return String.valueOf(key'.' + regionName;
  }

  public OSCache(int refreshPeriod, String cron, String region) {
    this.refreshPeriod = refreshPeriod;
    this.cron = cron;
    this.regionName = region;
  }

  public void setCacheCapacity(int cacheCapacity) {
    cache.setCacheCapacity(cacheCapacity);
  }

  public Object get(Object keythrows CacheException {
    try {
      return cache.getFromCachetoString(key), refreshPeriod, cron );
    }
    catch (NeedsRefreshException e) {
      cache.cancelUpdatetoString(key) );
      return null;
    }
  }

  public Object read(Object keythrows CacheException {
    return get(key);
  }
  
  public void update(Object key, Object valuethrows CacheException {
    put(key, value);
  }
  
  public void put(Object key, Object valuethrows CacheException {
    cache.putInCachetoString(key), value );
  }

  public void remove(Object keythrows CacheException {
    cache.flushEntrytoString(key) );
  }

  public void clear() throws CacheException {
    cache.flushAll();
  }

  public void destroy() throws CacheException {
    cache.destroy();
  }

  public void lock(Object keythrows CacheException {
    // local cache, so we use synchronization
  }

  public void unlock(Object keythrows CacheException {
    // local cache, so we use synchronization
  }

  public long nextTimestamp() {
    return Timestamper.next();
  }

  public int getTimeout() {
    return Timestamper.ONE_MS * 60000//ie. 60 seconds
  }

  public String getRegionName() {
    return regionName;
  }

  public long getSizeInMemory() {
    return -1;
  }

  public long getElementCountInMemory() {
    return -1;
  }

  public long getElementCountOnDisk() {
    return -1;
  }

  public Map toMap() {
    throw new UnsupportedOperationException();
  }

  public String toString() {
    return "OSCache(" + regionName + ')';
  }

}