Merge pull request #319 from aceld/feature/aceld

fix close channel Write goroutins
aceld · Apr 25, 2024 · eb55d5f · eb55d5f
2 parents a7a32fd + fd3a0a3
commit eb55d5f
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/znet/connection.go b/znet/connection.go
@@ -389,13 +389,10 @@ func (c *Connection) SendToQueue(data []byte) error {
 	select {
 	case <-c.ctx.Done():
 		return errors.New("connection closed when send buff msg")
-	default:
-		select {
-		case <-idleTimeout.C:
-			return errors.New("send buff msg timeout")
-		case c.msgBuffChan <- data:
-			return nil
-		}
+	case <-idleTimeout.C:
+		return errors.New("send buff msg timeout")
+	case c.msgBuffChan <- data:
+		return nil
 	}
 }