Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 412 for lockR (0.01 sec)

  1. src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java

     */
    package jcifs.internal.smb2.lock;
    
    import jcifs.Configuration;
    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb2.ServerMessageBlock2Response;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Lock response message. This response acknowledges the successful
     * acquisition or release of byte-range locks.
     *
     * @author mbechler
     *
     */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.TreeSet;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    import org.apache.maven.api.SessionData;
    import org.apache.maven.api.services.MavenException;
    import org.apache.maven.api.services.MessageBuilderFactory;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Jun 12 14:55:55 UTC 2025
    - 21K bytes
    - Viewed (0)
  3. 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();
            }
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  4. cmd/namespace-lock_test.go

    		//    successfully acquiring the lock.
    		// 2) lk2 then needs to advance and remove the resource from lockMap.
    		// 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates
    		//    a new entry in lockMap and acquires a lock for the same resource.
    
    		<-lk2ch
    		lk3ok := <-lk3ch
    		lk4ok := <-lk4ch
    
    		if lk3ok && lk4ok {
    			t.Fatalf("multiple locks acquired; iteration=%d, lk3=%t, lk4=%t", i, lk3ok, lk4ok)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex.go

    	"time"
    )
    
    // A LRWMutex is a mutual exclusion lock with timeouts.
    type LRWMutex struct {
    	id          string
    	source      string
    	isWriteLock bool
    	ref         int
    	mu          sync.Mutex // Mutex to prevent multiple simultaneous locks
    }
    
    // NewLRWMutex - initializes a new lsync RW mutex.
    func NewLRWMutex() *LRWMutex {
    	return &LRWMutex{}
    }
    
    // Lock holds a write lock on lm.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java

                lock.readLock().unlock();
            }
        }
    
        /**
         * Get handle information by path
         * @param path the file path
         * @return the handle info or null if not found
         */
        public HandleInfo getHandleByPath(String path) {
            lock.readLock().lock();
            try {
                return handles.get(path);
            } finally {
                lock.readLock().unlock();
            }
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 13K bytes
    - Viewed (0)
  7. internal/dsync/lock-args_gen.go

    Klaus Post <******@****.***> 1759093161 +0200
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  9. 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);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  10. internal/dsync/lock-args_gen_test.go

    Klaus Post <******@****.***> 1759093161 +0200
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
Back to top