- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 106 for realCall (0.13 sec)
-
cmd/s3-zip-handlers.go
rs := &HTTPRangeSpec{IsSuffixLength: true, Start: int64(-size)} gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, rs, nil, opts) if err != nil { return nil, ObjectInfo{}, err } b, err := io.ReadAll(gr) gr.Close() if err != nil { return nil, ObjectInfo{}, err } if size > len(b) { size = len(b) } // Calculate the object real size if encrypted
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
t.Fatalf("Case %d: Expected the response status to be `%d`, but instead found `%d`", i+1, testCase.expectedRespStatus, recV4.Code) } // read the response body. bucketPolicyReadBuf, err := io.ReadAll(recV4.Body) if err != nil { t.Fatalf("Test %d: %s: Failed parsing response body: <ERROR> %v", i+1, instanceType, err) } if recV4.Code != testCase.expectedRespStatus {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } func parseJSONBody(ctx context.Context, body io.Reader, v interface{}, encryptionKey string) error { data, err := io.ReadAll(body) if err != nil { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, } } if encryptionKey != "" { data, err = madmin.DecryptData(encryptionKey, bytes.NewReader(data))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
src/archive/tar/reader.go
n += nn } if len(b) == n && err == io.EOF { err = nil } return n, err } // readSpecialFile is like io.ReadAll except it returns // ErrFieldTooLong if more than maxSpecialFileSize is read. func readSpecialFile(r io.Reader) ([]byte, error) { buf, err := io.ReadAll(io.LimitReader(r, maxSpecialFileSize+1)) if len(buf) > maxSpecialFileSize { return nil, ErrFieldTooLong } return buf, err }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
src/archive/zip/reader_test.go
return } start, err := f.DataOffset() if err != nil { t.Errorf("%v: DataOffset error=%v", f.Name, err) return } got, err := io.ReadAll(rw) if err != nil { t.Errorf("%v: OpenRaw ReadAll error=%v", f.Name, err) return } end := uint64(start) + f.CompressedSize64 want := raw[start:end] if !bytes.Equal(got, want) { t.Logf("got %q", got)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 55.6K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if disk == nil { return nil, errors.New("loadHealingTracker: nil drive given") } diskID, err := disk.GetDiskID() if err != nil { return nil, err } b, err := disk.ReadAll(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, healingTrackerFilename)) if err != nil { return nil, err } var h healingTracker _, err = h.UnmarshalMsg(b) if err != nil { return nil, err
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
var baseName string // versionID -> combineFiles := make(map[string][]string) decode := func(r io.Reader, file string) ([]byte, error) { file = strings.ReplaceAll(file, ":", "_") b, err := io.ReadAll(r) if err != nil { return nil, err } b, _, minor, err := checkXL2V1(b) if err != nil { return nil, err } filemap[file] = make(map[string]string)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 05 11:57:44 UTC 2024 - 40.3K bytes - Viewed (0) -
api/go1.19.txt
pkg go/doc, func Synopsis //deprecated #51082 pkg go/doc, func ToHTML //deprecated #51082 pkg go/doc, func ToText //deprecated #51082 pkg io/ioutil, func NopCloser //deprecated #42026 pkg io/ioutil, func ReadAll //deprecated #42026 pkg io/ioutil, func ReadDir //deprecated #42026 pkg io/ioutil, func ReadFile //deprecated #42026 pkg io/ioutil, func TempDir //deprecated #42026 pkg io/ioutil, func TempFile //deprecated #42026
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 17.9K bytes - Viewed (0) -
cmd/metacache-stream_test.go
r := loadMetacacheSample(t) defer r.Close() var readErr error objs := make(chan metaCacheEntry, 1) var wg sync.WaitGroup wg.Add(1) go func() { readErr = r.readAll(context.Background(), objs) wg.Done() }() want := loadMetacacheSampleNames i := 0 for entry := range objs { if entry.name != want[i] { t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
val zippedSize = zipped.size.toInt() writeMedium(frame, zippedSize) frame.writeByte(Http2.TYPE_DATA) frame.writeByte(FLAG_COMPRESSED) frame.writeInt(expectedStreamId and 0x7fffffff) zipped.readAll(frame) assertFailsWith<IOException> { reader.nextFrame(requireSettings = false, BaseTestHandler()) }.also { expected -> assertThat(expected.message)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K bytes - Viewed (0)