Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for CompleteMultipartUpload (0.22 sec)

  1. cmd/object_api_suite_test.go

    		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++ {
    		expectedETaghex := getMD5Hash(data)
    
    		var calcPartInfo PartInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils.go

    			return err
    		}, index)
    	}
    
    	return metadataArray, g.Wait()
    }
    
    // shuffleDisksAndPartsMetadataByIndex this function should be always used by GetObjectNInfo()
    // and CompleteMultipartUpload code path, it is not meant to be used with PutObject,
    // NewMultipartUpload metadata shuffling.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    	var completeBytes []byte
    	// Complete multipart upload parts.
    	completeUploads := &CompleteMultipartUpload{
    		Parts: parts,
    	}
    	completeBytes, err = xml.Marshal(completeUploads)
    	if err != nil {
    		t.Fatalf("Error XML encoding of parts: <ERROR> %s.", err)
    	}
    	// Indicating that all parts are uploaded and initiating CompleteMultipartUpload.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    				ETag:       pi.ETag,
    				PartNumber: pi.PartNumber,
    			}
    		}
    		_, err = z.CompleteMultipartUpload(ctx, bucket, oi.Name, res.UploadID, parts, ObjectOptions{
    			DataMovement: true,
    			MTime:        oi.ModTime,
    			NoAuditLog:   true,
    		})
    		if err != nil {
    			err = fmt.Errorf("rebalanceObject: CompleteMultipartUpload() %w", err)
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    		return err
    	}
    	return InvalidUploadID{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    // CompleteMultipartUpload - completes a pending multipart transaction, on hashedSet based on object name.
    func (z *erasureServerPools) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    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/api-router.go

    		// ListObjectParts
    		router.Methods(http.MethodGet).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.ListObjectPartsHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// CompleteMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// NewMultipartUpload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-decom.go

    				ChecksumSHA1:   pi.ChecksumSHA1,
    			}
    		}
    		_, err = z.CompleteMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, parts, ObjectOptions{
    			SrcPoolIdx:   idx,
    			DataMovement: true,
    			MTime:        objInfo.ModTime,
    			NoAuditLog:   true,
    		})
    		if err != nil {
    			err = fmt.Errorf("decommissionObject: CompleteMultipartUpload() %w", err)
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  8. cmd/object-api-datatypes_gen.go

    	s = 1 + 5 + msgp.StringPrefixSize + len(z.Name) + 8 + msgp.TimeSize + 8 + msgp.TimeSize + 11 + msgp.BoolSize + 14 + msgp.BoolSize
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *CompleteMultipartUpload) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 1
    	// string "Parts"
    	o = append(o, 0x81, 0xa5, 0x50, 0x61, 0x72, 0x74, 0x73)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  9. cmd/object-api-putobject_test.go

    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Complete multipart.
    	parts := []CompletePart{
    		{ETag: etag1, PartNumber: 1},
    		{ETag: etag2, PartNumber: 2},
    	}
    	_, err = obj.CompleteMultipartUpload(context.Background(), bucket, object, uploadID, parts, ObjectOptions{})
    	if err != nil {
    		// Failed to complete multipart upload, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  10. cmd/bucket-handlers_test.go

    	// The only aim is to generate an HTTP request in a way that the relevant/registered end point is evoked/called.
    	// Indicating that all parts are uploaded and initiating completeMultipartUpload.
    	nilBucket := "dummy-bucket"
    	nilObject := ""
    
    	nilReq, err := newTestSignedRequestV4(http.MethodPost, getDeleteMultipleObjectsURL("", nilBucket), 0, nil, "", "", nil)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
Back to top