Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 191 for rlocked (0.04 sec)

  1. docs/bucket/lifecycle/DESIGN.md

              "X-Amz-Restore-Request-Date": "Mon, 22 Feb 2021 21:10:09 GMT",
              "x-amz-restore": "ongoing-request=false, expiry-date=Sat, 27 Feb 2021 00:00:00 GMT",
    ...
    ```
    
    ### Encrypted/Object locked objects
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    		lc, err = globalLifecycleSys.Get(bucket)
    		if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) {
    			return err
    		}
    
    		// Check if bucket is object locked.
    		lr, err = globalBucketObjectLockSys.Get(bucket)
    		if err != nil {
    			return err
    		}
    
    		rcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return err
    		}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 28.7K bytes
    - Viewed (0)
  3. internal/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * specified access policy.
       *
       * @param capacity the capacity of this queue
       * @param fair if {@code true} then queue accesses for threads blocked on insertion or removal,
       *     are processed in FIFO order; if {@code false} the access order is unspecified.
       * @throws IllegalArgumentException if {@code capacity} is less than 1
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. cmd/peer-s3-server.go

    	peerS3BucketForceDelete = "force-delete"
    )
    
    func healBucketLocal(ctx context.Context, bucket string, opts madmin.HealOpts) (res madmin.HealResultItem, err error) {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    	// Initialize sync waitgroup.
    	g := errgroup.WithNErrs(len(localDrives))
    
    	// Disk states slices
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. cmd/ilm-config.go

    	},
    }
    
    type ilmConfig struct {
    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    func (c *ilmConfig) getExpirationWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.ExpirationWorkers
    }
    
    func (c *ilmConfig) getTransitionWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.TransitionWorkers
    }
    
    func (c *ilmConfig) update(cfg ilm.Config) {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Mar 05 02:50:24 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/NtStatus.java

        int NT_STATUS_PASSWORD_MUST_CHANGE = 0xC0000224;
        /** The object was not found */
        int NT_STATUS_NOT_FOUND = 0xC0000225;
        /** The referenced account is currently locked out */
        int NT_STATUS_ACCOUNT_LOCKED_OUT = 0xC0000234;
        /** The pathname does not traverse a DFS junction */
        int NT_STATUS_PATH_NOT_COVERED = 0xC0000257;
        /** The IO operation on the reparse point failed */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          List<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get());
          LockGraphNode node = lock.getLockGraphNode();
          // Iterate in reverse because locks are usually locked/unlocked in a
          // LIFO order.
          for (int i = acquiredLockList.size() - 1; i >= 0; i--) {
            if (acquiredLockList.get(i) == node) {
              acquiredLockList.remove(i);
              break;
            }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  9. internal/config/heal/heal.go

    // - '> 0' interval duration between cycles
    func (opts Config) BitrotScanCycle() (d time.Duration) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.cache.bitrotCycle
    }
    
    // Clone safely the heal configuration
    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 04 19:06:02 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. compat/maven-model-builder/src/main/java/org/apache/maven/model/root/RootLocator.java

    import org.apache.maven.api.annotations.Nonnull;
    import org.apache.maven.api.annotations.Nullable;
    
    /**
     * Interface used to locate the root directory for a given project.
     *
     * The root locator is usually looked up from the plexus container.
     * One notable exception is the computation of the early {@code session.rootDirectory}
     * property which happens very early.  The implementation used in this case
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 25 08:27:34 UTC 2025
    - 2.5K bytes
    - Viewed (0)
Back to top