Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 571 - 580 of 859 for Block (0.04 seconds)

  1. docs/smb3-features/04-directory-leasing-design.md

            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return children.get(name);
            } finally {
                lock.readLock().unlock();
            }
        }
        
        public boolean hasChild(String name) {
            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return children.containsKey(name);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 36.2K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. src/main/java/jcifs/internal/smb2/lock/Smb2LockRequest.java

        private byte[] fileId;
        private final Smb2Lock[] locks;
    
        /**
         * Constructs an SMB2 lock request with the specified parameters.
         *
         * @param config the configuration for this request
         * @param fileId the file identifier for the file to lock
         * @param locks the array of lock elements to apply
         */
        public Smb2LockRequest(final Configuration config, final byte[] fileId, final Smb2Lock[] locks) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java

                assertEquals(2, SMBUtil.readInt2(buffer, 52)); // Lock count
                assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 58, 74)); // File ID
            }
    
            @Test
            @DisplayName("Should handle lock request with all lock types")
            void testAllLockTypes() {
    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)
  6. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

      }
    
      @Override
      public int size() {
        synchronized (lock) {
          return cachingHashMap.size();
        }
      }
    
      @Override
      public boolean isEmpty() {
        synchronized (lock) {
          return cachingHashMap.isEmpty();
        }
      }
    
      @Override
      public @Nullable V get(@Nullable Object key) {
        Timestamped<V> value;
        synchronized (lock) {
          checkNotNull(key);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 21.6K bytes
    - Click Count (0)
  7. cmd/namespace-lock_test.go

    	}
    }
    
    // Test lock race
    func TestNSLockRace(t *testing.T) {
    	t.Skip("long test skip it")
    
    	ctx := t.Context()
    
    	for i := range 10000 {
    		nsLk := newNSLock(false)
    
    		// lk1; ref=1
    		if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) {
    			t.Fatal("failed to acquire lock")
    		}
    
    		// lk2
    		lk2ch := make(chan struct{})
    		go func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            setField(cmd, "timeout", 3000L);
            // arrays of one lock and one unlock range
            LockingAndXRange lock = new LockingAndXRange(false);
            lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
            setField(lock, "pid", 123);
            setField(lock, "byteOffset", 100L);
            setField(lock, "lengthInBytes", 200L);
            LockingAndXRange unlock = new LockingAndXRange(false);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  10. internal/bucket/object/lock/lock_test.go

    				"x-amz-object-lock-mode":              "governance",
    				"x-amz-object-lock-retain-until-date": "2020-02-01",
    			},
    			expected:        map[string]string{},
    			filterRetention: true,
    			filterLegalHold: true,
    		},
    		{
    			metadata: map[string]string{
    				"x-amz-object-lock-legal-hold":        "on",
    				"x-amz-object-lock-mode":              "governance",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.4K bytes
    - Click Count (0)
Back to Top