Search Options

Results per page
Sort
Preferred Languages
Advance

Results 821 - 830 of 1,020 for err (0.03 sec)

  1. internal/disk/disk_test.go

    package disk_test
    
    import (
    	"testing"
    
    	"github.com/minio/minio/internal/disk"
    )
    
    func TestFree(t *testing.T) {
    	di, err := disk.GetInfo(t.TempDir(), true)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if di.FSType == "UNKNOWN" {
    		t.Error("Unexpected FSType", di.FSType)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 31 22:20:48 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  2. cmd/object-api-common.go

    }
    
    // Depending on the disk type network or local, initialize storage API.
    func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) {
    	if endpoint.IsLocal {
    		storage, err := newXLStorage(endpoint, opts.cleanUp)
    		if err != nil {
    			return nil, err
    		}
    		return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil
    	}
    
    	return newStorageRESTClient(endpoint, opts.healthCheck, globalGrid.Load())
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/line_test.go

    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    			t.Errorf("#%d: %q: want error %q; have none", i, test.input, test.error)
    		case !strings.Contains(err.Error(), test.error):
    			t.Errorf("#%d: %q: want error %q; have %q", i, test.input, test.error, err)
    		}
    	}
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/endpoint_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/endpoint/configdump.json")
    			cw.Prime(cd)
    			err := cw.PrintEndpointsSummary(tt.filter)
    			assert.NoError(t, err)
    
    			wantOutputFile := path.Join("testdata/endpoint", fmt.Sprintf("%s_output.txt", tt.name))
    			util.CompareContent(t, gotOut.Bytes(), wantOutputFile)
    		})
    	}
    }
    
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Tue Jul 12 02:25:59 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  5. cmd/object-handlers-common.go

    	// since the specified time otherwise return 412 (precondition failed).
    	ifModifiedSinceHeader := r.Header.Get(xhttp.AmzCopySourceIfModifiedSince)
    	if ifModifiedSinceHeader != "" {
    		if givenTime, err := amztime.ParseHeader(ifModifiedSinceHeader); err == nil {
    			if !ifModifiedSince(objInfo.ModTime, givenTime) {
    				// If the object is not modified since the specified time.
    				writeHeaders()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/parse.go

    func (p *Parser) positiveAtoi(str string) int64 {
    	value, err := strconv.ParseInt(str, 0, 64)
    	if err != nil {
    		p.errorf("%s", err)
    	}
    	if value < 0 {
    		p.errorf("%s overflows int64", str)
    	}
    	return value
    }
    
    func (p *Parser) atoi(str string) uint64 {
    	value, err := strconv.ParseUint(str, 0, 64)
    	if err != nil {
    		p.errorf("%s", err)
    	}
    	return value
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  7. internal/hash/checksum.go

    		if len(valSplit) != 2 {
    			return nil
    		}
    		value = valSplit[0]
    		nParts, err := strconv.Atoi(valSplit[1])
    		if err != nil {
    			return nil
    		}
    		alg |= ChecksumMultipart
    		wantParts = nParts
    	}
    	bvalue, err := base64.StdEncoding.DecodeString(value)
    	if err != nil {
    		return nil
    	}
    	c := Checksum{Type: alg, Encoded: value, Raw: bvalue, WantParts: wantParts}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. cmd/metacache-manager.go

    // Should only be called if a failure occurred.
    func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error {
    	// We operate on a copy...
    	o.Create = false
    	c, err := rpc.GetMetacacheListing(ctx, o)
    	if err != nil {
    		return err
    	}
    	cache := *c
    
    	if cache.status == scanStateNone || cache.fileNotFound {
    		return errFileNotFound
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  9. istioctl/pkg/metrics/metrics_test.go

    			WantException:  true,
    		},
    	}
    
    	ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    		IstioNamespace: "istio-system",
    	})
    	client, err := ctx.CLIClient()
    	if err != nil {
    		t.Fatal(err)
    	}
    	client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "prometheus",
    			Namespace: "istio-system",
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 01:35:47 UTC 2024
    - 8K bytes
    - Viewed (0)
  10. internal/grid/trace.go

    	remote := strings.TrimPrefix(strings.TrimPrefix(t.Remote, httpsScheme), httpScheme)
    
    	start := time.Now()
    	body := bytesOrLength(req)
    	resp, err := c.roundtrip(h, req)
    	end := time.Now()
    	status := http.StatusOK
    	errString := ""
    	if err != nil {
    		errString = err.Error()
    		if IsRemoteErr(err) == nil {
    			status = http.StatusInternalServerError
    		} else {
    			status = http.StatusBadRequest
    		}
    	}
    
    	prefix := t.Prefix
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top