Idle connections fix

nickname76 · Aug 31, 2020 · ac3a740 · ac3a740
1 parent 8901390
commit ac3a740
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/protdial.go b/protdial.go
@@ -223,13 +223,15 @@ func pipeBothIOsAndClose(parentctx context.Context, a io.ReadWriteCloser, b io.R
 		wg.Done()
 		if err != nil {
 			onErrFn(fmt.Errorf("pipeBothIOsAndClose b<-a: %s", err))
+			cancel()
 		}
 	}()
 	go func() {
 		_, err := io.Copy(a, b)
 		wg.Done()
 		if err != nil {
 			onErrFn(fmt.Errorf("pipeBothIOsAndClose a<-b: %s", err))
+			cancel()
 		}
 	}()