Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ReadParts (0.05 sec)

  1. cmd/naughty-disk_test.go

    	}
    	return d.disk.RenamePart(ctx, srcVolume, srcPath, dstVolume, dstPath, meta, skipParent)
    }
    
    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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    		DstFilePath: dstPath,
    		Meta:        meta,
    		SkipParent:  skipParent,
    	})
    	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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top