diff --git a/storage/fileTransfer/receiveTransfer.go b/storage/fileTransfer/receiveTransfer.go index 1f5d0756c33fe1fe66931ed7789886a865ca2c23..df4bad66163245c9593bfbbc949d73ccf04b5bc3 100644 --- a/storage/fileTransfer/receiveTransfer.go +++ b/storage/fileTransfer/receiveTransfer.go @@ -244,7 +244,7 @@ func (rt *ReceivedTransfer) stopScheduledProgressCB() error { err := cb.stopThread() if err != nil { failedCallbacks = append(failedCallbacks, i) - jww.WARN.Print(err.Error()) + jww.WARN.Printf("[FT] %s", err) } } diff --git a/storage/fileTransfer/sentFileTransfers.go b/storage/fileTransfer/sentFileTransfers.go index b68c265b18ee9735b35d330e7342b5cdffef2c9b..485eb67d062eca8ccb75f9b53bda262d64996eb3 100644 --- a/storage/fileTransfer/sentFileTransfers.go +++ b/storage/fileTransfer/sentFileTransfers.go @@ -36,7 +36,7 @@ const ( newSentTransferErr = "failed to create new sent transfer: %+v" getSentTransferErr = "sent file transfer not found" - cancelCallbackErr = "Transfer with ID %s: %+v" + cancelCallbackErr = "[FT] Transfer with ID %s: %+v" deleteSentTransferErr = "failed to delete sent transfer with ID %s from store: %+v" ) diff --git a/storage/fileTransfer/sentPartTracker.go b/storage/fileTransfer/sentPartTracker.go index b65a6aa115ab9d046086cb8e3fdfe68804665e0b..b5d30cf6e8960e404f8171b6ba00ed0fa508d8e6 100644 --- a/storage/fileTransfer/sentPartTracker.go +++ b/storage/fileTransfer/sentPartTracker.go @@ -13,6 +13,12 @@ import ( "gitlab.com/elixxir/client/storage/utility" ) +// Error messages. +const ( + // sentPartTracker.GetPartStatus + getInvalidPartErr = "[FT] Failed to get status for part %d: %+v" +) + // sentPartTracker tracks the status of individual sent file parts. type sentPartTracker struct { // The number of file parts in the file @@ -39,7 +45,7 @@ func newSentPartTracker(partStats *utility.MultiStateVector) sentPartTracker { func (spt sentPartTracker) GetPartStatus(partNum uint16) interfaces.FpStatus { status, err := spt.partStats.Get(partNum) if err != nil { - jww.FATAL.Fatalf("failed to get status for part %d: %+v", partNum, err) + jww.FATAL.Fatalf(getInvalidPartErr, partNum, err) } return interfaces.FpStatus(status) } diff --git a/storage/fileTransfer/sentTransfer.go b/storage/fileTransfer/sentTransfer.go index 351c50a78b607af43edde1b95c0470c4f5ba4f3e..a91a59847fee21466f0bff6a80a49ad01b67c82d 100644 --- a/storage/fileTransfer/sentTransfer.go +++ b/storage/fileTransfer/sentTransfer.go @@ -388,7 +388,7 @@ func (st *SentTransfer) stopScheduledProgressCB() error { err := cb.stopThread() if err != nil { failedCallbacks = append(failedCallbacks, i) - jww.WARN.Print(err.Error()) + jww.WARN.Printf("[FT] %s", err) } }