Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for PutObjectPart (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/benchmark-utils_test.go

    		}
    	}
    	// Benchmark ends here. Stop timer.
    	b.StopTimer()
    }
    
    // Benchmark utility functions for ObjectLayer.PutObjectPart().
    // Creates Object layer setup ( MakeBucket ) and then runs the PutObjectPart benchmark.
    func runPutObjectPartBenchmark(b *testing.B, obj ObjectLayer, partSize int) {
    	var err error
    	// obtains random bucket name.
    	bucket := getRandomBucketName()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  2. cmd/erasure-multipart.go

    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    // them. This call is similar to single put operation but it is part
    // of the multipart transaction.
    //
    // Implements S3 compatible Upload Part API.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  3. cmd/object-api-input-checks.go

    	_, err := base64.RawURLEncoding.DecodeString(uploadID)
    	if err != nil {
    		return MalformedUploadID{
    			UploadID: uploadID,
    		}
    	}
    	return checkObjectArgs(ctx, bucket, object)
    }
    
    // Checks for PutObjectPart arguments validity, also validates if bucket exists.
    func checkPutObjectPartArgs(ctx context.Context, bucket, object, uploadID string) error {
    	return checkMultipartObjectArgs(ctx, bucket, object, uploadID)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  4. cmd/object-api-multipart_test.go

    				}
    			}
    		})
    	}
    }
    
    // Benchmarks for ObjectLayer.PutObjectPart().
    // The intent is to benchmark PutObjectPart for various sizes ranging from few bytes to 100MB.
    // Also each of these Benchmarks are run both Erasure and FS backends.
    
    // BenchmarkPutObjectPart5MbFS - Benchmark FS.PutObjectPart() for object size of 5MB.
    func BenchmarkPutObjectPart5MbFS(b *testing.B) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool.go

    		return PartInfo{}, err
    	}
    
    	return z.PutObjectPart(ctx, destBucket, destObject, uploadID, partID,
    		srcInfo.PutObjReader, dstOpts)
    }
    
    // PutObjectPart - writes part of an object to hashedSet based on the object name.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  6. cmd/erasure-sets.go

    	return set.NewMultipartUpload(ctx, bucket, object, opts)
    }
    
    // PutObjectPart - writes part of an object to hashedSet based on the object name.
    func (s *erasureSets) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data *PutObjReader, opts ObjectOptions) (info PartInfo, err error) {
    	set := s.getHashedSet(object)
    	return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  7. cmd/api-router.go

    			HeadersRegexp(xhttp.AmzCopySource, ".*?(\\/|%2F).*?").
    			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:.*}")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  8. cmd/erasure-object_test.go

    	md5Hex := getMD5Hash(fiveMBBytes)
    	_, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	// PutObjectPart should succeed even if part already exists. ref: https://github.com/minio/minio/issues/1930
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-decom.go

    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("decommissionObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, objInfo.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    				ObjectOptions{
    					PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata.
    					IndexCB: func() []byte {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  10. 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)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
Back to Top