Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for readParts (0.05 seconds)

  1. internal/hash/checksum_test.go

    	serializedOut := chksmOut.AppendTo(nil, checksumCombined)
    
    	// Read part checksums from serializedOut
    	readParts := ReadPartCheckSums(serializedOut)
    	expectedChecksums := []string{
    		part1Checksum.Encoded,
    		part2Checksum.Encoded,
    		part3Checksum.Encoded,
    	}
    	for i, expected := range expectedChecksums {
    		if got := readParts[i][ChecksumCRC32C.String()]; got != expected {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 22 14:15:21 GMT 2025
    - 7.1K bytes
    - Click Count (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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  4. 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))
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  5. cmd/xl-storage.go

    			logger.GetReqInfo(ctx).AppendTags("disk", s.String())
    			storageLogOnceIf(ctx, err, partPath)
    		}
    	}
    
    	return &resp, nil
    }
    
    func (s *xlStorage) ReadParts(ctx context.Context, volume string, partMetaPaths ...string) ([]*ObjectPartInfo, error) {
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return nil, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
Back to Top