Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 212 for newReader (0.14 sec)

  1. cmd/storage-rest-client.go

    	}
    	respBody, err := client.call(ctx, storageRESTMethodReadMultiple, nil, bytes.NewReader(body), int64(len(body)))
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	pr, pw := io.Pipe()
    	go func() {
    		pw.CloseWithError(waitForHTTPStream(respBody, ioutil.NewDeadlineWriter(pw, globalDriveConfig.GetMaxTimeout())))
    	}()
    	mr := msgp.NewReader(pr)
    	defer readMsgpReaderPoolPut(mr)
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. cmd/server_test.go

    	c.Assert(err, nil)
    	// Verify if downloaded policy matches with previously uploaded.
    	expectedPolicy, err := policy.ParseBucketPolicyConfig(strings.NewReader(bucketPolicyStr), bucketName)
    	c.Assert(err, nil)
    	gotPolicy, err := policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyReadBuf), bucketName)
    	c.Assert(err, nil)
    	c.Assert(reflect.DeepEqual(expectedPolicy, gotPolicy), true)
    
    	// Delete policy.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  3. internal/s3select/select_test.go

    			}
    			s3Select, err := NewS3Select(bytes.NewReader(testReq))
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err = s3Select.Open(newStringRSC(input)); err != nil {
    				t.Fatal(err)
    			}
    
    			w := &testResponseWriter{}
    			s3Select.Evaluate(w)
    			s3Select.Close()
    			resp := http.Response{
    				StatusCode:    http.StatusOK,
    				Body:          io.NopCloser(bytes.NewReader(w.response)),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  4. src/archive/zip/fuzz_test.go

    		b, err := os.ReadFile(filepath.Join("testdata", de.Name()))
    		if err != nil {
    			f.Fatalf("failed to read testdata: %s", err)
    		}
    		f.Add(b)
    	}
    
    	f.Fuzz(func(t *testing.T, b []byte) {
    		r, err := NewReader(bytes.NewReader(b), int64(len(b)))
    		if err != nil {
    			return
    		}
    
    		type file struct {
    			header  *FileHeader
    			content []byte
    		}
    		files := []file{}
    
    		for _, f := range r.File {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 13 18:06:33 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  5. cmd/mrf_gen_test.go

    	}
    
    	vn := PartialOperation{}
    	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 BenchmarkEncodePartialOperation(b *testing.B) {
    	v := PartialOperation{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. cmd/tier_gen_test.go

    	}
    
    	vn := TierConfigMgr{}
    	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 BenchmarkEncodeTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  7. cmd/metacache-set_gen_test.go

    	}
    
    	vn := listPathOptions{}
    	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 BenchmarkEncodelistPathOptions(b *testing.B) {
    	v := listPathOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  8. cmd/metacache-walk_gen_test.go

    	}
    
    	vn := WalkDirOptions{}
    	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 BenchmarkEncodeWalkDirOptions(b *testing.B) {
    	v := WalkDirOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  9. cmd/site-replication-utils_gen_test.go

    	}
    
    	vn := SiteResyncStatus{}
    	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 BenchmarkEncodeSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  10. cmd/erasure-healing_test.go

    		t.Fatal(err)
    	}
    
    	oi1, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    	// 2nd version.
    	_, _ = rand.Read(data)
    	oi2, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	disk := er.getDisks()[0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top