Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ReadMultiple (0.15 sec)

  1. cmd/storage-rest-common.go

    	storageRESTMethodRenameFile     = "/renamefile"
    	storageRESTMethodVerifyFile     = "/verifyfile"
    	storageRESTMethodStatInfoFile   = "/statfile"
    	storageRESTMethodReadMultiple   = "/readmultiple"
    	storageRESTMethodCleanAbandoned = "/cleanabandoned"
    )
    
    const (
    	storageRESTVolume        = "volume"
    	storageRESTVolumes       = "volumes"
    	storageRESTDirPath       = "dir-path"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	VerifyFile(ctx context.Context, volume, path string, fi FileInfo) (*CheckPartsResp, error)
    	StatInfoFile(ctx context.Context, volume, path string, glob bool) (stat []StatInfo, err error)
    	ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error
    	CleanAbandonedData(ctx context.Context, volume string, path string) error
    
    	// Write all data, syncs the data to disk.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    		return stat, err
    	}
    	return d.disk.StatInfoFile(ctx, volume, path, glob)
    }
    
    func (d *naughtyDisk) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
    	if err := d.calcError(); err != nil {
    		close(resp)
    		return err
    	}
    	return d.disk.ReadMultiple(ctx, req, resp)
    }
    
    func (d *naughtyDisk) CleanAbandonedData(ctx context.Context, volume string, path string) error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/erasure-common.go

    	// Read files in parallel across disks.
    	for index := range disks {
    		index := index
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].ReadMultiple(ctx, req, resps[index])
    		}, index)
    	}
    
    	dataArray := make([]ReadMultipleResp, 0, len(req.Files))
    	// Merge results. They should come in order from each.
    	for _, wantFile := range req.Files {
    		quorum := 0
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top