Mercurial > hg > blitz_condensed
view src/org/dancres/blitz/remote/txn/TxnLeaseHandlerImpl.java @ 28:4b2f23b6feca
Add a schema compatibility check to indexer that parallels storage.
author | Dan Creswell <dan.creswell@gmail.com> |
---|---|
date | Sat, 12 Jun 2010 10:11:15 +0100 |
parents | 3dc0c5604566 |
children |
line wrap: on
line source
package org.dancres.blitz.remote.txn; import java.io.IOException; import net.jini.core.lease.UnknownLeaseException; import net.jini.core.lease.LeaseDeniedException; import org.dancres.blitz.lease.LeaseHandler; import org.dancres.blitz.lease.SpaceUID; import org.dancres.blitz.lease.LeaseBounds; import org.dancres.blitz.util.Time; /** */ public class TxnLeaseHandlerImpl implements LeaseHandler { public boolean recognizes(SpaceUID aUID) { return (aUID instanceof SpaceTxnUID); } public long renew(SpaceUID aUID, long aLeaseDuration) throws UnknownLeaseException, LeaseDeniedException, IOException { long myDuration = LeaseBounds.boundView(aLeaseDuration); long myExpiry = Time.getAbsoluteTime(myDuration); boolean myResult; myResult = LoopBackMgr.get().renew((SpaceTxnUID) aUID, myExpiry); if (!myResult) throw new UnknownLeaseException(); return myDuration; } public void cancel(SpaceUID aUID) throws UnknownLeaseException, IOException { boolean myResult; myResult = LoopBackMgr.get().cancel((SpaceTxnUID) aUID); if (!myResult) throw new UnknownLeaseException(); } }