Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 597 for errs (0.2 sec)

  1. cmd/erasure-healing.go

    			errs, bucket, object, versionID), err
    	}
    
    	readQuorum, _, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
    	if err != nil {
    		m, err := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    		for i := range errs {
    			errs[i] = err
    		}
    		if err == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:26:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common_test.go

    			if err != nil {
    				t.Fatalf("Failed to getLatestFileInfo %v", err)
    			}
    
    			for j := range partsMetadata {
    				if errs[j] != nil {
    					t.Fatalf("expected error to be nil: %s", errs[j])
    				}
    				partsMetadata[j].ModTime = test.modTimes[j]
    			}
    
    			tamperedIndex := -1
    			switch test._tamperBackend {
    			case deletePart:
    				for index, err := range test.errs {
    					if err != nil {
    						continue
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  3. cmd/peer-s3-server.go

    				}
    				return err
    			}
    
    			bucketsInfo[index] = BucketInfo{Name: bucket, Created: volInfo.Created}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    	if err := reduceReadQuorumErrs(ctx, errs, bucketOpIgnoredErrs, (len(localDrives) / 2)); err != nil {
    		return BucketInfo{}, err
    	}
    
    	var bucketInfo BucketInfo
    	for i, err := range errs {
    		if err == nil {
    			bucketInfo = bucketsInfo[i]
    			break
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Checking abandoned parts should do nothing
    	err = er.checkAbandonedParts(ctx, bucket, object, madmin.HealOpts{ScanMode: madmin.HealNormalScan, Remove: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	_, err = er.HealObject(ctx, bucket, object, "", madmin.HealOpts{ScanMode: madmin.HealNormalScan})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  5. cmd/erasure-metadata-utils.go

    // the corresponding error in errs slice is not nil
    func evalDisks(disks []StorageAPI, errs []error) []StorageAPI {
    	if len(errs) != len(disks) {
    		bugLogIf(GlobalContext, errors.New("unexpected drives/errors slice length"))
    		return nil
    	}
    	newDisks := make([]StorageAPI, len(disks))
    	for index := range errs {
    		if errs[index] == nil {
    			newDisks[index] = disks[index]
    		} else {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common.go

    		modTimes[i] = timeSentinel
    	}
    	return modTimes
    }
    
    func listObjectETags(partsMetadata []FileInfo, errs []error, quorum int) (etags []string) {
    	etags = make([]string, len(partsMetadata))
    	vidMap := map[string]int{}
    	for index, metadata := range partsMetadata {
    		if errs[index] != nil {
    			continue
    		}
    		vid := metadata.VersionID
    		if metadata.VersionID == "" {
    			vid = nullVersionID
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  7. istioctl/pkg/validate/validate.go

    		if err != nil {
    			errs = multierror.Append(errs, err)
    		}
    		err = reader.Close()
    		if err != nil {
    			log.Infof("file: %s is not closed: %v", path, err)
    		}
    		warningsByFilename[path] = warning
    	}
    	processDirectory := func(directory string, processFile func(string)) error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  8. internal/logger/targets.go

    	tgts := make([]*http.Target, 0)
    	newWebhooks := make([]Target, 0)
    	for _, cfg := range cfgs {
    		if cfg.Enabled {
    			t, err := http.New(cfg)
    			if err != nil {
    				errs = append(errs, err)
    			}
    			tgts = append(tgts, t)
    			newWebhooks = append(newWebhooks, t)
    		}
    	}
    
    	oldTargets, others := splitTargets(*targetList, types.TargetHTTP)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    	lfi, err := meta.ToFileInfo(bucket, object, "", inclFreeVers, allParts)
    	if err != nil {
    		for i := range errs {
    			if errs[i] == nil {
    				errs[i] = err
    			}
    		}
    		return metaFileInfos, errs
    	}
    	if !lfi.IsValid() {
    		for i := range errs {
    			if errs[i] == nil {
    				errs[i] = errCorruptedFormat
    			}
    		}
    		return metaFileInfos, errs
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  10. cmd/erasure-encode.go

    	writer := &parallelWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    		errs:        make([]error, len(writers)),
    	}
    
    	for {
    		var blocks [][]byte
    		n, err := io.ReadFull(src, buf)
    		if err != nil {
    			if !IsErrIgnored(err, []error{
    				io.EOF,
    				io.ErrUnexpectedEOF,
    			}...) {
    				return 0, err
    			}
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3K bytes
    - Viewed (0)
Back to top