Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 1,149 for Take (0.08 sec)

  1. cmd/post-policy-fan-out.go

    func fanOutPutObject(ctx context.Context, bucket string, objectAPI ObjectLayer, fanOutEntries []minio.PutObjectFanOutEntry, fanOutBuf []byte, opts fanOutOptions) ([]ObjectInfo, []error) {
    	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()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    		workers:         make([]chan ReplicationWorkerOperation, 0, workers),
    		lrgworkers:      make([]chan ReplicationWorkerOperation, 0, maxLWorkers),
    		mrfReplicaCh:    make(chan ReplicationWorkerOperation, 100000),
    		mrfWorkerKillCh: make(chan struct{}, failedWorkers),
    		resyncer:        newresyncer(),
    		mrfSaveCh:       make(chan MRFReplicateEntry, 100000),
    		mrfStopCh:       make(chan struct{}, 1),
    		ctx:             ctx,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. src/cmd/asm/internal/lex/lex.go

    // A Token is a scan token plus its string value.
    // A macro is stored as a sequence of Tokens with spaces stripped.
    type Token struct {
    	ScanToken
    	text string
    }
    
    // Make returns a Token with the given rune (ScanToken) and text representation.
    func Make(token ScanToken, text string) Token {
    	// Substitute the substitutes for . and /.
    	text = strings.ReplaceAll(text, "\u00B7", ".")
    	text = strings.ReplaceAll(text, "\u2215", "/")
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  7. 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)
  8. cmd/erasure-encode_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K 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. 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)
Back to top