diff --git a/fileTransfer/send.go b/fileTransfer/send.go index c266a35c8f5d8f9882b8b07a7b308566c4c6c69d..9a4aa9ff1939584e5c3019455fab08376dc25e6e 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 92439f7083cb65f60517879449535485b53b575b..7f76a7f0b6973e600c09184a50dddc21789f6f3d 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