Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for uploadcdn (0.18 sec)

  1. cmd/server_test.go

    	err = decoder.Decode(newResponse)
    	c.Assert(err, nil)
    	c.Assert(len(newResponse.UploadID) > 0, true)
    	// uploadID to be used for rest of the multipart operations on the object.
    	uploadID := newResponse.UploadID
    
    	// content for the part to be uploaded.
    	buffer1 := bytes.NewReader([]byte("hello world"))
    	// HTTP request for the part to be uploaded.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  2. 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
    	}
    
    	if z.SinglePool() {
    		return z.serverPools[0].GetMultipartInfo(ctx, bucket, object, uploadID, opts)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/erasure-server-pool-rebalance.go

    			UserDefined: oi.UserDefined,
    			NoAuditLog:  true,
    		})
    		if err != nil {
    			return fmt.Errorf("rebalanceObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, oi.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    
    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		if err != nil {
    			return setRestoreHeaderFn(oi, err)
    		}
    		pInfo, err := er.PutObjectPart(ctx, bucket, object, res.UploadID, partInfo.Number, NewPutObjReader(hr), ObjectOptions{})
    		if err != nil {
    			return setRestoreHeaderFn(oi, err)
    		}
    		if pInfo.Size != partInfo.Size {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  8. cmd/api-errors.go

    		HTTPStatusCode: http.StatusMethodNotAllowed,
    	},
    	ErrInvalidPart: {
    		Code:           "InvalidPart",
    		Description:    "One or more of the specified parts could not be found.  The part may not have been uploaded, or the specified entity tag may not match the part's entity tag.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrMissingPart: {
    		Code:           "InvalidRequest",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  9. cmd/object-api-multipart_test.go

    				},
    				{
    					Object:   objectNames[0],
    					UploadID: uploadIDs[3],
    				},
    			},
    		},
    		// listMultipartResults - 17.
    		// Testing for listing of 3 uploadID's (uploadIDs[1-3]) for a given object with uploadID Marker set.
    		// uploadIDs[1] is set as UploadMarker, Expecting it to be skipped in the result.
    		// uploadIDs[2] and uploadIDs[3] are expected to be in the result.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  10. 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)
Back to top