Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ReadMultiple (0.18 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)
  5. cmd/storage-rest-server.go

    	done(err)
    	if err != nil {
    		return
    	}
    	for _, si := range stats {
    		msgp.Encode(w, &si)
    	}
    }
    
    // ReadMultiple returns multiple files
    func (s *storageRESTServer) ReadMultiple(w http.ResponseWriter, r *http.Request) {
    	if !s.IsValid(w, r) {
    		return
    	}
    	rw := streamHTTPResponse(w)
    	defer func() {
    		if r := recover(); r != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	return p.storage.StatInfoFile(ctx, volume, path, glob)
    }
    
    // ReadMultiple will read multiple files and send each files as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    func (p *xlStorageDiskIDCheck) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) (err error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context or network errors returns an error.
    func (client *storageRESTClient) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    		}
    	}
    
    	return &resp, nil
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    func (s *xlStorage) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top