Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 208 for newReader (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/postpolicyform_test.go

    			success: true,
    		},
    	}
    
    	for _, testCase := range testCases {
    		testCase := testCase
    		t.Run("", func(t *testing.T) {
    			_, err := parsePostPolicyForm(strings.NewReader(testCase.policy))
    			if testCase.success && err != nil {
    				t.Errorf("Expected success but failed with %s", err)
    			}
    			if !testCase.success && err == nil {
    				t.Errorf("Expected failed but succeeded")
    			}
    		})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 8.9K bytes
    - Viewed (0)
  7. 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)
  8. okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt

          ),
        )
      }
    
      @Test
      fun readSingleByteInt() {
        assertThat(newReader(byteStream()).readInt(10, 31)).isEqualTo(10)
        assertThat(newReader(byteStream()).readInt(0xe0 or 10, 31)).isEqualTo(10)
      }
    
      @Test
      fun readMultibyteInt() {
        assertThat(newReader(byteStream(154, 10)).readInt(31, 31)).isEqualTo(1337)
      }
    
      @Test
      fun writeSingleByteInt() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  9. cmd/bucket-handlers_test.go

    				int64(len(testCase.objects)), bytes.NewReader(testCase.objects), testCase.accessKey, testCase.secretKey, nil)
    		} else {
    			req, err = newTestRequest(http.MethodPost, getDeleteMultipleObjectsURL("", testCase.bucket),
    				int64(len(testCase.objects)), bytes.NewReader(testCase.objects))
    		}
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  10. 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)
Back to top