Skip to content
Snippets Groups Projects
Commit 8ddb19ef authored by Josh Brooks's avatar Josh Brooks
Browse files

Add debugs to FT bindings

parent 53ef1591
Branches
Tags
2 merge requests!510Release,!398Add debug log for file transfer not quitting
......@@ -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
......
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment