Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 111 for getCount (0.05 sec)

  1. cmd/endpoint-ellipses.go

    			newSetCounts[ss] = struct{}{}
    		}
    	}
    
    	setCounts = []uint64{}
    	for setCount := range newSetCounts {
    		setCounts = append(setCounts, setCount)
    	}
    
    	// Not necessarily needed but it ensures to the readers
    	// eyes that we prefer a sorted setCount slice for the
    	// subsequent function to figure out the right common
    	// divisor, it avoids loops.
    	slices.Sort(setCounts)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        when(backingMap.remove(KEY, current)).thenReturn(true);
    
        assertEquals(countToRemove, multiset.setCount(KEY, 0));
        assertEquals(0, current.get());
      }
    
      public void testSetCount_0_nonePresent() {
        when(backingMap.get(KEY)).thenReturn(null);
    
        assertEquals(0, multiset.setCount(KEY, 0));
      }
    
      public void testSerialCycle() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 16.3K bytes
    - Viewed (0)
  3. cmd/peer-s3-server.go

    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    		SetCount:  -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	// mutate only if not a dry-run
    	if opts.DryRun {
    		return res, nil
    	}
    
    	for i := range beforeState {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. 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)
  5. android/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
    - 53K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top