From 8ddb19eff7f23332ea5bfbe45a0040cd4056c159 Mon Sep 17 00:00:00 2001
From: joshemb <josh@elixxir.io>
Date: Wed, 28 Sep 2022 15:04:26 -0700
Subject: [PATCH] Add debugs to FT bindings
---
bindings/fileTransfer.go | 4 +++-
fileTransfer/manager.go | 2 +-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/bindings/fileTransfer.go b/bindings/fileTransfer.go
index 88cda1ebc..c9ae897f3 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 ba5ca3e25..c6058ed7e 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
--
GitLab