Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for oidx (0.03 sec)

  1. cmd/erasure-server-pool.go

    	var wg sync.WaitGroup
    	for idx, pool := range z.serverPools {
    		if z.IsSuspended(idx) {
    			continue
    		}
    		wg.Add(1)
    		go func(idx int, pool *erasureSets) {
    			defer wg.Done()
    			result, err := pool.HealObject(ctx, bucket, object, versionID, opts)
    			result.Object = decodeDirObject(result.Object)
    			errs[idx] = err
    			results[idx] = result
    		}(idx, pool)
    	}
    	wg.Wait()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. tests/query_test.go

    	}
    
    	for idx, name := range names {
    		if name != users[idx].Name {
    			t.Errorf("Unexpected result on pluck name, got %+v", names)
    		}
    	}
    
    	for idx, id := range ids {
    		if int(id) != int(users[idx].ID) {
    			t.Errorf("Unexpected result on pluck id, got %+v", ids)
    		}
    	}
    
    	for idx, id := range ids2 {
    		if int(id) != int(users[idx].ID+1) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2.go

    		}
    	}
    	return -1, nil, errFileVersionNotFound
    }
    
    func (x *xlMetaV2) getIdx(idx int) (ver *xlMetaV2Version, err error) {
    	if idx < 0 || idx >= len(x.versions) {
    		return nil, errFileNotFound
    	}
    	var dst xlMetaV2Version
    	_, err = dst.unmarshalV(x.metaV, x.versions[idx].meta)
    	if false {
    		if err == nil && x.versions[idx].header.VersionID != dst.getVersionID() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  4. cmd/test-utils_test.go

    	for i, cache, remain := n-1, src.Int63(), letterIdxMax; i >= 0; {
    		if remain == 0 {
    			cache, remain = src.Int63(), letterIdxMax
    		}
    		if idx := int(cache & letterIdxMask); idx < len(letterBytes) {
    			b[i] = letterBytes[idx]
    			i--
    		}
    		cache >>= letterIdxBits
    		remain--
    	}
    
    	return *(*string)(unsafe.Pointer(&b))
    }
    
    // generate random object name.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

            if (tracker != null) {
                if (fieldName != null) {
                    Object key = fieldName;
    
                    int idx = fieldName.lastIndexOf('.');
                    if (idx >= 0) {
                        fieldName = fieldName.substring(idx + 1);
                        key = fieldName;
                    }
    
                    if (fieldName.endsWith("]")) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 77.1K bytes
    - Viewed (0)
  6. cmd/object-api-multipart_test.go

    	}
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	erasureDisks := er.getDisks()
    	ridx := rand.Intn(len(erasureDisks))
    
    	z.serverPools[0].erasureDisksMu.Lock()
    	er.getDisks = func() []StorageAPI {
    		erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk)
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  7. tests/migrate_test.go

    		Field2 float32 `gorm:"column:field2"`
    	}
    
    	if err := DB.AutoMigrate(&AutoIncrementStruct{}); err != nil {
    		t.Fatalf("AutoMigrate err: %v", err)
    	}
    
    	const ROWS = 10
    	for idx := 0; idx < ROWS; idx++ {
    		if err := DB.Create(&AutoIncrementStruct{}).Error; err != nil {
    			t.Fatalf("create auto_increment_struct fail, err: %v", err)
    		}
    	}
    
    	rows := make([]*AutoIncrementStruct, 0, ROWS)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    	if err != nil {
    		return nil, err
    	}
    
    	parts := make([]*ObjectPartInfo, len(partMetaPaths))
    	for idx, partMetaPath := range partMetaPaths {
    		var partNumber int
    		fmt.Sscanf(pathutil.Base(partMetaPath), "part.%d.meta", &partNumber)
    
    		if contextCanceled(ctx) {
    			parts[idx] = &ObjectPartInfo{
    				Error:  ctx.Err().Error(),
    				Number: partNumber,
    			}
    			continue
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    			objectsToDelete[object] = index
    		}
    	}
    
    	toNames := func(input map[ObjectToDelete]int) (output []ObjectToDelete) {
    		output = make([]ObjectToDelete, len(input))
    		idx := 0
    		for obj := range input {
    			output[idx] = obj
    			idx++
    		}
    		return
    	}
    
    	// Disable timeouts and cancellation
    	ctx = bgContext(ctx)
    
    	deleteList := toNames(objectsToDelete)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. cmd/sts-handlers_test.go

    		c.Fatalf("GetLDAPPolicyEntities should not fail: %v", err)
    	}
    	{
    		// Check that the mapping we created exists.
    		idx := slices.IndexFunc(policyResult.PolicyMappings, func(e madmin.PolicyEntities) bool {
    			return e.Policy == policy && slices.Contains(e.Groups, actualGroupDN)
    		})
    		if !(idx >= 0) {
    			c.Fatalf("expected groupDN (%s) to be present in mapping list: %#v", actualGroupDN, policyResult)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
Back to top