From 6e88a678263c6b30e5f4b2edb9cef52c34564b96 Mon Sep 17 00:00:00 2001
From: joshemb <josh@elixxir.io>
Date: Tue, 27 Sep 2022 15:08:46 -0700
Subject: [PATCH] Add more debugs
---
fileTransfer/send.go | 1 +
stoppable/multi.go | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/fileTransfer/send.go b/fileTransfer/send.go
index c266a35c8..9a4aa9ff1 100644
--- a/fileTransfer/send.go
+++ b/fileTransfer/send.go
@@ -63,6 +63,7 @@ func (m *manager) startSendingWorkerPool(multiStop *stoppable.Multi) {
for i := 0; i < workerPoolThreads; i++ {
stop := stoppable.NewSingle(sendThreadStoppableName + strconv.Itoa(i))
go m.sendingThread(stop)
+ jww.INFO.Printf("Adding stoppable %s", stop.Name())
multiStop.Add(stop)
}
diff --git a/stoppable/multi.go b/stoppable/multi.go
index 92439f708..7f76a7f0b 100644
--- a/stoppable/multi.go
+++ b/stoppable/multi.go
@@ -121,8 +121,8 @@ func (m *Multi) Close() error {
m.once.Do(func() {
var wg sync.WaitGroup
- jww.TRACE.Printf("Sending on quit channel to multi stoppable %q.",
- m.Name())
+ jww.INFO.Printf("Sending on quit channel to multi stoppable %q with processes: %v.",
+ m.Name(), m.GetRunningProcesses())
m.mux.Lock()
// Attempt to stop each stoppable in its own goroutine
--
GitLab