diff --git a/bindings/fileTransfer.go b/bindings/fileTransfer.go index 88cda1ebc444dc719860b6adb1b0ddee64f02dde..c9ae897f33e518e9de9c2c7cdd6046ae342bd516 100644 --- a/bindings/fileTransfer.go +++ b/bindings/fileTransfer.go @@ -9,6 +9,7 @@ package bindings import ( "encoding/json" + jww "github.com/spf13/jwalterweatherman" "time" "gitlab.com/elixxir/client/fileTransfer" @@ -127,7 +128,7 @@ type FileTransferReceiveProgressCallback interface { // - paramsJSON - JSON marshalled fileTransfer.Params func InitFileTransfer(e2eID int, receiveFileCallback ReceiveFileCallback, e2eFileTransferParamsJson, fileTransferParamsJson []byte) (*FileTransfer, error) { - + jww.INFO.Printf("Calling InitFileTransfer()") // Get user from singleton user, err := e2eTrackerSingleton.get(e2eID) if err != nil { @@ -165,6 +166,7 @@ func InitFileTransfer(e2eID int, receiveFileCallback ReceiveFileCallback, } // Add file transfer processes to API services tracking + jww.INFO.Printf("FT PROCESS IS STARTING HERE AT InitFileTransfer") err = user.api.AddService(m.StartProcesses) if err != nil { return nil, err diff --git a/fileTransfer/manager.go b/fileTransfer/manager.go index ba5ca3e254af289f1098083072a8079ff76b6d6e..c6058ed7e64cb86798158adfe97a9daba3743148 100644 --- a/fileTransfer/manager.go +++ b/fileTransfer/manager.go @@ -215,7 +215,7 @@ func NewManager(params Params, user FtE2e) (FileTransfer, error) { // StartProcesses starts the sending threads. Adheres to the xxdk.Service type. func (m *manager) StartProcesses() (stoppable.Stoppable, error) { // Construct stoppables - sendStoppable := stoppable.NewMulti(sendThreadStoppableName) + sendStoppable := stoppable.NewMulti(workerPoolStoppable) batchBuilderStop := stoppable.NewSingle(batchBuilderThreadStoppable) // Start sending threads