Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 1,222 for take (0.02 sec)

  1. cmd/erasure-multipart.go

    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize || size == -1:
    		if int64(globalBytePoolCap.Load().Width()) < fi.Erasure.BlockSize {
    			buffer = make([]byte, fi.Erasure.BlockSize, 2*fi.Erasure.BlockSize)
    		} else {
    			buffer = globalBytePoolCap.Load().Get()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  2. cmd/metrics-v3-types.go

    ) []prometheus.Metric {
    	metrics := make([]prometheus.Metric, 0, len(m.values))
    	for metricName, mv := range m.values {
    		desc := m.descriptors[metricName]
    		promDesc := desc.toPromDesc(namePrefix, extraLabels)
    		for _, v := range mv {
    			// labelValues is in the same order as the variable labels in the
    			// descriptor.
    			labelValues := make([]string, 0, len(v.Labels))
    			for _, k := range desc.VariableLabels {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  3. cmd/post-policy-fan-out.go

    	errs := make([]error, len(fanOutEntries))
    	objInfos := make([]ObjectInfo, len(fanOutEntries))
    
    	var wg sync.WaitGroup
    	for i, req := range fanOutEntries {
    		wg.Add(1)
    		go func(idx int, req minio.PutObjectFanOutEntry) {
    			defer wg.Done()
    
    			objInfos[idx] = ObjectInfo{Name: req.Key}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  4. ci/official/containers/ml_build_arm64/setup.python.sh

        tar -xf Python-3.14.0rc1.tar.xz
      fi
      pushd Python-3.14.0rc1
      mkdir -p /python314-0rc1
      CC=clang-18 CXX=clang++-18 ./configure --prefix /python314-0rc1 --with-ensurepip=install
      make -j$(nproc)
      make install -j$(nproc)
      ln -s /python314-0rc1/bin/python3 /usr/bin/python3.14
      popd
    elif [[ ${VERSION} == "python3.14-nogil" ]]; then
      if [[ ! -d Python-3.14.0rc1 ]]; then
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Aug 01 19:14:43 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  5. cmd/bucket-targets.go

    func NewBucketTargetSys(ctx context.Context) *BucketTargetSys {
    	sys := &BucketTargetSys{
    		arnRemotesMap: make(map[string]arnTarget),
    		targetsMap:    make(map[string][]madmin.BucketTarget),
    		arnErrsMap:    make(map[string]arnErrs),
    		hc:            make(map[string]epHealth),
    		hcClient:      newHCClient(),
    	}
    	// reload healthCheck endpoints map periodically to remove stale endpoints from the map.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  6. schema/utils.go

    	queryValues := make([]interface{}, len(foreignValues))
    	if len(foreignKeys) == 1 {
    		for idx, r := range foreignValues {
    			queryValues[idx] = r[0]
    		}
    
    		return clause.Column{Table: table, Name: foreignKeys[0]}, queryValues
    	}
    
    	columns := make([]clause.Column, len(foreignKeys))
    	for idx, key := range foreignKeys {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Feb 13 06:16:26 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  7. cmd/local-locker_test.go

    		t.Fatalf("lockUID len, got %d, want %d", len(l.lockUID), 0)
    	}
    }
    
    func TestLocalLockerUnlock(t *testing.T) {
    	const n = 1000
    	const m = 5
    	wResources := make([][m]string, n)
    	rResources := make([]string, n)
    	wUIDs := make([]string, n)
    	rUIDs := make([]string, 0, n*2)
    	l := newLocker()
    	ctx := t.Context()
    	quorum := 0
    	for i := range wResources {
    		names := [m]string{}
    		for j := range names {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. cmd/erasure-decode.go

    	stashBuffer   []byte
    }
    
    // newParallelReader returns parallelReader.
    func newParallelReader(readers []io.ReaderAt, e Erasure, offset, totalLength int64) *parallelReader {
    	r2b := make([]int, len(readers))
    	for i := range r2b {
    		r2b[i] = i
    	}
    	bufs := make([][]byte, len(readers))
    	shardSize := int(e.ShardSize())
    	var b []byte
    
    	// We should always have enough capacity, but older objects may be bigger
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. cmd/metrics-realtime.go

    		dm.NDisks = 1
    		if d.Healing {
    			dm.Healing++
    		}
    		if d.Metrics != nil {
    			dm.LifeTimeOps = make(map[string]uint64, len(d.Metrics.APICalls))
    			for k, v := range d.Metrics.APICalls {
    				if v != 0 {
    					dm.LifeTimeOps[k] = v
    				}
    			}
    			dm.LastMinute.Operations = make(map[string]madmin.TimedAction, len(d.Metrics.APICalls))
    			for k, v := range d.Metrics.LastMinute {
    				if v.Count != 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    	}
    
    	globalLocalDrivesMap = make(map[string]StorageAPI)
    	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)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top