Kaynağa Gözat

Also detect 'connectior reset by peer' which is what a unix socket says

Evan Phoenix 10 yıl önce
ebeveyn
işleme
8e87fd5984
1 değiştirilmiş dosya ile 1 ekleme ve 1 silme
  1. 1 1
      session.go

+ 1 - 1
session.go

@@ -330,7 +330,7 @@ func (s *Session) recv() {
 	for {
 		// Read the header
 		if _, err := io.ReadFull(s.bufRead, hdr); err != nil {
-			if err != io.EOF && !strings.Contains(err.Error(), "closed") {
+			if err != io.EOF && !strings.Contains(err.Error(), "closed") && !strings.Contains(err.Error(), "reset by peer") {
 				s.logger.Printf("[ERR] yamux: Failed to read header: %v", err)
 			}
 			s.exitErr(err)