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

Potential fix

parent 4e27d9fc
Branches
Tags v1.0.2
2 merge requests!510Release,!398Add debug log for file transfer not quitting
......@@ -86,11 +86,21 @@ func (m *manager) sendingThread(stop *stoppable.Single) {
case healthy := <-healthChan:
for !healthy {
jww.INFO.Printf("not healthy, waiting for health update")
healthy = <-healthChan
select {
// Wait for health update or a quit signal
case <-stop.Quit():
jww.DEBUG.Printf("[FT] Stopping file part sending thread (%s): "+
"stoppable triggered.", stop.Name())
m.cmix.RemoveHealthCallback(healthChanID)
stop.ToStopped()
return
case healthy = <-healthChan:
jww.INFO.Printf("received health update, it is now set to %s", healthy)
}
}
case packet := <-m.sendQueue:
jww.INFO.Printf("sending packet")
jww.INFO.Printf("sending pack")
m.sendCmix(packet)
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment