Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for clen (0.6 sec)

  1. cmd/xl-storage.go

    		}
    		return nil, err
    	}
    	volsInfo := make([]VolInfo, 0, len(entries))
    	for _, entry := range entries {
    		if !HasSuffix(entry, SlashSeparator) || !isValidVolname(pathutil.Clean(entry)) {
    			// Skip if entry is neither a directory not a valid volume name.
    			continue
    		}
    		volsInfo = append(volsInfo, VolInfo{
    			Name: pathutil.Clean(entry),
    		})
    	}
    	return volsInfo, nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    	return certOut.Bytes(), keyOut.Bytes(), nil
    }
    
    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,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    			concurrentSize = runtime.GOMAXPROCS(0)
    		}
    
    		fanOutResp := make([]minio.PutObjectFanOutResponse, 0, len(fanOutEntries))
    		eventArgsList := make([]eventArgs, 0, len(fanOutEntries))
    		for {
    			var objInfos []ObjectInfo
    			var errs []error
    
    			var done bool
    			if len(fanOutEntries) < concurrentSize {
    				objInfos, errs = fanOutPutObject(ctx, bucket, objectAPI, fanOutEntries, buf.Bytes()[:n], fanOutOpts)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller.go

    	if len(newUncounted) != len(uncountedStatus.Succeeded) {
    		updated = true
    		status.Succeeded += int32(len(uncountedStatus.Succeeded) - len(newUncounted))
    		uncountedStatus.Succeeded = newUncounted
    	}
    	newUncounted = filterInUncountedUIDs(uncountedStatus.Failed, uidsWithFinalizer)
    	if len(newUncounted) != len(uncountedStatus.Failed) {
    		updated = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		}
    	}
    	if len(selectedObjects) == 0 {
    		// Ensure that we never return a nil Items pointer in the result for consistency.
    		listVal.Set(reflect.MakeSlice(listVal.Type(), 0, 0))
    	} else {
    		// Resize the slice appropriately, since we already know that size of result set
    		listVal.Set(reflect.MakeSlice(listVal.Type(), len(selectedObjects), len(selectedObjects)))
    		span.AddEvent("Resized result")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top