Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 61 for deadlock (0.05 seconds)

  1. CHANGELOG/CHANGELOG-1.7.md

    * Enable audit log in local cluster ([#42379](https://github.com/kubernetes/kubernetes/pull/42379), [@xilabao](https://github.com/xilabao))
    * Fix a deadlock in kubeadm master initialization. ([#43835](https://github.com/kubernetes/kubernetes/pull/43835), [@mikedanese](https://github.com/mikedanese))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu May 05 13:44:43 GMT 2022
    - 308.7K bytes
    - Click Count (1)
  2. internal/dsync/drwmutex.go

    		defer dm.m.Unlock()
    
    		// Check if minimally a single bool is set in the writeLocks array
    		lockFound := slices.ContainsFunc(dm.readLocks, isLocked)
    		if !lockFound {
    			panic("Trying to RUnlock() while no RLock() is active")
    		}
    
    		// Copy write locks to stack array
    		copy(locks, dm.readLocks)
    	}
    
    	// Tolerance is not set, defaults to half of the locker clients.
    	tolerance := len(restClnts) / 2
    	isReadLock := true
    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)
  3. CHANGELOG/CHANGELOG-1.12.md

    * Fix race condition introduced by graceful termination which can lead to a deadlock in kube-proxy ([#72361](https://github.com/kubernetes/kubernetes/pull/72361), [@lbernail](https://github.com/lbernail))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 06 06:04:15 GMT 2020
    - 293.8K bytes
    - Click Count (0)
  4. cmd/namespace-lock.go

    	lockSource := getSource(2)
    	start := UTCNow()
    	const readLock = false
    	success := make([]int, len(li.paths))
    	for i, path := range li.paths {
    		if !li.ns.lock(ctx, li.volume, path, lockSource, li.opsID, readLock, timeout.Timeout()) {
    			timeout.LogFailure()
    			for si, sint := range success {
    				if sint == 1 {
    					li.ns.unlock(li.volume, li.paths[si], readLock)
    				}
    			}
    			if errors.Is(ctx.Err(), context.Canceled) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

         *
         * @return list of child file info
         */
        public List<FileInfo> getChildren() {
            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return new ArrayList<>(children.values());
            } finally {
                lock.readLock().unlock();
            }
        }
    
        /**
         * Get a specific child
         *
         * @param name child name
    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)
  6. src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java

         * @return the handle info or null if not found
         */
        public HandleInfo getHandleByGuid(HandleGuid guid) {
            lock.readLock().lock();
            try {
                return guidToHandle.get(guid);
            } finally {
                lock.readLock().unlock();
            }
        }
    
        /**
         * Get handle information by path
         * @param path the file path
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:49:49 GMT 2025
    - 13K bytes
    - Click Count (0)
  7. internal/dsync/dsync-server_test.go

    	return true, nil
    }
    
    const ReadLock = 1
    
    func (l *lockServer) RLock(args *LockArgs) (reply bool, err error) {
    	if d := atomic.LoadInt64(&l.responseDelay); d != 0 {
    		time.Sleep(time.Duration(d))
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply {
    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)
  8. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Object key = new Object();
        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();
        }
      }
    
    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)
  9. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Object key = new Object();
        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();
        }
      }
    
    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)
  10. docs/smb3-features/04-directory-leasing-design.md

        
        public List<FileInfo> getChildren() {
            lock.readLock().lock();
            try {
                lastAccessTime = System.currentTimeMillis();
                return new ArrayList<>(children.values());
            } finally {
                lock.readLock().unlock();
            }
        }
        
        public FileInfo getChild(String name) {
            lock.readLock().lock();
            try {
    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)
Back to Top