Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for uploadID (0.12 sec)

  1. cmd/object-api-multipart_test.go

    		// Test Case - 10.
    		// Case with valid UploadID, existing bucket name.
    		// But using the bucket name from which NewMultipartUpload is not constructed from.
    		{bucketName: "unused-bucket", objName: object, uploadID: uploadID, PartID: 1, expectedError: fmt.Errorf("%s", "Invalid upload id "+uploadID)},
    		// Test Case - 11.
    		// Case with valid UploadID, existing bucket name.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		for uploadIndex < len(uploads) {
    			if uploads[uploadIndex].UploadID != uploadIDMarker {
    				uploadIndex++
    				continue
    			}
    			if uploads[uploadIndex].UploadID == uploadIDMarker {
    				uploadIndex++
    				break
    			}
    			uploadIndex++
    		}
    	}
    	for uploadIndex < len(uploads) {
    		result.Uploads = append(result.Uploads, uploads[uploadIndex])
    		result.NextUploadIDMarker = uploads[uploadIndex].UploadID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. cmd/api-response.go

    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    	for index, upload := range multipartsInfo.Uploads {
    		newUpload := Upload{}
    		newUpload.UploadID = upload.UploadID
    		newUpload.Key = s3EncodeName(upload.Object, encodingType)
    		newUpload.Initiated = amztime.ISO8601Format(upload.Initiated.UTC())
    		listMultipartUploadsResponse.Uploads[index] = newUpload
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    				return
    			}
    			// push the obtained upload ID from the response into the array.
    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    	// Wait till all go routines finishes execution.
    	wg.Wait()
    	// Validate the upload ID by an attempt to list parts using it.
    	for _, uploadID := range testUploads.uploads {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. cmd/warm-backend-gcs.go

    		err = BucketNotFound{
    			Bucket: bucket,
    		}
    		return err
    	case "storage: object doesn't exist":
    		if uploadID != "" {
    			err = InvalidUploadID{
    				UploadID: uploadID,
    			}
    		} else {
    			err = ObjectNotFound{
    				Bucket: bucket,
    				Object: object,
    			}
    		}
    		return err
    	}
    
    	googleAPIErr, ok := err.(*googleapi.Error)
    	if !ok {
    		// We don't interpret non MinIO errors. As minio errors will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 10:51:23 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    	queryValues.Set("uploadId", uploadID)
    	queryValues.Set("partNumber", partNumber)
    	return makeTestTargetURL(endPoint, bucketName, objectName, queryValues)
    }
    
    // return URL for aborting multipart upload.
    func getAbortMultipartUploadURL(endPoint, bucketName, objectName, uploadID string) string {
    	queryValue := url.Values{}
    	queryValue.Set("uploadId", uploadID)
    	return makeTestTargetURL(endPoint, bucketName, objectName, queryValue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top