Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for uploadcdn (5.92 sec)

  1. cmd/erasure-multipart.go

    		break
    	}
    
    	for i := range uploadIDs {
    		uploadIDs[i] = strings.TrimSuffix(uploadIDs[i], SlashSeparator)
    	}
    
    	// S3 spec says uploadIDs should be sorted based on initiated time, we need
    	// to read the metadata entry.
    	var uploads []MultipartInfo
    
    	populatedUploadIDs := set.NewStringSet()
    
    	for _, uploadID := range uploadIDs {
    		if populatedUploadIDs.Contains(uploadID) {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  2. cmd/object-api-datatypes.go

    	UserDefined map[string]string
    
    	// ChecksumAlgorithm if set
    	ChecksumAlgorithm string
    }
    
    // Lookup - returns if uploadID is valid
    func (lm ListMultipartsInfo) Lookup(uploadID string) bool {
    	for _, upload := range lm.Uploads {
    		if upload.UploadID == uploadID {
    			return true
    		}
    	}
    	return false
    }
    
    // ListMultipartsInfo - represents bucket resources for incomplete multipart uploads.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  3. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  4. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatalf("Failed to create a multipart upload - %v", err)
    	}
    	uploadID := res.UploadID
    
    	var uploadedParts []CompletePart
    	for _, partID := range []int{2, 1} {
    		pInfo, err1 := set.PutObjectPart(ctx, bucket, object, uploadID, partID, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), opts)
    		if err1 != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  5. 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++ {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  6. cmd/api-router.go

    			HandlerFunc(s3APIMiddleware(api.CopyObjectPartHandler)).
    			Queries("partNumber", "{partNumber:.*}", "uploadId", "{uploadId:.*}")
    		// PutObjectPart
    		router.Methods(http.MethodPut).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.PutObjectPartHandler, traceHdrsS3HFlag)).
    			Queries("partNumber", "{partNumber:.*}", "uploadId", "{uploadId:.*}")
    		// ListObjectParts
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  7. cmd/api-response.go

    	}
    }
    
    // generates InitiateMultipartUploadResponse for given bucket, key and uploadID.
    func generateInitiateMultipartUploadResponse(bucket, key, uploadID string) InitiateMultipartUploadResponse {
    	return InitiateMultipartUploadResponse{
    		Bucket:   bucket,
    		Key:      key,
    		UploadID: uploadID,
    	}
    }
    
    // generates CompleteMultipartUploadResponse for given bucket, key, location and ETag.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  8. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  9. cmd/object-api-errors.go

    type MalformedUploadID struct {
    	UploadID string
    }
    
    func (e MalformedUploadID) Error() string {
    	return "Malformed upload id " + e.UploadID
    }
    
    // InvalidUploadID invalid upload id.
    type InvalidUploadID struct {
    	Bucket   string
    	Object   string
    	UploadID string
    }
    
    func (e InvalidUploadID) Error() string {
    	return "Invalid upload id " + e.UploadID
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    		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)
    	GetMultipartInfo(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (info MultipartInfo, err error)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
Back to top