Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 158 for lockR (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock(); // will throw an IllegalStateException
       * lockC.lock(); // will throw an IllegalStateException
       *
       * lockA.lock(); // reentrant acquisition is okay
       * }
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  2. internal/bucket/object/lock/lock.go

    	AmzObjectLockRetainUntilDate     = "X-Amz-Object-Lock-Retain-Until-Date"
    	AmzObjectLockMode                = "X-Amz-Object-Lock-Mode"
    	AmzObjectLockLegalHold           = "X-Amz-Object-Lock-Legal-Hold"
    )
    
    var (
    	// ErrMalformedBucketObjectConfig -indicates that the bucket object lock config is malformed
    	ErrMalformedBucketObjectConfig = errors.New("invalid bucket object lock config")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  3. cmd/bucket-object-lock.go

    					return ObjectLocked{}
    				}
    
    				if !ret.RetainUntilDate.Before(t) {
    					return ObjectLocked{}
    				}
    				return nil
    			}
    			// https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes
    			// If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:25 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  4. internal/dsync/drwmutex.go

    		case <-ctx.Done():
    			return false
    		default:
    			// Try to acquire the lock.
    			if locked = lock(ctx, dm.clnt, &locks, id, source, isReadLock, tolerance, quorum, dm.Names...); locked {
    				dm.m.Lock()
    
    				// If success, copy array to object
    				if isReadLock {
    					copy(dm.readLocks, locks)
    				} else {
    					copy(dm.writeLocks, locks)
    				}
    
    				dm.m.Unlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  5. cmd/local-locker_test.go

    	rng := rand.New(rand.NewSource(0))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    			for _, readers := range []int{1, 10, 100} {
    				if locks > 1000 && readers > 1 {
    					continue
    				}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java

                // Verify total bytes written (structure + lock data)
                assertEquals(24 + 24, bytesWritten); // 24 for structure, 24 for lock
            }
    
            @Test
            @DisplayName("Should write request structure correctly with multiple locks")
            void testWriteBytesWireFormatMultipleLocks() {
                Smb2Lock[] locks = new Smb2Lock[] { new Smb2Lock(0L, 100L, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK),
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Striped.java

         * error-prone code like:
         *
         * Striped<Lock> stripedLock = Striped.lazyWeakXXX(...)'
         * Iterable<Lock> locks = stripedLock.bulkGet(keys);
         * for (Lock lock : locks) {
         *   lock.lock();
         * }
         * operation();
         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 22:01:32 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  8. internal/dsync/dsync_test.go

    		}()
    
    		dm3rd.Lock(id, source)
    
    		// fmt.Printf("3rd lock obtained after 1st & 2nd locks are released\n")
    		time.Sleep(testDrwMutexRefreshCallTimeout)
    
    		dm3rd.Unlock(t.Context())
    	}()
    	expect += 2*testDrwMutexAcquireTimeout + testDrwMutexRefreshCallTimeout
    
    	go func() {
    		defer wg.Done()
    
    		dm3rd.Lock(id, source)
    
    		// Release lock after 10 seconds
    		go func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
     * except that the method parameter must accept whatever condition-like object is passed into {@code
     * callAndAssertWaits} by the test.
     *
     * @param <L> the type of the lock-like object to be used
     * @author Justin T. Sampson
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
     * except that the method parameter must accept whatever condition-like object is passed into {@code
     * callAndAssertWaits} by the test.
     *
     * @param <L> the type of the lock-like object to be used
     * @author Justin T. Sampson
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
Back to Top