Home
last modified time | relevance | path

Searched refs:putObjectRequest (Results 1 – 25 of 50) sorted by relevance

12

/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/presigner/model/
DPutObjectPresignRequest.java45 private final PutObjectRequest putObjectRequest; field in PutObjectPresignRequest
49 this.putObjectRequest = Validate.notNull(builder.putObjectRequest, "putObjectRequest"); in PutObjectPresignRequest()
64 public PutObjectRequest putObjectRequest() { in putObjectRequest() method in PutObjectPresignRequest
65 return putObjectRequest; in putObjectRequest()
87 return putObjectRequest.equals(that.putObjectRequest); in equals()
93 result = 31 * result + putObjectRequest.hashCode(); in hashCode()
107 Builder putObjectRequest(PutObjectRequest putObjectRequest); in putObjectRequest() argument
115 default Builder putObjectRequest(Consumer<PutObjectRequest.Builder> putObjectRequest) { in putObjectRequest() argument
117 putObjectRequest.accept(builder); in putObjectRequest()
118 return putObjectRequest(builder.build()); in putObjectRequest()
[all …]
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/model/
DUploadRequest.java47 private final PutObjectRequest putObjectRequest; field in UploadRequest
52 this.putObjectRequest = paramNotNull(builder.putObjectRequest, "putObjectRequest"); in UploadRequest()
60 public PutObjectRequest putObjectRequest() { in putObjectRequest() method in UploadRequest
61 return putObjectRequest; in putObjectRequest()
110 if (!Objects.equals(putObjectRequest, that.putObjectRequest)) { in equals()
121 int result = putObjectRequest != null ? putObjectRequest.hashCode() : 0; in hashCode()
130 .add("putObjectRequest", putObjectRequest) in toString()
160 Builder putObjectRequest(PutObjectRequest putObjectRequest); in putObjectRequest() method
173 … default Builder putObjectRequest(Consumer<PutObjectRequest.Builder> putObjectRequestBuilder) { in putObjectRequest() method
174 return putObjectRequest(PutObjectRequest.builder() in putObjectRequest()
[all …]
DUploadFileRequest.java48 private final PutObjectRequest putObjectRequest; field in UploadFileRequest
53 this.putObjectRequest = paramNotNull(builder.putObjectRequest, "putObjectRequest"); in UploadFileRequest()
61 public PutObjectRequest putObjectRequest() { in putObjectRequest() method in UploadFileRequest
62 return putObjectRequest; in putObjectRequest()
111 if (!Objects.equals(putObjectRequest, that.putObjectRequest)) { in equals()
122 int result = putObjectRequest != null ? putObjectRequest.hashCode() : 0; in hashCode()
131 .add("putObjectRequest", putObjectRequest) in toString()
174 Builder putObjectRequest(PutObjectRequest putObjectRequest); in putObjectRequest() argument
187 … default Builder putObjectRequest(Consumer<PutObjectRequest.Builder> putObjectRequestBuilder) { in putObjectRequest() method
188 return putObjectRequest(PutObjectRequest.builder() in putObjectRequest()
[all …]
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/
DCrtS3TransferManager.java74 …PutObjectRequest putObjectRequest = attachSdkAttribute(uploadFileRequest.putObjectRequest(), attac… in uploadFile() local
82 assertNotUnsupportedArn(putObjectRequest.bucket(), "upload"); in uploadFile()
85 s3AsyncClient.putObject(putObjectRequest, uploadFileRequest.source()); in uploadFile()
105 PutObjectRequest putObjectRequest = uploadFileRequest.putObjectRequest(); in uploadFromBeginning() local
114 putObjectRequest.bucket(), in uploadFromBeginning()
115 putObjectRequest.key())); in uploadFromBeginning()
121 … .bucket(putObjectRequest.bucket()) in uploadFromBeginning()
122 … .key(putObjectRequest.key()) in uploadFromBeginning()
143 putObjectRequest.bucket(), in uploadFromBeginning()
144 putObjectRequest.key())); in uploadFromBeginning()
[all …]
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/
DUploadObjectHelperTest.java113 PutObjectRequest putObjectRequest = putObjectRequest(contentLength); in uploadObject_contentLengthDoesNotExceedThresholdAndPartSize_shouldUploadInOneChunk() local
118 … when(s3AsyncClient.putObject(putObjectRequest, asyncRequestBody)).thenReturn(completedFuture); in uploadObject_contentLengthDoesNotExceedThresholdAndPartSize_shouldUploadInOneChunk()
119 uploadHelper.uploadObject(putObjectRequest, asyncRequestBody).join(); in uploadObject_contentLengthDoesNotExceedThresholdAndPartSize_shouldUploadInOneChunk()
120 Mockito.verify(s3AsyncClient).putObject(putObjectRequest, asyncRequestBody); in uploadObject_contentLengthDoesNotExceedThresholdAndPartSize_shouldUploadInOneChunk()
126 PutObjectRequest putObjectRequest = putObjectRequest(contentLength); in uploadObject_unKnownContentLengthDoesNotExceedPartSize_shouldUploadInOneChunk() local
133 … when(s3AsyncClient.putObject(putObjectRequest, asyncRequestBody)).thenReturn(completedFuture); in uploadObject_unKnownContentLengthDoesNotExceedPartSize_shouldUploadInOneChunk()
134 uploadHelper.uploadObject(putObjectRequest, asyncRequestBody).join(); in uploadObject_unKnownContentLengthDoesNotExceedPartSize_shouldUploadInOneChunk()
135 Mockito.verify(s3AsyncClient).putObject(putObjectRequest, asyncRequestBody); in uploadObject_unKnownContentLengthDoesNotExceedPartSize_shouldUploadInOneChunk()
141 PutObjectRequest putObjectRequest = putObjectRequest(null); in uploadObject_contentLengthExceedThresholdAndPartSize_shouldUseMPU() local
147 uploadHelper.uploadObject(putObjectRequest, asyncRequestBody).join(); in uploadObject_contentLengthExceedThresholdAndPartSize_shouldUseMPU()
[all …]
DMultipartClientChecksumTest.java69 PutObjectRequest putObjectRequest = putObjectRequestBuilder().build(); in putObject_default_shouldAddCrc32() local
71 s3Client.putObject(putObjectRequest, AsyncRequestBody.fromString("hello world")); in putObject_default_shouldAddCrc32()
82 PutObjectRequest putObjectRequest = in putObject_withNonCrc32ChecksumType_shouldNotAddCrc32() local
87 s3Client.putObject(putObjectRequest, AsyncRequestBody.fromString("hello world")); in putObject_withNonCrc32ChecksumType_shouldNotAddCrc32()
98 PutObjectRequest putObjectRequest = in putObject_withNonCrc32ChecksumValue_shouldNotAddCrc32() local
103 s3Client.putObject(putObjectRequest, AsyncRequestBody.fromString("hello world")); in putObject_withNonCrc32ChecksumValue_shouldNotAddCrc32()
115 PutObjectRequest putObjectRequest = in putObject_withCrc32Value_shouldNotAddCrc32TypeHeader() local
120 s3Client.putObject(putObjectRequest, AsyncRequestBody.fromString("hello world")); in putObject_withCrc32Value_shouldNotAddCrc32TypeHeader()
/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/
DMultipartS3AsyncClient.java71 …public CompletableFuture<PutObjectResponse> putObject(PutObjectRequest putObjectRequest, AsyncRequ… in putObject() argument
72 if (shouldEnableCrc32(putObjectRequest)) { in putObject()
73 …putObjectRequest = putObjectRequest.toBuilder().checksumAlgorithm(ChecksumAlgorithm.CRC32).build(); in putObject()
76 return mpuHelper.uploadObject(putObjectRequest, requestBody); in putObject()
79 private boolean shouldEnableCrc32(PutObjectRequest putObjectRequest) { in shouldEnableCrc32() argument
80 … return !checksumSetOnRequest(putObjectRequest) && checksumEnabledPerConfig(putObjectRequest); in shouldEnableCrc32()
83 private boolean checksumSetOnRequest(PutObjectRequest putObjectRequest) { in checksumSetOnRequest() argument
84 if (putObjectRequest.checksumAlgorithm() != null) { in checksumSetOnRequest()
89 .anyMatch(s -> putObjectRequest.getValueForField(s, String.class).isPresent()); in checksumSetOnRequest()
92 private boolean checksumEnabledPerConfig(PutObjectRequest putObjectRequest) { in checksumEnabledPerConfig() argument
[all …]
DUploadWithUnknownContentLengthHelper.java72 public CompletableFuture<PutObjectResponse> uploadObject(PutObjectRequest putObjectRequest, in uploadObject() argument
81 … putObjectRequest, in uploadObject()
117 private final PutObjectRequest putObjectRequest; field in UploadWithUnknownContentLengthHelper.UnknownContentLengthAsyncRequestBodySubscriber
126 PutObjectRequest putObjectRequest, in UnknownContentLengthAsyncRequestBodySubscriber() argument
129 this.putObjectRequest = putObjectRequest; in UnknownContentLengthAsyncRequestBodySubscriber()
168 multipartUploadHelper.createMultipartUpload(putObjectRequest, returnFuture); in onNext()
200 … multipartUploadHelper.failRequestsElegantly(futures, t, uploadId, returnFuture, putObjectRequest); in sendUploadPartRequest()
213 SdkPojoConversionUtils.toUploadPartRequest(putObjectRequest, in uploadPart()
223 … multipartUploadHelper.failRequestsElegantly(futures, t, uploadId, returnFuture, putObjectRequest); in onError()
233 … multipartUploadHelper.uploadInOneChunk(putObjectRequest, firstRequestBody, returnFuture); in onComplete()
[all …]
DUploadWithKnownContentLengthHelper.java70 public CompletableFuture<PutObjectResponse> uploadObject(PutObjectRequest putObjectRequest, in uploadObject() argument
78 uploadInParts(putObjectRequest, contentLength, asyncRequestBody, returnFuture); in uploadObject()
81 … multipartUploadHelper.uploadInOneChunk(putObjectRequest, asyncRequestBody, returnFuture); in uploadObject()
91 …private void uploadInParts(PutObjectRequest putObjectRequest, long contentLength, AsyncRequestBody… in uploadInParts() argument
95 multipartUploadHelper.createMultipartUpload(putObjectRequest, returnFuture); in uploadInParts()
102 … doUploadInParts(Pair.of(putObjectRequest, asyncRequestBody), contentLength, returnFuture, in uploadInParts()
170 private final PutObjectRequest putObjectRequest; field in UploadWithKnownContentLengthHelper.KnownContentLengthAsyncRequestBodySubscriber
181 this.putObjectRequest = mpuRequestContext.request.left(); in KnownContentLengthAsyncRequestBodySubscriber()
200 … multipartUploadHelper.failRequestsElegantly(futures, t, uploadId, returnFuture, putObjectRequest); in onSubscribe()
211 SdkPojoConversionUtils.toUploadPartRequest(putObjectRequest, in onNext()
[all …]
DMultipartUploadHelper.java66 …tableFuture<CreateMultipartUploadResponse> createMultipartUpload(PutObjectRequest putObjectRequest, in createMultipartUpload() argument
68 …artUploadRequest request = SdkPojoConversionUtils.toCreateMultipartUploadRequest(putObjectRequest); in createMultipartUpload()
80 PutObjectRequest putObjectRequest) { in completeMultipartUpload() argument
81 genericMultipartHelper.completeMultipartUpload(putObjectRequest, in completeMultipartUpload()
84 … .handle(genericMultipartHelper.handleExceptionOrResponse(putObjectRequest, returnFuture, in completeMultipartUpload()
117 PutObjectRequest putObjectRequest) { in failRequestsElegantly() argument
120 … genericMultipartHelper.cleanUpParts(uploadId, toAbortMultipartUploadRequest(putObjectRequest)); in failRequestsElegantly()
139 void uploadInOneChunk(PutObjectRequest putObjectRequest, in uploadInOneChunk() argument
142 …e<PutObjectResponse> putObjectResponseCompletableFuture = s3AsyncClient.putObject(putObjectRequest, in uploadInOneChunk()
DUploadObjectHelper.java61 public CompletableFuture<PutObjectResponse> uploadObject(PutObjectRequest putObjectRequest, in uploadObject() argument
63 … Long contentLength = asyncRequestBody.contentLength().orElseGet(putObjectRequest::contentLength); in uploadObject()
66 return uploadWithUnknownContentLength.uploadObject(putObjectRequest, asyncRequestBody); in uploadObject()
68 …return uploadWithKnownContentLength.uploadObject(putObjectRequest, asyncRequestBody, contentLength… in uploadObject()
DSdkPojoConversionUtils.java57 …public static UploadPartRequest toUploadPartRequest(PutObjectRequest putObjectRequest, int partNum… in toUploadPartRequest() argument
60 setSdkFields(builder, putObjectRequest, PUT_OBJECT_REQUEST_TO_UPLOAD_PART_FIELDS_TO_IGNORE); in toUploadPartRequest()
64 …ic CreateMultipartUploadRequest toCreateMultipartUploadRequest(PutObjectRequest putObjectRequest) { in toCreateMultipartUploadRequest() argument
67 setSdkFields(builder, putObjectRequest); in toCreateMultipartUploadRequest()
71 … CompleteMultipartUploadRequest toCompleteMultipartUploadRequest(PutObjectRequest putObjectRequest, in toCompleteMultipartUploadRequest() argument
74 setSdkFields(builder, putObjectRequest); in toCompleteMultipartUploadRequest()
162 …rtMultipartUploadRequest.Builder toAbortMultipartUploadRequest(PutObjectRequest putObjectRequest) { in toAbortMultipartUploadRequest() argument
164 setSdkFields(builder, putObjectRequest); in toAbortMultipartUploadRequest()
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/handlers/
DPutObjectHeaderTest.java56 private PutObjectRequest putObjectRequest; field in PutObjectHeaderTest
65 putObjectRequest = PutObjectRequest.builder().bucket("test").key("test").build(); in setup()
85 s3Client.putObject(putObjectRequest, RequestBody.fromFile(file)); in putObjectFile_headerShouldContainContentType()
94 s3Client.putObject(putObjectRequest, RequestBody.fromFile(file)); in putObject_gzipFile_hasProperContentType()
105 s3Client.putObject(putObjectRequest.toBuilder().contentType(contentType).build(), in putObject_gzipFile_shouldNotOverrideContentTypeInRequest()
115 s3Client.putObject(putObjectRequest, RequestBody.fromFile(file)); in putObjectUnknownFileExtension_contentTypeDefaultToBeStream()
124 putObjectRequest = putObjectRequest.toBuilder().contentType(contentType).build(); in putObjectWithContentTypeHeader_shouldNotOverrideContentTypeInRequest()
125 s3Client.putObject(putObjectRequest, RequestBody.fromString("test")); in putObjectWithContentTypeHeader_shouldNotOverrideContentTypeInRequest()
135 …putObjectRequest = (PutObjectRequest) putObjectRequest.toBuilder().overrideConfiguration(b -> b.pu… in putObjectWithContentTypeHeader_shouldNotOverrideContentTypeInRawConfig()
136 s3Client.putObject(putObjectRequest, RequestBody.fromString("test")); in putObjectWithContentTypeHeader_shouldNotOverrideContentTypeInRawConfig()
DAsyncChecksumValidationInterceptorTest.java143 PutObjectRequest putObjectRequest = PutObjectRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum() local
152 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_shouldValidateChecksum()
165 PutObjectRequest putObjectRequest = PutObjectRequest.builder().build(); in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid() local
174 .request(putObjectRequest) in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid()
195 PutObjectRequest putObjectRequest = PutObjectRequest.builder().build(); in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum() local
205 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum()
DSyncChecksumValidationInterceptorTest.java175 PutObjectRequest putObjectRequest = PutObjectRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum() local
184 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_shouldValidateChecksum()
197 PutObjectRequest putObjectRequest = PutObjectRequest.builder().build(); in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid() local
207 .request(putObjectRequest) in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid()
228 PutObjectRequest putObjectRequest = PutObjectRequest.builder().build(); in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum() local
238 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum()
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/
DS3TransferManagerUploadPauseAndResumeTest.java80 PutObjectRequest putObjectRequest = putObjectRequest(); in resumeUploadFile_noResumeToken_shouldUploadFromBeginning() local
86 .putObjectRequest(putObjectRequest) in resumeUploadFile_noResumeToken_shouldUploadFromBeginning()
105 PutObjectRequest putObjectRequest = putObjectRequest(); in resumeUploadFile_fileModified_shouldAbortExistingAndUploadFromBeginning() local
111 .putObjectRequest(putObjectRequest) in resumeUploadFile_fileModified_shouldAbortExistingAndUploadFromBeginning()
144 PutObjectRequest putObjectRequest = putObjectRequest(); in resumeUploadFile_hasValidResumeToken_shouldResumeUpload() local
150 .putObjectRequest(putObjectRequest) in resumeUploadFile_hasValidResumeToken_shouldResumeUpload()
199 private static PutObjectRequest putObjectRequest() { in putObjectRequest() method in S3TransferManagerUploadPauseAndResumeTest
DUploadDirectoryHelperTest.java221 … .putObjectRequest(newPutObjectRequest) in uploadDirectory_withRequestTransformer_usesRequestTransformer()
236 assertThat(r.putObjectRequest()).isEqualTo(newPutObjectRequest); in uploadDirectory_withRequestTransformer_usesRequestTransformer()
241 assertThat(r.putObjectRequest()).isEqualTo(newPutObjectRequest); in uploadDirectory_withRequestTransformer_usesRequestTransformer()
263 actualRequests.forEach(r -> assertThat(r.putObjectRequest().bucket()).isEqualTo("bucket")); in uploadDirectory_defaultSetting_shouldRecursivelyUpload()
268 actualRequests.stream().map(u -> u.putObjectRequest().key()) in uploadDirectory_defaultSetting_shouldRecursivelyUpload()
290 actualRequests.stream().map(u -> u.putObjectRequest().key()) in uploadDirectory_depth1FollowSymlinkTrue_shouldOnlyUploadTopLevel()
311 actualRequests.forEach(r -> assertThat(r.putObjectRequest().bucket()).isEqualTo("bucket")); in uploadDirectory_FollowSymlinkTrue_shouldIncludeLinkedFiles()
314 actualRequests.stream().map(u -> u.putObjectRequest().key()) in uploadDirectory_FollowSymlinkTrue_shouldIncludeLinkedFiles()
337 requestArgumentCaptor.getAllValues().stream().map(u -> u.putObjectRequest().key()) in uploadDirectory_withPrefix_keysShouldHavePrefix()
361 requestArgumentCaptor.getAllValues().stream().map(u -> u.putObjectRequest().key()) in uploadDirectory_withDelimiter_shouldHonor()
[all …]
DS3TransferManagerTest.java87 …CompletedFileUpload completedFileUpload = tm.uploadFile(u -> u.putObjectRequest(p -> p.bucket("buc… in uploadFile_returnsResponse()
102 CompletedUpload completedUpload = tm.upload(u -> u.putObjectRequest(p -> p.bucket("bucket") in upload_returnsResponse()
133 …CompletableFuture<CompletedFileUpload> future = tm.uploadFile(u -> u.putObjectRequest(p -> p.bucke… in uploadFile_cancel_shouldForwardCancellation()
148 …CompletableFuture<CompletedUpload> future = tm.upload(u -> u.putObjectRequest(p -> p.bucket("bucke… in upload_cancel_shouldForwardCancellation()
224 …assertThatThrownBy(() -> tm.uploadFile(b -> b.putObjectRequest(p -> p.bucket(objectLambdaArn).key(… in objectLambdaArnBucketProvided_shouldThrowException()
229 …assertThatThrownBy(() -> tm.upload(b -> b.putObjectRequest(p -> p.bucket(objectLambdaArn).key("key… in objectLambdaArnBucketProvided_shouldThrowException()
274 … assertThatThrownBy(() -> tm.uploadFile(b -> b.putObjectRequest(p -> p.bucket(mrapArn).key("key")) in mrapArnProvided_shouldThrowException()
279 … assertThatThrownBy(() -> tm.upload(b -> b.putObjectRequest(p -> p.bucket(mrapArn).key("key")) in mrapArnProvided_shouldThrowException()
/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/handlers/
DObjectMetadataInterceptor.java50 private PutObjectRequest trimMetadataNames(PutObjectRequest putObjectRequest) { in trimMetadataNames() argument
51 if (!putObjectRequest.hasMetadata()) { in trimMetadataNames()
52 return putObjectRequest; in trimMetadataNames()
55 return putObjectRequest.toBuilder() in trimMetadataNames()
56 .metadata(trimKeys(putObjectRequest.metadata())) in trimMetadataNames()
/external/aws-sdk-java-v2/services/mediastoredata/src/it/java/software/amazon/awssdk/services/mediastoredata/
DTransferEncodingChunkedIntegrationTest.java39 private static PutObjectRequest putObjectRequest; field in TransferEncodingChunkedIntegrationTest
65 putObjectRequest = PutObjectRequest.builder() in setup()
83 …syncClientWithApache.putObject(putObjectRequest, RequestBody.fromContentProvider(provider, "binary… in apacheClientPutObject_withoutContentLength_sendsSuccessfully()
90 …syncClientWithUrlConnection.putObject(putObjectRequest, RequestBody.fromContentProvider(provider, … in urlConnectionClientPutObject_withoutContentLength_sendsSuccessfully()
96 …asyncClientWithNetty.putObject(putObjectRequest, customAsyncRequestBodyWithoutContentLength("TestB… in nettyClientPutObject_withoutContentLength_sendsSuccessfully()
DRequestCompressionStreamingIntegrationTest.java54 private static PutObjectRequest putObjectRequest; field in RequestCompressionStreamingIntegrationTest
93 putObjectRequest = PutObjectRequest.builder() in setup()
121 …syncClient.putObject(putObjectRequest, RequestBody.fromContentProvider(provider, "binary/octet-str… in putObject_withSyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()
136 asyncClient.putObject(putObjectRequest, asyncRequestBody).join(); in putObject_withAsyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/serialization/
DResumableFileUploadSerializer.java105 marshallPutObjectRequest(fileRequest.putObjectRequest(), jsonGenerator); in marshallUploadFileRequest()
109 …private static void marshallPutObjectRequest(PutObjectRequest putObjectRequest, JsonWriter jsonGen… in marshallPutObjectRequest() argument
112 validateNoRequestOverrideConfiguration(putObjectRequest); in marshallPutObjectRequest()
113 …putObjectRequest.sdkFields().forEach(field -> marshallPojoField(field, putObjectRequest, jsonGener… in marshallPutObjectRequest()
117 private static void validateNoRequestOverrideConfiguration(PutObjectRequest putObjectRequest) { in validateNoRequestOverrideConfiguration() argument
118 if (putObjectRequest.overrideConfiguration().isPresent()) { in validateNoRequestOverrideConfiguration()
196 fileRequestBuilder.putObjectRequest(putObjectBuilder.build()); in parseUploadFileRequest()
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/model/
DUploadRequestTest.java40 .putObjectRequest(PutObjectRequest.builder().build()) in bodyMissing_shouldThrow()
49 .putObjectRequest(b -> b.bucket("bucket").key("key")) in bodyEqualsGivenBody()
59 .putObjectRequest(b -> b.bucket("bucket").key("key")) in null_requestBody_shouldThrowException()
DUploadFileRequestTest.java41 … .putObjectRequest(PutObjectRequest.builder().build()) in pathMissing_shouldThrow()
50 … .putObjectRequest(b -> b.bucket("bucket").key("key")) in sourceUsingFile()
60 … .putObjectRequest(b -> b.bucket("bucket").key("key")) in sourceUsingFile_null_shouldThrowException()
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/serialization/
DResumableFileUploadSerializerTest.java85 … .putObjectRequest(PUT_OBJECT_REQUESTS.get("ALL_TYPES"))) in serializeDeserialize_fromStoredString_ShouldWork()
106 … .putObjectRequest(PUT_OBJECT_REQUESTS.get("STANDARD")) in serializeDeserialize_DoesNotPersistConfiguration()
131 … .putObjectRequest(requestWithOverride) in serializeDeserialize_DoesNotPersistRequestOverrideConfiguration()
145 …UploadFileRequest fileRequestCopy = uploadFileRequest.copy(r -> r.putObjectRequest(requestWithoutO… in serializeDeserialize_DoesNotPersistRequestOverrideConfiguration()
190 .putObjectRequest(request) in downloadRequest()

12