Use sync.Once to properly support concurrent calls to Close

Signed-off-by: Mathieu Champlon <[email protected]>

Author: mat007

pipe.go

@@ -11,6 +11,7 @@ import (
 	"net"
 	"os"
 	"runtime"
+	"sync"
 	"time"
 	"unsafe"
 
@@ -316,6 +317,7 @@ type win32PipeListener struct {
 	path        string
 	config      PipeConfig
 	acceptCh    chan (chan acceptResponse)
+	closeOnce   sync.Once
 	closeCh     chan struct{}
 	doneCh      chan struct{}
 }
@@ -573,14 +575,10 @@ func (l *win32PipeListener) Accept() (net.Conn, error) {
 }
 
 func (l *win32PipeListener) Close() error {
-	select {
-	case <-l.doneCh:
-	case <-l.closeCh:
-		<-l.doneCh
-	default:
+	l.closeOnce.Do(func() {
 		close(l.closeCh)
-		<-l.doneCh
-	}
+	})
+	<-l.doneCh
 	return nil
 }