Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 41 for UploadID (0.14 sec)

  1. cmd/erasure-server-pool.go

    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    func (z *erasureServerPools) GetMultipartInfo(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (MultipartInfo, error) {
    	if err := checkListPartsArgs(ctx, bucket, object, uploadID); err != nil {
    		return MultipartInfo{}, err
    	}
    
    	uploadIDLock := z.NewNSLock(bucket, pathJoin(object, uploadID))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts)
    }
    
    // GetMultipartInfo - return multipart metadata info uploaded at hashedSet.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  3. cmd/api-resources_test.go

    			t.Errorf("Test %d: Expected %s, got %s", i+1, testCase.uploadID, uploadID)
    		}
    		if partNumberMarker != testCase.partNumberMarker {
    			t.Errorf("Test %d: Expected %d, got %d", i+1, testCase.partNumberMarker, partNumberMarker)
    		}
    		if maxParts != testCase.maxParts {
    			t.Errorf("Test %d: Expected %d, got %d", i+1, testCase.maxParts, maxParts)
    		}
    		if encodingType != testCase.encodingType {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 7.1K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    			uploadID:         uploadID,
    			copySourceHeader: url.QueryEscape(SlashSeparator + bucketName + SlashSeparator + testObject),
    			accessKey:        credentials.AccessKey,
    			secretKey:        credentials.SecretKey,
    
    			expectedRespStatus: http.StatusNotFound,
    		},
    
    		// Test case - 4.
    		// Test case with valid byte range.
    		{
    			bucketName:       bucketName,
    			uploadID:         uploadID,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  5. buildscripts/multipart-quorum-test.sh

    	aws --endpoint-url http://localhost:"$start_port" s3api create-multipart-upload --bucket bucket --key obj-1 >upload-id.json
    	uploadId=$(jq -r '.UploadId' upload-id.json)
    
    	truncate -s 5MiB file-5mib
    	for i in {1..2}; do
    		aws --endpoint-url http://localhost:"$start_port" s3api upload-part \
    			--upload-id "$uploadId" --bucket bucket --key obj-1 \
    			--part-number "$i" --body ./file-5mib
    	done
    	for i in {1..6}; do
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 10:51:23 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. cmd/object_api_suite_test.go

    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	res, err := obj.NewMultipartUpload(context.Background(), "bucket", "key", opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	uploadID := res.UploadID
    
    	// Create a byte array of 5MiB.
    	data := bytes.Repeat([]byte("0123456789abcdef"), 5*humanize.MiByte/16)
    	completedParts := CompleteMultipartUpload{}
    	for i := 1; i <= 10; i++ {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	}
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.GetObjectAction, srcBucket, srcObject); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	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)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  8. cmd/object-api-putobject_test.go

    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    	uploadID := res.UploadID
    
    	// Upload part1.
    	fiveMBBytes := bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	md5Writer := md5.New()
    	md5Writer.Write(fiveMBBytes)
    	etag1 := hex.EncodeToString(md5Writer.Sum(nil))
    	sha256sum := ""
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  9. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Upload a part
    	partData := bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	md5Hex := getMD5Hash(partData)
    	_, err = obj.PutObjectPart(ctx, bucket, object, res.UploadID, 1,
    		mustGetPutObjReader(t, bytes.NewReader(partData), int64(len(partData)), md5Hex, ""),
    		ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Now simulate read quorum failure
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    }
    
    func getPutObjectPartURL(endPoint, bucketName, objectName, uploadID, partNumber string) string {
    	queryValues := url.Values{}
    	queryValues.Set("uploadId", uploadID)
    	queryValues.Set("partNumber", partNumber)
    	return makeTestTargetURL(endPoint, bucketName, objectName, queryValues)
    }
    
    func getCopyObjectPartURL(endPoint, bucketName, objectName, uploadID, partNumber string) string {
    	queryValues := url.Values{}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top