Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 192 for NewReader (0.18 sec)

  1. cmd/batch-handlers_gen_test.go

    	}
    
    	vn := BatchJobRequest{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBatchJobRequest(b *testing.B) {
    	v := BatchJobRequest{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 29 18:27:23 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  2. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		return
    	}
    
    	result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    
    	result.SubSys, _, _, err = config.GetSubSys(string(kvBytes))
    	if err != nil {
    		return
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
  3. cmd/post-policy-fan-out.go

    			hopts := hash.Options{
    				Size:       int64(len(fanOutBuf)),
    				MD5Hex:     opts.MD5Hex,
    				SHA256Hex:  "",
    				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
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  4. src/archive/tar/reader_test.go

    			switch j {
    			case 0:
    				tr = NewReader(&reader{strings.NewReader(v.input)})
    				s1, s2 = "io.Reader", "auto"
    			case 1:
    				tr = NewReader(&reader{strings.NewReader(v.input)})
    				s1, s2 = "io.Reader", "manual"
    			case 2:
    				tr = NewReader(&readSeeker{strings.NewReader(v.input)})
    				s1, s2 = "io.ReadSeeker", "auto"
    			case 3:
    				tr = NewReader(&readSeeker{strings.NewReader(v.input)})
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Nov 21 21:14:38 GMT 2022
    - 47.1K bytes
    - Viewed (0)
  5. internal/config/cache/remote_gen_test.go

    	}
    
    	vn := CondCheck{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeCondCheck(b *testing.B) {
    	v := CondCheck{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Nov 22 21:46:17 GMT 2023
    - 4.4K bytes
    - Viewed (0)
  6. cmd/storage-rest-common_gen_test.go

    	}
    
    	vn := nsScannerOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodensScannerOptions(b *testing.B) {
    	v := nsScannerOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4.6K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor_gen_test.go

    	}
    
    	vn := BucketBandwidthReport{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBucketBandwidthReport(b *testing.B) {
    	v := BucketBandwidthReport{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  8. cmd/dummy-data-generator_test.go

    	}
    	return true, ""
    }
    
    func TestCmpReaders(t *testing.T) {
    	{
    		r1 := bytes.NewReader([]byte("abc"))
    		r2 := bytes.NewReader([]byte("abc"))
    		ok, msg := cmpReaders(r1, r2)
    		if !(ok && msg == "") {
    			t.Fatalf("unexpected")
    		}
    	}
    
    	{
    		r1 := bytes.NewReader([]byte("abc"))
    		r2 := bytes.NewReader([]byte("abcd"))
    		ok, _ := cmpReaders(r1, r2)
    		if ok {
    			t.Fatalf("unexpected")
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  9. cmd/benchmark-utils_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    			mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    		if err != nil {
    			b.Fatal(err)
    		}
    		if objInfo.ETag != md5hex {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  10. src/cmd/addr2line/addr2line_test.go

    	out, err := cmd.CombinedOutput()
    	if err != nil {
    		t.Fatalf("%v: %v\n%s", cmd, err, string(out))
    	}
    	syms := make(map[string]string)
    	scanner := bufio.NewScanner(bytes.NewReader(out))
    	for scanner.Scan() {
    		f := strings.Fields(scanner.Text())
    		if len(f) < 3 {
    			continue
    		}
    		syms[f[2]] = f[0]
    	}
    	if err := scanner.Err(); err != nil {
    		t.Fatalf("error reading symbols: %v", err)
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Feb 21 22:16:54 GMT 2024
    - 3.8K bytes
    - Viewed (0)
Back to top