Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 536 for partID (0.04 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  2. internal/crypto/key_test.go

    	}
    }
    
    var derivePartKeyTest = []struct {
    	PartID  uint32
    	PartKey string
    }{
    	{PartID: 0, PartKey: "aa7855e13839dd767cd5da7c1ff5036540c9264b7a803029315e55375287b4af"},
    	{PartID: 1, PartKey: "a3e7181c6eed030fd52f79537c56c4d07da92e56d374ff1dd2043350785b37d8"},
    	{PartID: 10000, PartKey: "f86e65c396ed52d204ee44bd1a0bbd86eb8b01b7354e67a3b3ae0e34dd5bd115"},
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. internal/crypto/sse.go

    	}
    	return r
    }
    
    // EncryptMultiPart encrypts an io.Reader which must be the body of
    // multi-part PUT request. It derives an unique encryption key from
    // the partID and the object key.
    func EncryptMultiPart(r io.Reader, partID int, key ObjectKey) io.Reader {
    	partKey := key.DerivePartKey(uint32(partID))
    	return EncryptSinglePart(r, ObjectKey(partKey))
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  5. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  6. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  7. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  9. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  10. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top