- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for checkPart (0.08 sec)
-
cmd/naughty-disk_test.go
return err } return d.disk.RenameFile(ctx, srcVolume, srcPath, dstVolume, dstPath) } func (d *naughtyDisk) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) (*CheckPartsResp, error) { if err := d.calcError(); err != nil { return nil, err } return d.disk.CheckParts(ctx, volume, path, fi) } func (d *naughtyDisk) DeleteBulk(ctx context.Context, volume string, paths ...string) (err error) {
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
DiskID: *client.diskID.Load(), Volume: volume, FilePath: path, Buf: b, }) return toStorageErr(err) } // CheckParts - stat all file parts. func (client *storageRESTClient) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) (*CheckPartsResp, error) { var resp *CheckPartsResp
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-healing-common.go
// parts. This is considered an outdated disk, since // it needs healing too. verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta) default: verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta) } for p := range latestMeta.Parts { if verifyErr != nil { dataErrsByPart[p][i] = convPartErrToInt(verifyErr) } else { dataErrsByPart[p][i] = verifyResp.Results[p]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/sftp-server.go
return errors.New("public key authority validation requested but no ca public key specified.") } cert, ok := clientKey.(*ssh.Certificate) if !ok { return errSftpPublicKeyWithoutCert } // ssh.CheckCert called by ssh.Authenticate accepts certificates // with empty principles list so we block those in here. if len(cert.ValidPrincipals) == 0 { return errSftpCertWithoutPrincipals }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 20:00:29 UTC 2024 - 16K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
}) } func (p *xlStorageDiskIDCheck) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) (*CheckPartsResp, error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCheckParts, volume, path) if err != nil { return nil, err } defer done(0, &err) return p.storage.CheckParts(ctx, volume, path, fi) }
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-datatypes.go
checkPartSuccess checkPartDiskNotFound checkPartVolumeNotFound checkPartFileNotFound checkPartFileCorrupt ) // CheckPartsResp is a response of the storage CheckParts and VerifyFile APIs type CheckPartsResp struct { Results []int `msg:"r"` } // LocalDiskIDs - GetLocalIDs response. type LocalDiskIDs struct { IDs []string `msg:"i"` }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.checkID(p.DiskID) { return nil, grid.NewRemoteErr(errDiskNotFound) } volume := p.Volume filePath := p.FilePath resp, err := s.getStorage().CheckParts(context.Background(), volume, filePath, p.FI) return resp, grid.NewRemoteErr(err) } func (s *storageRESTServer) WriteAllHandler(p *WriteAllHandlerParams) (grid.NoPayload, *grid.RemoteErr) { if !s.checkID(p.DiskID) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 45.7K bytes - Viewed (0)