diff --git a/fileTransfer/manager.go b/fileTransfer/manager.go index e1a82dab762f9f156172c1445b45463d24f16207..4ac4c1ab75b820edfc7e390a3a14bc69f1fc6036 100644 --- a/fileTransfer/manager.go +++ b/fileTransfer/manager.go @@ -9,6 +9,7 @@ package fileTransfer import ( "github.com/pkg/errors" + jww "github.com/spf13/jwalterweatherman" "gitlab.com/elixxir/client/api" "gitlab.com/elixxir/client/interfaces" "gitlab.com/elixxir/client/interfaces/message" @@ -307,6 +308,10 @@ func (m Manager) Send(fileName, fileType string, fileData []byte, } rng.Close() + jww.DEBUG.Printf("[FT] Sending new file transfer %q to %s {parts: %d, "+ + "size: %d, type: %q, ID: %s}", + fileName, recipient, numParts, fileSize, fileType, transferID) + // Add all parts to queue m.queueParts(transferID, makeListOfPartNums(numParts)) @@ -372,6 +377,10 @@ func (m Manager) CloseSend(tid ftCrypto.TransferID) error { return errors.Errorf(transferInProgressErr, tid) } + jww.DEBUG.Printf("[FT] Closing file transfer %s sent to %s "+ + "{completed: %t, parts: %d}", + tid, transfer.GetRecipient(), completed, transfer.GetNumParts()) + // Delete the transfer from storage return m.sent.DeleteTransfer(tid) } diff --git a/fileTransfer/receiveNew.go b/fileTransfer/receiveNew.go index 2fa736cbbd2f7bd287095d4a8bfcd168f5d30707..47c873c807d3044801f6168e6bda4e4bcbcd83b5 100644 --- a/fileTransfer/receiveNew.go +++ b/fileTransfer/receiveNew.go @@ -82,6 +82,10 @@ func (m *Manager) readNewFileTransferMessage(msg message.Receive) ( return } + jww.DEBUG.Printf("[FT] Received new file transfer %q from %s {parts: %d, "+ + "size: %d, type: %q}", + newFT.FileName, msg.Sender, newFT.NumParts, newFT.Size, newFT.FileType) + // Get RNG from stream rng := m.rng.GetStream() defer rng.Close() diff --git a/fileTransfer/send.go b/fileTransfer/send.go index aad1d93cd79a0ae19383220b27eecdefc5a3c7da..3dfe633caca4fa886b2326a85ee997bae6a5a3a9 100644 --- a/fileTransfer/send.go +++ b/fileTransfer/send.go @@ -312,6 +312,11 @@ func (m *Manager) buildMessages(partList []queuedPart) ( // Generate new cMix message with encrypted file part cmixMsg, err := m.newCmixMessage(transfer, part.partNum, rng) if err == ftStorage.MaxRetriesErr { + jww.DEBUG.Printf("[FT] File transfer %s sent to %s ran out of "+ + "retries {parts: %d, fingerprints: %d}", + part.tid, transfer.GetRecipient(), transfer.GetNumParts(), + transfer.GetNumFps()) + // If the max number of retries has been reached, then report the // error on the callback, delete the transfer, and skip to the next // message