Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 292 for partID (0.78 sec)

  1. cmd/object-api-multipart_test.go

    	for _, part := range parts {
    		_, err = obj.PutObjectPart(context.Background(), part.bucketName, part.objName, part.uploadID, part.PartID, mustGetPutObjReader(t, bytes.NewBufferString(part.inputReaderData), part.inputDataSize, part.inputMd5, sha256sum), opts)
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err)
    		}
    	}
    	// Parts to be sent as input for CompleteMultipartUpload.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    	uploadID := r.Form.Get(xhttp.UploadID)
    	partIDString := r.Form.Get(xhttp.PartNumber)
    
    	partID, err := strconv.Atoi(partIDString)
    	if err != nil || partID <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidPart), r.URL)
    		return
    	}
    
    	// check partID with maximum part ID for multipart objects
    	if isMaxPartID(partID) {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidMaxParts), r.URL)
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  3. cmd/erasure-healing_test.go

    	}
    
    	// Create an object with multiple parts uploaded in decreasing
    	// part number.
    	res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    		t.Fatalf("Failed to create a multipart upload - %v", err)
    	}
    
    	var uploadedParts []CompletePart
    	for _, partID := range []int{2, 1} {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    	currentFI := fi
    
    	// Allocate parts similar to incoming slice.
    	fi.Parts = make([]ObjectPartInfo, len(parts))
    
    	var checksum hash.Checksum
    	checksum.Type = checksumType
    
    	// Validate each part and then commit to disk.
    	for i, part := range parts {
    		partIdx := objectPartIndex(currentFI.Parts, part.PartNumber)
    		// All parts should have same part number.
    		if partIdx == -1 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    	CopyObjectPart(ctx context.Context, srcBucket, srcObject, destBucket, destObject string, uploadID string, partID int,
    		startOffset int64, length int64, srcInfo ObjectInfo, srcOpts, dstOpts ObjectOptions) (info PartInfo, err error)
    	PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data *PutObjReader, opts ObjectOptions) (info PartInfo, err error)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    		return PartInfo{}, err
    	}
    
    	return z.PutObjectPart(ctx, destBucket, destObject, uploadID, partID,
    		srcInfo.PutObjReader, dstOpts)
    }
    
    // PutObjectPart - writes part of an object to hashedSet based on the object name.
    func (z *erasureServerPools) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data *PutObjReader, opts ObjectOptions) (PartInfo, error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  7. cmd/utils.go

    	return size > globalMaxObjectSize
    }
    
    // Check if part size is more than or equal to minimum allowed size.
    func isMinAllowedPartSize(size int64) bool {
    	return size >= globalMinPartSize
    }
    
    // isMaxPartNumber - Check if part ID is greater than the maximum allowed ID.
    func isMaxPartID(partID int) bool {
    	return partID > globalMaxPartID
    }
    
    // profilerWrapper is created because pkg/profiler doesn't
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    }
    
    // PutObjectPart - writes part of an object to hashedSet based on the object name.
    func (s *erasureSets) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data *PutObjReader, opts ObjectOptions) (info PartInfo, err error) {
    	set := s.getHashedSet(object)
    	return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  9. cmd/encryption-v1.go

    	partDecRelOffset, partEncRelOffset int64
    }
    
    func (d *DecryptBlocksReader) buildDecrypter(partID int) error {
    	var partIDbin [4]byte
    	binary.LittleEndian.PutUint32(partIDbin[:], uint32(partID)) // marshal part ID
    
    	mac := hmac.New(sha256.New, d.objectEncryptionKey) // derive part encryption key from part ID and object key
    	mac.Write(partIDbin[:])
    	partEncryptionKey := mac.Sum(nil)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    		// Upload each part
    		var cp []CompletePart
    		cumulativeSum := int64(0)
    		for i, partLen := range partSizes {
    			partID := i + 1
    			partSrc := NewDummyDataGen(partLen, cumulativeSum)
    			cumulativeSum += partLen
    			req, errP := newTestSignedRequestV4(http.MethodPut,
    				getPutObjectPartURL("", bucketName, objectName, upID, fmt.Sprintf("%d", partID)),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top