Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 208 for locked (0.26 sec)

  1. internal/dsync/drwmutex.go

    			if sendRelease(ctx, ds, restClnts[lockID], owner, (*locks)[lockID], isReadLock, names...) {
    				(*locks)[lockID] = ""
    			}
    		}(lockID)
    	}
    	wg.Wait()
    
    	// Return true if releaseAll was successful, otherwise we return 'false'
    	// to indicate we haven't sufficiently unlocked lockers to avoid deadlocks.
    	//
    	// Caller may use this as an indication to call again.
    	return !checkFailedUnlocks(*locks, tolerance)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var lri []lockRequesterInfo
    
    	resource := args.Resources[0]
    	if lri, reply = l.lockMap[resource]; !reply {
    		// No lock is held on the given name
    		return true, nil
    	}
    	if isWriteLock(lri) {
    		// A write-lock is held, cannot release a read lock
    		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", resource)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. cmd/bucket-object-lock.go

    // enforceRetentionForDeletion checks if it is appropriate to remove an
    // object according to locking configuration when this is lifecycle/ bucket quota asking.
    func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
    	if objInfo.DeleteMarker {
    		return false
    	}
    
    	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
    	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
    		return true
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  4. manifests/charts/README.md

    It is strongly recommended that different namespaces are used, with different service accounts.
    In particular access to the security-critical production components (root CA, policy, control)
    should be locked down and restricted.  The new installer allows multiple instances of
    policy/control/telemetry - so testing/staging of new settings and versions can be performed
    by a different role than the prod version.
    
    Plain Text
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Feb 07 17:53:24 GMT 2024
    - 6.7K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    			if i.debug {
    				if obj.VersionID != "" {
    					console.Debugf(applyVersionActionsLogPrefix+" lifecycle: %s v(%s) is locked, not deleting\n", obj.Name, obj.VersionID)
    				} else {
    					console.Debugf(applyVersionActionsLogPrefix+" lifecycle: %s is locked, not deleting\n", obj.Name)
    				}
    			}
    			// add this version back to remaining versions for
    			// subsequent lifecycle policy applications
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/hash/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  9. cmd/global-heal.go

    			lc, err = globalLifecycleSys.Get(bucket)
    			if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			// Check if bucket is object locked.
    			lr, err = globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			rcfg, err = getReplicationConfig(ctx, bucket)
    			if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  10. cmd/erasure-server-pool-decom.go

    		return err
    	}
    
    	// if no update is needed return right away.
    	if !update {
    		z.poolMetaMutex.Lock()
    		z.poolMeta = meta
    		z.poolMetaMutex.Unlock()
    	} else {
    		newMeta := newPoolMeta(z, meta)
    		if err = newMeta.save(ctx, z.serverPools); err != nil {
    			return err
    		}
    		z.poolMetaMutex.Lock()
    		z.poolMeta = newMeta
    		z.poolMetaMutex.Unlock()
    	}
    
    	pools := meta.returnResumablePools()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
Back to top