Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 440 for errC (0.04 sec)

  1. internal/s3select/sql/evaluate.go

    	}
    
    	var rhs Value
    	var err error
    	var eltVal *Value
    	switch {
    	case e.JPathExpr != nil:
    		eltVal, err = e.JPathExpr.evalNode(r, tableAlias)
    		if err != nil {
    			return nil, err
    		}
    	case e.ListExpr != nil:
    		eltVal, err = e.ListExpr.evalNode(r, tableAlias)
    		if err != nil {
    			return nil, err
    		}
    	default:
    		return nil, errInvalidASTNode
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. 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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    	}
    
    	if globalDNSConfig != nil {
    		if err := globalDNSConfig.Delete(bucket); err != nil {
    			return err
    		}
    	}
    	err := objAPI.DeleteBucket(ctx, bucket, opts)
    	if err != nil {
    		if globalDNSConfig != nil {
    			if err2 := globalDNSConfig.Put(bucket); err2 != nil {
    				replLogIf(ctx, fmt.Errorf("Unable to restore bucket DNS entry %w, please fix it manually", err2))
    			}
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  4. cmd/object-api-utils.go

    		off, length, skipLen, seqNumber, partStart, err = oi.GetDecryptedRange(rs)
    		if err != nil {
    			return nil, 0, 0, err
    		}
    		var decSize int64
    		decSize, err = oi.DecryptedSize()
    		if err != nil {
    			return nil, 0, 0, err
    		}
    		var decRangeLength int64
    		decRangeLength, err = rs.GetLength(decSize)
    		if err != nil {
    			return nil, 0, 0, err
    		}
    
    		// We define a closure that performs decryption given
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  5. cmd/config-current.go

    		}
    	case config.HealSubSys:
    		if _, err := heal.LookupConfig(s[config.HealSubSys][config.Default]); err != nil {
    			return err
    		}
    	case config.ScannerSubSys:
    		if _, err := scanner.LookupConfig(s[config.ScannerSubSys][config.Default]); err != nil {
    			return err
    		}
    	case config.EtcdSubSys:
    		etcdCfg, err := etcd.LookupConfig(s[config.EtcdSubSys][config.Default], globalRootCAs)
    		if err != nil {
    			return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top