Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for writeLock (0.11 seconds)

  1. internal/dsync/dsync-server_test.go

    		subrouter.Methods(http.MethodPost).Path("/v1/force-unlock").HandlerFunc(lockServer.ForceUnlockHandler)
    
    		nodes[i] = httptest.NewServer(router)
    	}
    }
    
    const WriteLock = -1
    
    type lockServer struct {
    	mutex sync.Mutex
    	// Map of locks, with negative value indicating (exclusive) write lock
    	// and positive values indicating number of read locks
    	lockMap map[string]int64
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = createGarbage();
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        try {
          assertFalse(writeLock.tryLock());
        } finally {
          readLock.unlock();
        }
      }
    
      private WeakReference<Object> createGarbage() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = createGarbage();
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        try {
          assertFalse(writeLock.tryLock());
        } finally {
          readLock.unlock();
        }
      }
    
      private WeakReference<Object> createGarbage() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt

                // we only allow 1 promotion job running at the same time to avoid website xml conflicts
                feature {
                    type = "JetBrains.SharedResources"
                    param("locks-param", "WebsiteReleasesXml writeLock")
                }
            }
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 04:44:29 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          this.writeLock = new CycleDetectingReentrantWriteLock(this);
          this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode);
        }
    
        ///// Overridden ReentrantReadWriteLock methods. /////
    
        @Override
        public ReadLock readLock() {
          return readLock;
        }
    
        @Override
        public WriteLock writeLock() {
          return writeLock;
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        // Establish an ordering from writeLockA -> writeLockB.
        writeLockA.lock();
        writeLockB.lock();
        writeLockB.unlock();
        writeLockA.unlock();
    
        // Establish an ordering from writeLockB -> writeLockC.
        writeLockB.lock();
        writeLockC.lock();
        writeLockB.unlock();
    
        // writeLockC -> writeLockA should fail.
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        // Establish an ordering from writeLockA -> writeLockB.
        writeLockA.lock();
        writeLockB.lock();
        writeLockB.unlock();
        writeLockA.unlock();
    
        // Establish an ordering from writeLockB -> writeLockC.
        writeLockB.lock();
        writeLockC.lock();
        writeLockB.unlock();
    
        // writeLockC -> writeLockA should fail.
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/Striped.java

        }
    
        @Override
        public Lock readLock() {
          return new WeakSafeLock(delegate.readLock(), this);
        }
    
        @Override
        public Lock writeLock() {
          return new WeakSafeLock(delegate.writeLock(), this);
        }
      }
    
      /** Lock object that ensures a strong reference is retained to a specified object. */
      private static final class WeakSafeLock extends ForwardingLock {
    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)
  9. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

                }
            } finally {
                lock.writeLock().unlock();
            }
        }
    
        /**
         * Remove a child entry
         *
         * @param childName child file name
         */
        public void removeChild(String childName) {
            lock.writeLock().lock();
            try {
                if (children.remove(childName) != null) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

        public void releaseLease(Smb2LeaseKey key) {
            lock.writeLock().lock();
            try {
                LeaseEntry entry = leases.remove(key);
                if (entry != null) {
                    pathToLease.remove(entry.getPath());
                    log.debug("Released lease for path: {} with key: {}", entry.getPath(), key);
                }
            } finally {
                lock.writeLock().unlock();
            }
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
Back to Top