File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
src/aws-cpp-sdk-transfer/source/transfer Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -376,6 +376,11 @@ namespace Aws
376376 AWS_LOGSTREAM_TRACE (CLASS_TAG, " Transfer handle ID [" << GetId () << " ] Restarting transfer." );
377377 m_cancel.store (false );
378378 m_lastPart.store (false );
379+
380+ // Clear checksum state for retry
381+ std::lock_guard<std::mutex> locker (m_getterSetterLock);
382+ m_checksum.clear ();
383+ m_checksumAlgorithm = Aws::S3::Model::ChecksumAlgorithm::NOT_SET;
379384 }
380385
381386 bool TransferHandle::ShouldContinue () const
Original file line number Diff line number Diff line change @@ -945,7 +945,6 @@ namespace Aws
945945 handle->SetContentType (getObjectOutcome.GetResult ().GetContentType ());
946946 handle->ChangePartToCompleted (partState, getObjectOutcome.GetResult ().GetETag ());
947947 getObjectOutcome.GetResult ().GetBody ().flush ();
948-
949948 handle->UpdateStatus (TransferStatus::COMPLETED);
950949 }
951950 else
@@ -1224,7 +1223,7 @@ namespace Aws
12241223 Aws::IOStream* bufferStream = partState->GetDownloadPartStream ();
12251224 assert (bufferStream);
12261225
1227- handle->AddChecksumForPart (bufferStream, partState);
1226+ if (m_transferConfig. validateChecksums ) { handle->AddChecksumForPart (bufferStream, partState); }
12281227 Aws::String errMsg{handle->WritePartToDownloadStream (bufferStream, partState->GetRangeBegin ())};
12291228 if (errMsg.empty ()) {
12301229 handle->ChangePartToCompleted (partState, outcome.GetResult ().GetETag ());
You can’t perform that action at this time.
0 commit comments