Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for readParts (0.04 sec)

  1. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.RenamePart(ctx, srcVolume, srcPath, dstVolume, dstPath, meta)
    }
    
    func (d *naughtyDisk) ReadParts(ctx context.Context, bucket string, partMetaPaths ...string) ([]*ObjectPartInfo, error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ReadParts(ctx, bucket, partMetaPaths...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		DstVolume:   dstVolume,
    		DstFilePath: dstPath,
    		Meta:        meta,
    	})
    	return toStorageErr(err)
    }
    
    // ReadParts - reads various part.N.meta paths from a drive remotely and returns object part info for each of those part.N.meta if found
    func (client *storageRESTClient) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) {
    	values := make(url.Values)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	partMetaPaths := make([]string, len(partNums))
    	for i, part := range partNums {
    		partMetaPaths[i] = pathJoin(partPath, fmt.Sprintf("part.%d.meta", part))
    	}
    
    	// Read parts in quorum
    	objParts, err := readParts(ctx, onlineDisks, minioMetaMultipartBucket, partMetaPaths,
    		partNums, readQuorum)
    	if err != nil {
    		return result, toObjectErr(err, bucket, object, uploadID)
    	}
    
    	count := maxParts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadParts, volume, path.Dir(partMetaPaths[0]))
    	if err != nil {
    		return nil, err
    	}
    	defer done(0, &err)
    
    	return p.storage.ReadParts(ctx, volume, partMetaPaths...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	var preq ReadPartsReq
    	if err := msgp.Decode(r.Body, &preq); err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	done := keepHTTPResponseAlive(w)
    	infos, err := s.getStorage().ReadParts(r.Context(), volume, preq.Paths...)
    	done(nil)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	presp := &ReadPartsResp{Infos: infos}
    	storageLogIf(r.Context(), msgp.Encode(w, presp))
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top