diff --git a/ste/mgr-JobPartTransferMgr.go b/ste/mgr-JobPartTransferMgr.go index b249d3d51..ba648054b 100644 --- a/ste/mgr-JobPartTransferMgr.go +++ b/ste/mgr-JobPartTransferMgr.go @@ -94,6 +94,7 @@ type IJobPartTransferMgr interface { GetS2SSourceBlobTokenCredential() azblob.TokenCredential PropertiesToTransfer() common.SetPropertiesFlags ResetSourceSize() // sets source size to 0 (made to be used by setProperties command to make number of bytes transferred = 0) + SuccessfulBytesTransferred() int64 } type TransferInfo struct { @@ -972,3 +973,7 @@ func (jptm *jobPartTransferMgr) ShouldInferContentType() bool { fromTo := jptm.FromTo() return fromTo.From() == common.ELocation.Local() } + +func (jptm *jobPartTransferMgr) SuccessfulBytesTransferred() int64 { + return atomic.LoadInt64(&jptm.atomicSuccessfulBytes) +} \ No newline at end of file