Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 230 for lock1 (0.06 sec)

  1. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy

            then:
            !lock1.lockedState
            !lock2.lockedState
        }
    
        def "can lock resources atomically with tryLock"() {
            def lock1 = resourceLock("lock1", lock1Locked)
            def lock2 = resourceLock("lock1", lock2Locked)
    
            when:
            def disposition = null
            coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() {
                @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. src/runtime/metrics_test.go

    // to abstract over the relationship of two Lock calls or an RLock
    // and a Lock call.
    type locker2 interface {
    	Lock1()
    	Unlock1()
    	Lock2()
    	Unlock2()
    }
    
    type mutex struct {
    	mu sync.Mutex
    }
    
    func (m *mutex) Lock1()   { m.mu.Lock() }
    func (m *mutex) Unlock1() { m.mu.Unlock() }
    func (m *mutex) Lock2()   { m.mu.Lock() }
    func (m *mutex) Unlock2() { m.mu.Unlock() }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 45K bytes
    - Viewed (0)
  3. 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")
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  4. src/runtime/lockrank_on.go

    		// No possibility of lock ordering problem if no other locks held
    		return
    	}
    
    	systemstack(func() {
    		i := gp.m.locksHeldLen
    		if i >= len(gp.m.locksHeld) {
    			throw("too many locks held concurrently for rank checking")
    		}
    		// Temporarily add this lock to the locksHeld list, so
    		// checkRanks() will print out list, including this lock, if there
    		// is a lock ordering problem.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. 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()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java

        }
    
        /**
         * Attempts an atomic, blocking lock on the provided resource locks.
         */
        public static InternalTransformer<ResourceLockState.Disposition, ResourceLockState> lock(Iterable<? extends ResourceLock> resourceLocks) {
            return new AcquireLocks(resourceLocks, true);
        }
    
        /**
         * Attempts an atomic, blocking lock on the provided resource locks.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. 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
     */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java

                ManagedExecutor executor;
                lock.lock();
                try {
                    executor = this.executor;
                } finally {
                    lock.unlock();
                }
                if (executor != null) {
                    executor.stop();
                }
            }
    
            public void add(C command) {
                lock.lock();
                try {
                    queue.add(command);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 19:51:37 UTC 2024
    - 16K bytes
    - Viewed (0)
  9. cmd/local-locker.go

    	TimeLastRefresh time.Time // Timestamp for last lock refresh.
    	Source          string    // Contains line, function and filename requesting the lock.
    	Group           bool      // indicates if it was a group lock.
    	Owner           string    // Owner represents the UUID of the owner who originally requested the lock.
    	Quorum          int       // Quorum represents the quorum required for this lock to be active.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. 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.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top