Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 64 for merrs (0.12 seconds)

  1. cmd/naughty-disk_test.go

    func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
    	if err := d.calcError(); err != nil {
    		errs := make([]error, len(versions))
    		for i := range errs {
    			errs[i] = err
    		}
    		return errs
    	}
    	return d.disk.DeleteVersions(ctx, volume, versions, opts)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  2. cmd/peer-s3-client.go

    	if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil {
    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	for i, err := range errs {
    		if err == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  4. internal/http/listener_test.go

    		{[]string{nonLoopBackIP + ":0"}},
    		{[]string{"127.0.0.1:0", nonLoopBackIP + ":0"}},
    	}
    
    nextTest:
    	for i, testCase := range testCases {
    		listener, errs := newHTTPListener(t.Context(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for _, err := range errs {
    			if err != nil {
    				if strings.Contains(err.Error(), "The requested address is not valid in its context") {
    					// Ignore if IP is unbindable.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  5. cmd/metacache-set.go

    	// if disk did not return any result, but also haven't errored
    	// the entry will be empty and errs will
    	partial func(entries metaCacheEntries, errs []error)
    
    	// finished will be called when all streams have finished and
    	// more than one disk returned an error.
    	// Will not be called if everything operates as expected.
    	finished func(errs []error)
    }
    
    // listPathRaw will list a path on the provided drives.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  6. internal/rest/rpc-stats.go

    	"net/http/httptrace"
    	"sync/atomic"
    	"time"
    )
    
    var globalStats = struct {
    	errs uint64
    
    	tcpDialErrs                 uint64
    	tcpDialCount                uint64
    	tcpDialTotalDur             uint64
    	tcpTimeForFirstByteTotalDur uint64
    }{}
    
    // RPCStats holds information about the DHCP/TCP metrics and errors
    type RPCStats struct {
    	Errs uint64
    
    	DialAvgDuration uint64
    	TTFBAvgDuration uint64
    	DialErrs        uint64
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 13 18:21:34 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  7. cmd/admin-handlers-users-race_test.go

    				if err != nil {
    					return err
    				}
    				c.mustNotListObjects(ctx, uClient, bucket)
    				return nil
    			}
    		}(i), i)
    	}
    	if errs := g.Wait(); len(errs) > 0 {
    		c.Fatalf("unable to remove users: %v", errs)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4K bytes
    - Click Count (0)
  8. cmd/erasure-metadata_test.go

    		}
    		return ps
    	}
    
    	mkTest := func(N, parity, agree int) (res struct {
    		metaArr  []FileInfo
    		errs     []error
    		parities []int
    		parity   int
    	},
    	) {
    		res.metaArr = mkMetaArr(N, parity, agree)
    		res.parities = mkParities(N, N-(N/2+1), parity, agree)
    		res.errs = make([]error, N)
    		if agree >= N/2+1 { // simple majority consensus
    			res.parity = N - (N/2 + 1)
    		} else {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  9. cmd/storage-rest-server.go

    		return errFileAccessDenied
    	}
    
    	if countErrs(errs, errDiskNotDir) == len(errs) {
    		return errDiskNotDir
    	}
    
    	if countErrs(errs, errFaultyDisk) == len(errs) {
    		return errFaultyDisk
    	}
    
    	if countErrs(errs, errXLBackend) == len(errs) {
    		return errXLBackend
    	}
    
    	return nil
    }
    
    // A single function to write certain errors to be fatal
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  10. cmd/xl-storage-disk-id-check.go

    	// Merely for tracing storage
    	path := ""
    	if len(versions) > 0 {
    		path = versions[0].Name
    	}
    	errs = make([]error, len(versions))
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDeleteVersions, volume, path)
    	if err != nil {
    		for i := range errs {
    			errs[i] = ctx.Err()
    		}
    		return errs
    	}
    	defer func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
Back to Top