- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for readParts (0.05 seconds)
-
internal/hash/checksum_test.go
serializedOut := chksmOut.AppendTo(nil, checksumCombined) // Read part checksums from serializedOut readParts := ReadPartCheckSums(serializedOut) expectedChecksums := []string{ part1Checksum.Encoded, part2Checksum.Encoded, part3Checksum.Encoded, } for i, expected := range expectedChecksums { if got := readParts[i][ChecksumCRC32C.String()]; got != expected {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 22 14:15:21 GMT 2025 - 7.1K bytes - Click Count (0) -
cmd/erasure-multipart.go
partMetaPaths := make([]string, len(partNums)) for i, part := range partNums { partMetaPaths[i] = pathJoin(partPath, fmt.Sprintf("part.%d.meta", part)) } // Read parts in quorum objParts, err := readParts(ctx, onlineDisks, minioMetaMultipartBucket, partMetaPaths, partNums, readQuorum) if err != nil { return result, toObjectErr(err, bucket, object, uploadID) } count := maxParts
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 47.1K bytes - Click Count (0) -
cmd/storage-rest-client.go
DstFilePath: dstPath, Meta: meta, SkipParent: skipParent, }) return toStorageErr(err) } // ReadParts - reads various part.N.meta paths from a drive remotely and returns object part info for each of those part.N.meta if found func (client *storageRESTClient) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) { values := make(url.Values)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/storage-rest-server.go
var preq ReadPartsReq if err := msgp.Decode(r.Body, &preq); err != nil { s.writeErrorResponse(w, err) return } done := keepHTTPResponseAlive(w) infos, err := s.getStorage().ReadParts(r.Context(), volume, preq.Paths...) done(nil) if err != nil { s.writeErrorResponse(w, err) return } presp := &ReadPartsResp{Infos: infos} storageLogIf(r.Context(), msgp.Encode(w, presp)) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
cmd/xl-storage.go
logger.GetReqInfo(ctx).AppendTags("disk", s.String()) storageLogOnceIf(ctx, err, partPath) } } return &resp, nil } func (s *xlStorage) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) { volumeDir, err := s.getVolDir(volume) if err != nil { return nil, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0)