Examples of org.jboss.cache.lock.TimeoutException

org.jboss.cache.lock.TimeoutException
Thrown when a timeout occurred. used by operations with timeouts, e.g. lock acquisition, or waiting for responses from all members. @author Bela Ban. @version $Revision: 7006 $

Revisions:

Dec 28 2002 Bela Ban: first implementation


      public void waitForFlushStart(long timeout) throws InterruptedException
      {
         if (channel.flushSupported() && !flushWaitGate.await(timeout, TimeUnit.MILLISECONDS))
         {
            throw new TimeoutException("Timed out waiting for flush to block. (timeout = " + CachePrinter.prettyPrint(timeout) + " )");
         }
      }

View Full Code Here

      private final ReentrantReadWriteLock coordinationLock = new ReentrantReadWriteLock();


      public void lockProcessingLock() throws InterruptedException
      {
         if (!coordinationLock.readLock().tryLock(configuration.getStateRetrievalTimeout(), TimeUnit.MILLISECONDS))
            throw new TimeoutException("Could not obtain processing lock");


      }

View Full Code Here

         while (true)
         {
            try
            {
               if (!coordinationLock.writeLock().tryLock(configuration.getStateRetrievalTimeout(), TimeUnit.MILLISECONDS))
                  throw new TimeoutException("Could not obtain processing lock");


               return;
            }
            catch (InterruptedException ie)
            {

View Full Code Here

         while (true)
         {
            try
            {
               if (!flushBlockGate.await(timeout, TimeUnit.MILLISECONDS))
                  throw new TimeoutException("Timed out waiting for flush to unblock. (timeout = " + CachePrinter.prettyPrint(timeout) + ")");


               return;
            }
            catch (InterruptedException ie)
            {

View Full Code Here

         while (true)
         {
            try
            {
               if (!flushWaitGate.await(timeout, TimeUnit.MILLISECONDS))
                  throw new TimeoutException("Timed out waiting for flush to block. (timeout = " + CachePrinter.prettyPrint(timeout) + ")");


               return;
            }
            catch (InterruptedException ie)
            {

View Full Code Here

      // nothing wrong, just means that we fail to record the lock.  And that is a problem.
      // Better to check our records and lock again if necessary.
      if (!ctx.hasLock(fqn)) {
         if (!lockManager.lockAndRecord(fqn, WRITE, ctx)) {
            Object owner = lockManager.getWriteOwner(fqn);
            throw new TimeoutException("Unable to acquire lock on Fqn [" + fqn + "] after [" + ctx.getLockAcquisitionTimeout(defaultLockAcquisitionTimeout) + "] milliseconds for requestor [" + lockManager.getLockOwner(ctx) + "]! Lock held by [" + owner + "]");
         }
         return true;
      }
      return false;
   }

View Full Code Here

    * @param id
    * @return
    */
   Object removeLocal(Fqn<?> fqn, String id)
   {
      TimeoutException ex = null;
      for (int i = 0; i < RETRY; i++)
      {
         try
         {
            this.getOptionOverrides().setCacheModeLocal(true);

View Full Code Here

    *
    * @param fqn
    */
   void removeLocal(Fqn<?> fqn)
   {
      TimeoutException ex = null;
      for (int i = 0; i < RETRY; i++)
      {
         try
         {
            this.getOptionOverrides().setCacheModeLocal(true);

View Full Code Here

      throw new RuntimeException(RETRY_FAIL_MSG, ex);
   }
   
   void evictSubtree(Fqn<?> fqn)
   {      
      TimeoutException ex = null;
      for (int i = 0; i < RETRY; i++)
      {
         try
         {
            this.getOptionOverrides();

View Full Code Here

   protected WorkspaceNode lockAndCreateWorkspaceNode(NodeFactory nodeFactory, NodeSPI node, TransactionWorkspace workspace, GlobalTransaction gtx, long timeout)
   {
      boolean locked = lockManager.lock(node, READ, gtx, timeout);


      if (!locked)
         throw new TimeoutException("Unable to lock node " + node.getFqn() + " after timeout " + timeout + " for copying into workspace");


      WorkspaceNode wn = nodeFactory.createWorkspaceNode(node, workspace);


      lockManager.unlock(node, gtx);
      return wn;

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.jboss.cache.lock.TimeoutException

org.jboss.cache.buddyreplication.BuddyManager

org.jboss.cache.interceptors.CacheLoaderInterceptor

org.jboss.cache.interceptors.LegacyCacheLoaderInterceptor

org.jboss.cache.interceptors.OptimisticInterceptor

org.jboss.cache.interceptors.PessimisticLockInterceptor

org.jboss.cache.interop.InteropTest

org.jboss.cache.mvcc.MVCCNodeHelper

org.jboss.cache.Node

org.jboss.cache.RPCManagerImpl

org.jboss.cache.RPCManagerImpl$FlushTracker

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.