Examples of org.apache.derby.iapi.services.locks.CompatibilitySpace

Package org.apache.derby.iapi.services.locks

Examples of org.apache.derby.iapi.services.locks.CompatibilitySpace

org.apache.derby.iapi.services.locks.CompatibilitySpace

This interface must be implemented by objects returned from LockFactory.createCompatibilitySpace().

A CompatibilitySpace can have an owner (for instance a transaction). Currently, the owner is used by the virtual lock table to find out which transaction a lock belongs to. Some parts of the code also use the owner as a group object which guarantees that the lock is released on a commit or an abort. The owner has no special meaning to the lock manager and can be any object, including null.
@see LockFactory#createCompatibilitySpace

          ** back and lock released already, so don't try to unlock if statement context
          ** is cleared.
          */
          if ((lcc.getStatementContext() != null) && lcc.getStatementContext().inUse())
          {
            CompatibilitySpace space =
              lcc.getTransactionExecute().getLockSpace();
            int unlockCount =
              lockFactory.unlock(
                space, space.getOwner(),
                cacheCoordinator, ShExQual.SH);
            if (SanityManager.DEBUG)
            {
              if (unlockCount != 1)
              {

View Full Code Here

                            // 
                            // See if we can get this lock granted without 
                            // waiting (while holding the dataDictionary 
                            // synchronization).


                            CompatibilitySpace space =
                                lcc.getTransactionExecute().getLockSpace();


                            lockGranted = 
                                lockFactory.lockObject(
                                    space, space.getOwner(),
                                    cacheCoordinator,
                                    ShExQual.SH,
                                    C_LockFactory.NO_WAIT);
                        } 
                        catch (StandardException e)

View Full Code Here

          ** back and lock released already, so don't try to unlock if statement context
          ** is cleared.
          */
          if ((lcc.getStatementContext() != null) && lcc.getStatementContext().inUse())
          {
            CompatibilitySpace space =
              lcc.getTransactionExecute().getLockSpace();
            int unlockCount =
              lockFactory.unlock(
                space, space.getOwner(),
                cacheCoordinator, ShExQual.SH);
            if (SanityManager.DEBUG)
            {
              if (unlockCount != 1)
              {

View Full Code Here

                    SQLState.DATA_ALLOC_NTT_CANT_OPEN, 
                    new Long(getSegmentId()), 
                    new Long(getContainerId()));
        }


    CompatibilitySpace cs = ntt.getCompatibilitySpace();
    // Latch this container, the commit will release the latch
    ntt.getLockFactory().lockObject(
                cs, ntt, this, null, C_LockFactory.WAIT_FOREVER);


    try

View Full Code Here

                    new Long(getSegmentId()), 
                    new Long(getContainerId()));
        }


    // Latch this container, the commit will release the latch
    CompatibilitySpace cs = ntt.getCompatibilitySpace();
    ntt.getLockFactory().lockObject(
                cs, ntt, this, null, C_LockFactory.WAIT_FOREVER);


    BasePage newPage = null;
    try

View Full Code Here


    // This method can be called from outside of the database
    // engine, in which case tc will be null. In that case
    // we lock the class loader only for the duration of
    // the loadClass().
    CompatibilitySpace lockSpace = null;
    
    if (cfc != null) {
      lockSpace = cfc.getLockSpace();
    }
    if (lockSpace == null)
      lockSpace = compat;


    Object lockGroup = lockSpace.getOwner();


    lf.lockObject(lockSpace, lockGroup, classLoaderLock, qualifier,
            C_LockFactory.TIMED_WAIT);


    return (lockGroup == this);

View Full Code Here

    // This allows correct operation of the cache. The cache remains
    // valid for all transactions except the one that is modifying
    // it. Thus readers see the old uncommited values. When this
    // thread releases its exclusive lock the cached is cleared
    // and the next reader will re-populate the cache.
    CompatibilitySpace cs = tc.getLockSpace();
    Object csGroup = cs.getOwner();
    lf.lockObject(cs, csGroup, cachedLock, ShExQual.EX,
            C_LockFactory.TIMED_WAIT);
  }

View Full Code Here

    Return true if the caller holds the exclusive update lock on the
    property conglomerate.
    */
  private boolean iHoldTheUpdateLock(TransactionController tc) throws StandardException
  {
    CompatibilitySpace cs = tc.getLockSpace();
    Object csGroup = cs.getOwner();
    return lf.isLockHeld(cs, csGroup, cachedLock, ShExQual.EX);
  }

View Full Code Here

                            // 
                            // See if we can get this lock granted without 
                            // waiting (while holding the dataDictionary 
                            // synchronization).


                            CompatibilitySpace space =
                                lcc.getTransactionExecute().getLockSpace();


                            lockGranted = 
                                lockFactory.lockObject(
                                    space, space.getOwner(),
                                    cacheCoordinator,
                                    ShExQual.SH,
                                    C_LockFactory.NO_WAIT);
                        } 
                        catch (StandardException e)

View Full Code Here

          ** back and lock released already, so don't try to unlock if statement context
          ** is cleared.
          */
          if ((lcc.getStatementContext() != null) && lcc.getStatementContext().inUse())
          {
            CompatibilitySpace space =
              lcc.getTransactionExecute().getLockSpace();
            int unlockCount =
              lockFactory.unlock(
                space, space.getOwner(),
                cacheCoordinator, ShExQual.SH);
            if (SanityManager.DEBUG)
            {
              if (unlockCount != 1)
              {

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.apache.derby.iapi.services.locks.CompatibilitySpace

org.apache.derby.impl.services.reflect.UpdateLoader

org.apache.derby.impl.sql.catalog.DataDictionaryImpl

org.apache.derby.impl.store.access.PropertyConglomerate

org.apache.derby.impl.store.raw.data.BaseContainer

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.