Examples of Locker

com.sleepycat.je.txn.Locker
Locker instances are JE's route to locking and transactional support. This class is the abstract base class for BasicLocker, ThreadLocker, Txn, MasterTxn and ReadonlyTxn. Locker instances are in fact only a transaction shell to get to the lock manager, and don't guarantee transactional semantics. Txn (includes Txns marked autoTxn) MasterTxn and ReadonlyTxn instances are truly transactional. They have potentially different transaction begin and end behaviors.
com.thinkaurelius.titan.diskstorage.locking.Locker
Threadsafe discretionary locking within and between processes Titan.
Locks are identified {@link KeyColumn} instances.{@code KeyColumn#equals(Object)} should be used to determine whether two{@code KeyColumn} instances refer to the same or different locks.
Threads taking locks are identified by {@link StoreTransaction} instances.Either {@code equals(...)} or reference equality (the {@code ==} operator)can be used to compare these instances.
This interface follows a three-step locking model that supports both nonblocking and blocking locking primitives. Not all Titan {@code StoreTransaction}s will need locks and use this interface. For those {@code StoreTransaction}s that do take one or more locks, Titan will call the methods on this interface in the following order. {@code tx} refers to thesame {@code StoreTransaction} instance in each step.
1. {@code writeLock(kc, tx)} one or more times per distinct{@code KeyColumn kc}
2. {@code checkLocks(tx)} once if the user commits {@code tx} or never ifthe user aborts {@code tx}
3. {@code deleteLocks(tx)} once, regardless of whether{@code checkLocks(tx)} was called
The first step, {@code writeLocks}, attempts to take a lock. This may, but need not necessarily, indicate whether the attempt succeeded or failed. The second step, {@code checkLocks}, returns if all previous {@code writeLocks}succeeded or throws an exception if one or more failed. The final step, {@code deleteLocks}, releases all locks and associated resources held by the {@code tx}.
All implementations of this interface must be safe for concurrent use by different threads. However, implementations may assume that, for any given {@code StoreTransaction tx}, all calls to this interface's methods with argument {@code tx} will either come from a single thread or multiple threadsusing external synchronization to provide the same effect.
org.apache.activemq.broker.Locker
Represents a lock service to ensure that a broker is the only master
org.apache.maven.index.fs.Locker
Filesystem locker. Can be used to synchronize access to filesystem directories from different operating system processes. @author igor
org.olat.core.util.coordinate.Locker
dsolutions.ch

Examples of org.apache.activemq.broker.Locker

            }
        });


        final BrokerService brokerService = context.mock(BrokerService.class);
        final JDBCPersistenceAdapter jdbcPersistenceAdapter = context.mock(JDBCPersistenceAdapter.class);
        final Locker locker = context.mock(Locker.class);


        final States jdbcConn = context.states("jdbc").startsAs("down");
        final States broker = context.states("broker").startsAs("started");


        // simulate jdbc up between hasLock and checkpoint, so hasLock fails to verify

View Full Code Here

Examples of org.apache.maven.index.fs.Locker


            fetcher.connect( context.getId(), context.getIndexUpdateUrl() );
        }


        File cacheDir = updateRequest.getLocalIndexCacheDir();
        Locker locker = updateRequest.getLocker();
        Lock lock = locker != null && cacheDir != null ? locker.lock( cacheDir ) : null;
        try
        {
            if ( cacheDir != null )
            {
                LocalCacheIndexAdaptor cache = new LocalCacheIndexAdaptor( cacheDir, result );

View Full Code Here

Examples of org.olat.core.util.coordinate.Locker

    LockImpl l3 = cm.findLock(asset);
    assertNull(l3);
    
    
    // ------------------ test the clusterlocker ----------------------    
    Locker cl = CoordinatorManager.getCoordinator().getLocker();
    
    // acquire
    LockResult res1 = cl.acquireLock(ores, ident, "abc");
    assertTrue(res1.isSuccess());
    DBFactory.getInstance().closeSession();
    
    // reacquire same identity (get from db)
    LockResult res11 = cl.acquireLock(ores, ident, "abc");
    long lock1Ac = res11.getLockAquiredTime();
    assertTrue(res11.isSuccess());
    DBFactory.getInstance().closeSession();


    // acquire by another identity must fail
    LockResult res2 = cl.acquireLock(ores, ident2, "abc");
    assertFalse(res2.isSuccess());
    DBFactory.getInstance().closeSession();


    // reacquire same identity
    LockResult res3 = cl.acquireLock(ores, ident, "abc");
    assertTrue(res3.isSuccess());
    DBFactory.getInstance().closeSession();


    // test the admin
    List<LockEntry> entries = cl.adminOnlyGetLockEntries();
    assertEquals(1, entries.size());
    LockEntry le = entries.get(0);
    // must be original owner
    assertEquals(le.getOwner().getName(), ident.getName());


    // release lock
    cl.releaseLock(res3);
    DBFactory.getInstance().closeSession();
    // test the admin
    entries = cl.adminOnlyGetLockEntries();
    assertEquals(0,entries.size());


    // make sure it is not locked anymore
    boolean lo = cl.isLocked(ores, "abc");
    assertFalse(lo);

View Full Code Here

0 1 2 3 4 5

TOP

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.