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

Add more debugs

parent 1a7f0aa0
No related branches found
No related tags found
2 merge requests!510Release,!398Add debug log for file transfer not quitting
...@@ -63,6 +63,7 @@ func (m *manager) startSendingWorkerPool(multiStop *stoppable.Multi) { ...@@ -63,6 +63,7 @@ func (m *manager) startSendingWorkerPool(multiStop *stoppable.Multi) {
for i := 0; i < workerPoolThreads; i++ { for i := 0; i < workerPoolThreads; i++ {
stop := stoppable.NewSingle(sendThreadStoppableName + strconv.Itoa(i)) stop := stoppable.NewSingle(sendThreadStoppableName + strconv.Itoa(i))
go m.sendingThread(stop) go m.sendingThread(stop)
jww.INFO.Printf("Adding stoppable %s", stop.Name())
multiStop.Add(stop) multiStop.Add(stop)
} }
......
...@@ -121,8 +121,8 @@ func (m *Multi) Close() error { ...@@ -121,8 +121,8 @@ func (m *Multi) Close() error {
m.once.Do(func() { m.once.Do(func() {
var wg sync.WaitGroup var wg sync.WaitGroup
jww.TRACE.Printf("Sending on quit channel to multi stoppable %q.", jww.INFO.Printf("Sending on quit channel to multi stoppable %q with processes: %v.",
m.Name()) m.Name(), m.GetRunningProcesses())
m.mux.Lock() m.mux.Lock()
// Attempt to stop each stoppable in its own goroutine // Attempt to stop each stoppable in its own goroutine
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment