From 82f742e31a8dba73282fc2eedba3feed530aa71a Mon Sep 17 00:00:00 2001 From: sheldonlyr Date: Tue, 7 Mar 2023 09:08:15 +0800 Subject: [PATCH] =?UTF-8?q?errCh=E4=BD=BF=E7=94=A8buffered=E6=A8=A1?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tcp/server.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/tcp/server.go b/tcp/server.go index b866548..24cdaa2 100644 --- a/tcp/server.go +++ b/tcp/server.go @@ -51,7 +51,7 @@ func ListenAndServeWithSignal(cfg *Config, handler tcp.Handler) error { // ListenAndServe binds port and handle requests, blocking until close func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan struct{}) { // listen signal - errCh := make(chan error) + errCh := make(chan error, 1) defer close(errCh) go func() { select { @@ -70,10 +70,7 @@ func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan for { conn, err := listener.Accept() if err != nil { - select { - case errCh <- err: - default: - } + errCh <- err break } // handle