Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for readData (0.09 sec)

  1. cmd/erasure-healing_test.go

    	disk := er.getDisks()[0]
    	fileInfoPreHeal1, err := disk.ReadVersion(context.Background(), "", bucket, object, oi1.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    	fileInfoPreHeal2, err := disk.ReadVersion(context.Background(), "", bucket, object, oi2.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    func (er erasureObjects) getObjectFileInfo(ctx context.Context, bucket, object string, opts ObjectOptions, readData bool) (FileInfo, []FileInfo, []StorageAPI, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    	}
    	return d.disk.ReadAll(ctx, volume, path)
    }
    
    func (d *naughtyDisk) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return rf, err
    	}
    	return d.disk.ReadXL(ctx, volume, path, readData)
    }
    
    func (d *naughtyDisk) VerifyFile(ctx context.Context, volume, path string, fi FileInfo) (*CheckPartsResp, 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)
  4. cmd/erasure-metadata-utils.go

    func readAllFileInfo(ctx context.Context, disks []StorageAPI, origbucket string, bucket, object, versionID string, readData, healing bool) ([]FileInfo, []error) {
    	metadataArray := make([]FileInfo, len(disks))
    
    	opts := ReadOptions{
    		ReadData: readData,
    		Healing:  healing,
    	}
    
    	g := errgroup.WithNErrs(len(disks))
    	// Read `xl.meta` in parallel across disks.
    	for index := range disks {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    func (client *storageRESTClient) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	// Use websocket when not reading data.
    	if !readData {
    		resp, err := storageReadXLRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. cmd/storage-interface.go

    	ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (FileInfo, error)
    	ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error)
    	RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error)
    
    	// File operations.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	// Validate file path length, before reading.
    	filePath := pathJoin(volumeDir, path)
    	if err = checkPathLength(filePath); err != nil {
    		return fi, err
    	}
    
    	readData := opts.ReadData
    
    	buf, _, err := s.readRaw(ctx, volume, volumeDir, filePath, readData)
    	if err != nil {
    		if err == errFileNotFound {
    			if versionID != "" {
    				return fi, errFileVersionNotFound
    			}
    		}
    		return fi, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  8. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadAll(ctx, volume, path)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadXL, volume, path)
    	if err != nil {
    		return RawFileInfo{}, err
    	}
    	defer func() {
    		done(int64(len(rf.Buf)), &err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    
    	fi, err := s.getStorage().ReadVersion(context.Background(), origvolume, volume, filePath, versionID, ReadOptions{
    		InclFreeVersions: inclFreeVersions,
    		ReadData:         false,
    		Healing:          healing,
    	})
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    	return &fi, nil
    }
    
    // ReadVersionHandler read metadata of versionID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    	c.inStream.Range(func(key uint64, client *muxServer) bool {
    		client.cancel()
    		return true
    	})
    	c.inStream.Clear()
    }
    
    func (c *Connection) receive(conn net.Conn, r receiver) error {
    	b, op, err := wsutil.ReadData(conn, c.side)
    	if err != nil {
    		return err
    	}
    	if op != ws.OpBinary {
    		return fmt.Errorf("unexpected connect response type %v", op)
    	}
    	if c.incomingBytes != nil {
    		c.incomingBytes(int64(len(b)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top