Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 49 of 49 for setCounts (0.09 sec)

  1. guava/src/com/google/common/collect/Synchronized.java

          }
        }
    
        @Override
        public int setCount(@ParametricNullness E element, int count) {
          synchronized (mutex) {
            return delegate().setCount(element, count);
          }
        }
    
        @Override
        public boolean setCount(@ParametricNullness E element, int oldCount, int newCount) {
          synchronized (mutex) {
            return delegate().setCount(element, oldCount, newCount);
          }
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Aug 08 15:11:10 UTC 2025
    - 56.9K bytes
    - Viewed (0)
  2. cmd/storage-rest_test.go

    		t.Fatalf("UpdateIsLocal failed %v", err)
    	}
    
    	endpoint.PoolIdx = 0
    	endpoint.SetIdx = 0
    	endpoint.DiskIdx = 0
    
    	poolEps := []PoolEndpoints{{
    		Endpoints: Endpoints{endpoint},
    	}}
    	poolEps[0].SetCount = 1
    	poolEps[0].DrivesPerSet = 1
    
    	// Register handlers on newly created servers
    	registerStorageRESTHandlers(tg.Mux[0], poolEps, tg.Managers[0])
    	registerStorageRESTHandlers(tg.Mux[1], poolEps, tg.Managers[1])
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    		// Count errNoHealRequired across all serverPools,
    		// to return appropriate error to the caller
    		if errors.Is(err, errNoHealRequired) {
    			countNoHeal++
    		}
    		r.DiskCount += result.DiskCount
    		r.SetCount += result.SetCount
    		r.Before.Drives = append(r.Before.Drives, result.Before.Drives...)
    		r.After.Drives = append(r.After.Drives, result.After.Drives...)
    	}
    
    	// No heal returned by all serverPools, return errNoHealRequired
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java

         * We keep an array of elements and counts.  Periodically -- when we need more room in the
         * array, or when we're building, or the like -- we sort, deduplicate, and combine the counts.
         * Negative counts indicate a setCount operation with ~counts[i].
         */
    
        private final Comparator<? super E> comparator;
    
        @VisibleForTesting E[] elements;
        private int[] counts;
    
        /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 35.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/ImmutableSortedMultiset.java

         * @throws IllegalArgumentException if {@code count} is negative
         */
        @CanIgnoreReturnValue
        @Override
        public Builder<E> setCount(E element, int count) {
          super.setCount(element, count);
          return this;
        }
    
        /**
         * Adds each element of {@code elements} to the {@code ImmutableSortedMultiset}.
         *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 21:07:18 UTC 2025
    - 29.5K bytes
    - Viewed (0)
  6. cmd/endpoint.go

    		PoolIdx: -1,
    		SetIdx:  -1,
    		DiskIdx: -1,
    	}, nil
    }
    
    // PoolEndpoints represent endpoints in a given pool
    // along with its setCount and setDriveCount.
    type PoolEndpoints struct {
    	// indicates if endpoints are provided in non-ellipses style
    	Legacy       bool
    	SetCount     int
    	DrivesPerSet int
    	Endpoints    Endpoints
    	CmdLine      string
    	Platform     string
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    func mustGetPoolEndpoints(poolIdx int, args ...string) EndpointServerPools {
    	drivesPerSet := len(args)
    	setCount := 1
    	if len(args) >= 16 {
    		drivesPerSet = 16
    		setCount = len(args) / 16
    	}
    	endpoints := mustGetNewEndpoints(poolIdx, drivesPerSet, args...)
    	return []PoolEndpoints{{
    		SetCount:     setCount,
    		DrivesPerSet: drivesPerSet,
    		Endpoints:    endpoints,
    		CmdLine:      strings.Join(args, " "),
    	}}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  8. cmd/peer-s3-client.go

    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	for i, err := range errs {
    		if err == nil {
    			res.Before.Drives = append(res.Before.Drives, healBucketResults[i].Before.Drives...)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
    	for pool := range globalLocalSetDrives {
    		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
    		for set := range globalLocalSetDrives[pool] {
    			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
    		}
    	}
    	for _, serverPool := range endpointServerPools {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top