Fix migration proxy goroutine leak
Due to a channel not being buffered, and not having a guaranteed
read occur, it's likely that one of the proxy copy goroutines
blocks indefinitely writing to a non buffered channel. THis is
fixed by making the channel buffered.
@@ -438,8 +438,8 @@ func (m *migrationProxy) Stop() {
func (m *migrationProxy) handleConnection(fd net.Conn) {
defer fd.Close()
- outBoundErr := make(chan error)
- inBoundErr := make(chan error)
+ outBoundErr := make(chan error, 1)
+ inBoundErr := make(chan error, 1)
var conn net.Conn
var err error
