Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for CheckParts (0.21 sec)

  1. 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) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.CheckParts(ctx, volume, path, fi)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error)
    	RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) error
    	CheckParts(ctx context.Context, volume string, path string, fi FileInfo) error
    	Delete(ctx context.Context, volume string, path string, opts DeleteOptions) (err error)
    	VerifyFile(ctx context.Context, volume, path string, fi FileInfo) error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  3. 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) error {
    	_, err := storageCheckPartsRPC.Call(ctx, client.gridConn, &CheckPartsHandlerParams{
    		DiskID:   *client.diskID.Load(),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/erasure-healing-common.go

    			if !meta.Deleted && !meta.IsRemote() {
    				dataErrs[i] = onlineDisk.VerifyFile(ctx, bucket, object, meta)
    			}
    		case madmin.HealNormalScan:
    			if !meta.Deleted && !meta.IsRemote() {
    				dataErrs[i] = onlineDisk.CheckParts(ctx, bucket, object, meta)
    			}
    		}
    
    		if dataErrs[i] == nil {
    			// All parts verified, mark it as all data available.
    			availableDisks[i] = onlineDisk
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	})
    }
    
    func (p *xlStorageDiskIDCheck) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCheckParts, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(&err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.CheckParts(ctx, volume, path, fi) })
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	n, err := w.Write(buf)
    	if err != nil {
    		return err
    	}
    
    	if n != len(buf) {
    		return io.ErrShortWrite
    	}
    
    	return nil
    }
    
    // CheckParts check if path has necessary parts available.
    func (s *xlStorage) CheckParts(ctx context.Context, volume string, path string, fi FileInfo) error {
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	if !s.checkID(p.DiskID) {
    		return grid.NewNPErr(errDiskNotFound)
    	}
    	volume := p.Volume
    	filePath := p.FilePath
    	return grid.NewNPErr(s.getStorage().CheckParts(context.Background(), volume, filePath, p.FI))
    }
    
    func (s *storageRESTServer) WriteAllHandler(p *WriteAllHandlerParams) (grid.NoPayload, *grid.RemoteErr) {
    	if !s.checkID(p.DiskID) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top