Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 2,412 for erros (0.02 sec)

  1. cmd/xl-storage.go

    	errs := make([]error, len(versions))
    
    	for i, fiv := range versions {
    		if contextCanceled(ctx) {
    			errs[i] = ctx.Err()
    			continue
    		}
    		errs[i] = s.deleteVersions(ctx, volume, fiv.Name, fiv.Versions...)
    		diskHealthCheckOK(ctx, errs[i])
    	}
    
    	return errs
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. cmd/object-api-utils.go

    	}
    
    	if nDisks < len(di)/2 || nDisks <= 0 {
    		var errs []error
    		for index, disk := range di {
    			switch {
    			case disk == nil:
    				errs = append(errs, fmt.Errorf("disk[%d]: offline", index))
    			case disk.Error != "":
    				errs = append(errs, fmt.Errorf("disk %s: %s", disk.Endpoint, disk.Error))
    			case disk.Total == 0:
    				errs = append(errs, fmt.Errorf("disk %s: total is zero", disk.Endpoint))
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  3. cmd/metrics-v3-system-network.go

    //
    // This is a `MetricsLoaderFn`.
    func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	connStats := globalConnStats.toServerConnStats()
    	rpcStats := rest.GetRPCStats()
    	if globalIsDistErasure {
    		m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
    		m.Set(internodeDialErrorsTotal, float64(rpcStats.DialErrs))
    		m.Set(internodeDialAvgTimeNanos, float64(rpcStats.DialAvgDuration))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    -----------------
    failure for all cases.
    
    // Pseudo code for managing `format.json`.
    
    // Generic checks.
    if (no quorum) return error
    if (any disk is corrupt) return error // Always error
    if (jbod inconsistent) return error // Always error.
    if (disks not recognized) // Always error.
    
    // Specific checks.
    if (all disks online)
      if (all disks return format.json)
         if (jbod consistent)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. tests/error_translator_test.go

    package tests_test
    
    import (
    	"errors"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestDialectorWithErrorTranslatorSupport(t *testing.T) {
    	// it shouldn't translate error when the TranslateError flag is false
    	translatedErr := errors.New("translated error")
    	untranslatedErr := errors.New("some random error")
    	db, _ := gorm.Open(tests.DummyDialector{TranslatedErr: translatedErr})
    
    	err := db.AddError(untranslatedErr)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jul 12 13:21:22 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  6. cmd/admin-handler-utils.go

    // specific error.
    func toAdminAPIErrCode(ctx context.Context, err error) APIErrorCode {
    	if errors.Is(err, errErasureWriteQuorum) {
    		return ErrAdminConfigNoQuorum
    	}
    	return toAPIErrorCode(ctx, err)
    }
    
    // wraps export error for more context
    func exportError(ctx context.Context, err error, fname, entity string) APIError {
    	if entity == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. istioctl/pkg/proxyconfig/proxyconfig.go

    					}
    				}
    				if err != nil {
    					errs = multierror.Append(errs, fmt.Errorf("error configuring log level for %v.%v: %v", podName, podNamespace, err))
    				} else {
    					_, _ = fmt.Fprintf(c.OutOrStdout(), "%v.%v:\n%v", podName, podNamespace, resp)
    				}
    			}
    			if err := multierror.Flatten(errs.ErrorOrNil()); err != nil {
    				return err
    			}
    			return nil
    		},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  8. cni/pkg/ipset/nldeps_unspecified.go

    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) flush(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. tests/test_additional_responses_response_class.py

    
    class JsonApiResponse(JSONResponse):
        media_type = "application/vnd.api+json"
    
    
    class Error(BaseModel):
        status: str
        title: str
    
    
    class JsonApiError(BaseModel):
        errors: typing.List[Error]
    
    
    @app.get(
        "/a",
        response_class=JsonApiResponse,
        responses={500: {"description": "Error", "model": JsonApiError}},
    )
    async def a():
        pass  # pragma: no cover
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jun 30 18:25:16 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  10. internal/logger/logonce.go

    	}
    }
    
    const unwrapErrsDepth = 3
    
    // unwrapErrs upto the point where errors.Unwrap(err) returns nil
    func unwrapErrs(err error) (leafErr error) {
    	uerr := errors.Unwrap(err)
    	depth := 1
    	for uerr != nil {
    		// Save the current `uerr`
    		leafErr = uerr
    		// continue to look for leaf errors underneath
    		uerr = errors.Unwrap(leafErr)
    		depth++
    		if depth == unwrapErrsDepth {
    			// If we have reached enough depth we
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top