Close errnotifier chan on err

rht · rht · commit 6b267ab4a4ff · 2015-12-18T13:47:32.000+07:00
License: MIT
Signed-off-by: rht &lt;rhtbot@gmail.com&gt;
diff --git a/core/corehttp/logs.go b/core/corehttp/logs.go
@@ -27,6 +27,7 @@ func (w *writeErrNotifier) Write(b []byte) (int, error) {
 	if err != nil {
 		select {
 		case w.errs <- err:
+			close(w.errs)
 		default:
 		}
 	}
@@ -39,6 +40,7 @@ func (w *writeErrNotifier) Write(b []byte) (int, error) {
 func (w *writeErrNotifier) Close() error {
 	select {
 	case w.errs <- io.EOF:
+		close(w.errs)
 	default:
 	}
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ func (w *writeErrNotifier) Write(b []byte) (int, error) {`
`27`	`27`	`if err != nil {`
`28`	`28`	`select {`
`29`	`29`	`case w.errs <- err:`
	`30`	`+ close(w.errs)`
`30`	`31`	`default:`
`31`	`32`	`}`
`32`	`33`	`}`
`@@ -39,6 +40,7 @@ func (w *writeErrNotifier) Write(b []byte) (int, error) {`
`39`	`40`	`func (w *writeErrNotifier) Close() error {`
`40`	`41`	`select {`
`41`	`42`	`case w.errs <- io.EOF:`
	`43`	`+ close(w.errs)`
`42`	`44`	`default:`
`43`	`45`	`}`
`44`	`46`	`return nil`