Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 162 for suspend (0.07 seconds)

  1. cmd/erasure-server-pool.go

    	storageInfos := make([][]*DiskInfo, len(z.serverPools))
    	nSets := make([]int, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    		pool := z.serverPools[index]
    		nSets[index] = pool.setCount
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-decom.go

    		CurrentSize: pi.Free,
    		TotalSize:   pi.Total,
    	}
    	return nil
    }
    
    func (p poolMeta) IsSuspended(idx int) bool {
    	if idx >= len(p.Pools) {
    		// We don't really know if the pool is suspended or not, since it doesn't exist.
    		return false
    	}
    	return p.Pools[idx].Decommission != nil
    }
    
    func (p *poolMeta) validate(pools []*erasureSets) (bool, error) {
    	type poolInfo struct {
    		position     int
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  3. android/guava/src/com/google/common/math/LongMath.java

             * and increasing the threshold to 2^32 doesn't pay for itself, and adding another enum
             * constant hurts performance further -- I suspect because bimorphic implementation is a
             * sweet spot for the JVM.
             */
            return (a * b) % m;
          }
    
          @Override
          long squareMod(long a, long m) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 09 23:01:02 GMT 2026
    - 46.8K bytes
    - Click Count (0)
  4. fastapi/routing.py

                            # Guarantee a checkpoint so cancellation can be
                            # delivered even when the producer is faster than
                            # the consumer and receive() never suspends.
                            await anyio.sleep(0)
    
                    sse_stream_content: AsyncIterator[bytes] | Iterator[bytes] = (
                        _sse_with_checkpoints(sse_receive_stream)
                    )
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 193K bytes
    - Click Count (0)
  5. cmd/xl-storage.go

    	}
    
    	var reqVID string
    	if fi.VersionID == "" {
    		reqVID = nullVersionID
    	} else {
    		reqVID = fi.VersionID
    	}
    
    	// Empty fi.VersionID indicates that versioning is either
    	// suspended or disabled on this bucket. RenameData will replace
    	// the 'null' version. We add a free-version to track its tiered
    	// content for asynchronous deletion.
    	//
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  6. cmd/bucket-replication.go

    		// dramatically reduces namespace pollution while keeping the
    		// benefits of replication, make sure to apply version suspension
    		// only at bucket level instead.
    		VersionSuspended: globalBucketVersioningSys.Suspended(bucket),
    	})
    	if err != nil && !isErrVersionNotFound(err) { // VersionNotFound would be reported by pool that object version is missing on.
    		sendEvent(eventArgs{
    			BucketName: bucket,
    			Object: ObjectInfo{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  7. cmd/admin-handlers-users.go

    				PrefixUsage:             prefixUsage,
    				Details: &madmin.BucketDetails{
    					Versioning:          globalBucketVersioningSys.Enabled(bucket.Name),
    					VersioningSuspended: globalBucketVersioningSys.Suspended(bucket.Name),
    					Replication:         rcfg != nil,
    					Locking:             lcfg.LockEnabled,
    					Quota:               quota,
    					Tagging:             tcfg,
    				},
    				Access: madmin.AccountAccess{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
  8. cmd/object-handlers.go

    		dsc = checkReplicateDelete(ctx, bucket, ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: object,
    				VersionID:  opts.VersionID,
    			},
    		}, *oi, opts, gerr)
    		// Mutations of objects on versioning suspended buckets
    		// affect its null version. Through opts below we select
    		// the null version's remote object to delete if
    		// transitioned.
    		if gerr == nil {
    			os.SetTransitionState(oi.TransitionedObject)
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.23.md

    - Node affinity, Node selectors, and tolerations are now mutable for Jobs that are suspended and have never been started ([#105479](https://github.com/kubernetes/kubernetes/pull/105479), [@ahg-g](https://github.com/ahg-g))
    - Pod template annotations and labels are now mutable for Jobs that are suspended and have never been started ([#105980](https://github.com/kubernetes/kubernetes/pull/105980), [@ahg-g](https://github.com/ahg-g))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Feb 28 21:06:52 GMT 2023
    - 424.5K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.31.md

    - .status.terminating field now gets tracked faster when active Pods are deleted, specifically when Job is failed, gets suspended or has too many active pods. ([#125175](https://github.com/kubernetes/kubernetes/pull/125175), [@dejanzele](https://github.com/dejanzele)) [SIG Apps and Testing]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Nov 12 11:33:21 GMT 2025
    - 451.9K bytes
    - Click Count (0)
Back to Top