Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ReadFileStream (0.19 sec)

  1. cmd/naughty-disk_test.go

    		return 0, err
    	}
    	return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier)
    }
    
    func (d *naughtyDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ReadFileStream(ctx, volume, path, offset, length)
    }
    
    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-rest-common.go

    	storageRESTMethodReadVersion    = "/readversion"
    	storageRESTMethodReadXL         = "/readxl"
    	storageRESTMethodReadAll        = "/readall"
    	storageRESTMethodReadFile       = "/readfile"
    	storageRESTMethodReadFileStream = "/readfilestream"
    	storageRESTMethodListDir        = "/listdir"
    	storageRESTMethodDeleteVersions = "/deleteverions"
    	storageRESTMethodRenameFile     = "/renamefile"
    	storageRESTMethodVerifyFile     = "/verifyfile"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 21:00:20 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    	CreateFile(ctx context.Context, origvolume, olume, path string, size int64, reader io.Reader) error
    	ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error)
    	RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) 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)
  4. cmd/bitrot-streaming.go

    		b.currOffset = offset
    		streamOffset := (offset/b.shardSize)*int64(b.h.Size()) + offset
    		if len(b.data) == 0 && b.tillOffset != streamOffset {
    			b.rc, err = b.disk.ReadFileStream(context.TODO(), b.volume, b.filePath, streamOffset, b.tillOffset-streamOffset)
    		} else {
    			b.rc = io.NewSectionReader(bytes.NewReader(b.data), streamOffset, b.tillOffset-streamOffset)
    		}
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    		Volume:   volume,
    		FilePath: path,
    	})
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	return *gridBytes, nil
    }
    
    // ReadFileStream - returns a reader for the requested file.
    func (client *storageRESTClient) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    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)
  6. cmd/erasure-encode_test.go

    func (a badDisk) String() string {
    	return "bad-disk"
    }
    
    func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	return errFaultyDisk
    }
    
    func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	return nil, errFaultyDisk
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    	if err != nil {
    		return err
    	}
    	defer done(&err)
    
    	return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader))
    }
    
    func (p *xlStorageDiskIDCheck) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadFileStream, volume, path)
    	if err != nil {
    		return nil, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    		default:
    			return nil, err
    		}
    	}
    
    	return w, nil
    }
    
    type sendFileReader struct {
    	io.Reader
    	io.Closer
    }
    
    // ReadFileStream - Returns the read stream of the file.
    func (s *xlStorage) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if offset < 0 {
    		return nil, errInvalidArgument
    	}
    
    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)
  9. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	w.Header().Set(xhttp.ContentLength, strconv.Itoa(length))
    
    	rc, err := s.getStorage().ReadFileStream(r.Context(), volume, filePath, int64(offset), int64(length))
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	defer rc.Close()
    
    	rf, ok := w.(io.ReaderFrom)
    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)
  10. cmd/erasure-server-pool.go

    				if err != nil {
    					continue
    				}
    				for _, si := range stats {
    					found++
    					var r io.ReadCloser
    					if !si.Dir {
    						r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size)
    						if err != nil {
    							continue
    						}
    					} else {
    						r = io.NopCloser(bytes.NewBuffer([]byte{}))
    					}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top