Source code: com/fetish/directory/tool/FetishLeaseImpl.java

   package com.fetish.directory.tool;
   
   import java.io.Serializable;
   import java.util.Hashtable;
   import java.rmi.Remote;
   import java.rmi.RemoteException;
   import java.rmi.server.UnicastRemoteObject;
   import net.jini.core.lease.*;
   import net.jini.core.lookup.ServiceID;
  import com.fetish.directory.Directory;
  
  /**
   * Implementation of the FetishLease interface
   */
  
  public class FetishLeaseImpl implements FetishLease {
  
    private Lease lease;
    private Directory fada;
    private Hashtable registry;
    private ServiceID sid;
    private Object expirationLock = new Object();
    private Thread t;
    private long expiration;
  
    public FetishLeaseImpl() throws RemoteException {
    }
  
    public FetishLeaseImpl( Lease lease, Hashtable registry, ServiceID sid ) {
      this.lease = lease;
      this.expiration = this.lease.getExpiration();
      this.registry = registry;
      this.sid = sid;
      this.t = new Thread( new ExpirationWatcher() );
      this.t.start();
    }
  
    class ExpirationWatcher implements Runnable {
      public ExpirationWatcher() {
      }
  
      public void run() {
        long sleepTime = expiration - System.currentTimeMillis();
        try {
          Thread.sleep( sleepTime );
          registry.remove( ( Object )sid );
          try{
            lease.cancel();
          } catch( Exception e ) {
          } finally {
          }
        } catch( InterruptedException e ) {
          // Nothing to be done
        } catch( Exception e ) {
          e.printStackTrace();
        }
      }
    }
  
    public void cancel() throws UnknownLeaseException,
                  RemoteException {
      if( this.lease == null )
        throw new UnknownLeaseException( "The lease no longer exists" );
      registry.remove( sid );
      this.lease.cancel();
      this.lease = null;
      this.t.interrupt();
    }
  
    public long renew( long duration ) throws LeaseDeniedException,
                          UnknownLeaseException,
                          RemoteException {
      long now = System.currentTimeMillis();
      if( this.lease == null )
        throw new UnknownLeaseException( "The lease no longer exists" );
      long grantedDuration = 0;
      try {
        this.lease.renew( duration );
        grantedDuration = this.lease.getExpiration() - now;
      } catch( UnknownLeaseException e ) {
        throw e;
      } catch( LeaseDeniedException e ) {
        throw e;
      }
      this.expiration = now + grantedDuration;
      if( t != null )
        t.interrupt();
      this.t = new Thread( new ExpirationWatcher() );
      this.t.start();
      return grantedDuration;
    }
  
  }