Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,105 for errC (0.02 sec)

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

    				ActualSize: -1,
    				DisableMD5: true,
    			}
    			hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts)
    			if err != nil {
    				errs[idx] = err
    				return
    			}
    
    			reader := NewPutObjReader(hr)
    			defer func() {
    				if err := reader.Close(); err != nil {
    					errs[idx] = err
    				}
    				if err := hr.Close(); err != nil {
    					errs[idx] = err
    				}
    			}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    			errs, bucket, object, versionID), err
    	}
    
    	readQuorum, _, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
    	if err != nil {
    		m, derr := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    		if derr == nil {
    			derr = errFileNotFound
    			if versionID != "" {
    				derr = errFileVersionNotFound
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  3. cmd/erasure-encode.go

    		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
    			}
    		}
    
    		eof := err == io.EOF || err == io.ErrUnexpectedEOF
    		if n == 0 && total != 0 {
    			// Reached EOF, nothing more to be done.
    			break
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. 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(targetsList.get(), types.TargetHTTP)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    	defer xhttp.DrainBody(respBody)
    	if err != nil {
    		if contextCanceled(ctx) {
    			err = ctx.Err()
    		}
    		for i := range errs {
    			errs[i] = err
    		}
    		return errs
    	}
    
    	reader, err := waitForHTTPResponse(respBody)
    	if err != nil {
    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.ListVols(ctx)
    }
    
    func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return VolInfo{}, err
    	}
    	return d.disk.StatVol(ctx, volume)
    }
    
    func (d *naughtyDisk) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. cmd/copy-part-range_test.go

    	}
    	objectSize := int64(10)
    
    	for _, successCase := range successCases {
    		rs, err := parseCopyPartRangeSpec(successCase.rangeString)
    		if err != nil {
    			t.Fatalf("expected: <nil>, got: %s", err)
    		}
    
    		start, length, err1 := rs.GetOffsetLength(objectSize)
    		if err1 != nil {
    			t.Fatalf("expected: <nil>, got: %s", err1)
    		}
    
    		if start != successCase.offsetBegin {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. cmd/peer-s3-client.go

    			if slices.Contains(client.GetPools(), poolIdx) {
    				perPoolErrs = append(perPoolErrs, errs[i])
    			}
    		}
    		quorum := len(perPoolErrs) / 2
    		if poolErr := reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum); poolErr != nil {
    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	for i, err := range errs {
    		if err == nil {
    			return healBucketResults[i], nil
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	lfi, err := meta.ToFileInfo(bucket, object, "", inclFreeVers, true)
    	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] = errFileCorrupt
    			}
    		}
    		return metaFileInfos, errs
    	}
    
    	versionID := lfi.VersionID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top