- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for readParts (0.04 sec)
-
cmd/naughty-disk_test.go
return err } return d.disk.RenamePart(ctx, srcVolume, srcPath, dstVolume, dstPath, meta) } func (d *naughtyDisk) ReadParts(ctx context.Context, bucket string, partMetaPaths ...string) ([]*ObjectPartInfo, error) { if err := d.calcError(); err != nil { return nil, err } return d.disk.ReadParts(ctx, bucket, partMetaPaths...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
DstVolume: dstVolume, DstFilePath: dstPath, Meta: meta, }) 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)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadParts, volume, path.Dir(partMetaPaths[0])) if err != nil { return nil, err } defer done(0, &err) return p.storage.ReadParts(ctx, volume, partMetaPaths...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (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)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 45.7K bytes - Viewed (0)