- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 208 for newReader (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)