소스 검색

Fix sasl connection reset

Alexey Edelev 5 년 전
부모
커밋
5e888a0a62
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      sasl/sasl.go

+ 2 - 2
sasl/sasl.go

@@ -106,6 +106,7 @@ func (s *SaslServer) Run() {
 
 func (s *SaslServer) handleRequest(conn net.Conn) {
 	conn.SetReadDeadline(time.Time{})
+	defer conn.Close()
 
 	connectionReader := bufio.NewReader(conn)
 	continueState := ContinueStateNone
@@ -158,7 +159,7 @@ func (s *SaslServer) handleRequest(conn net.Conn) {
 						fmt.Fprintf(conn, "%s\t%s\tuser=%s\n", Ok, ids[1], login)
 					}
 					continueState = ContinueStateNone
-					return
+					continue
 				}
 			}
 
@@ -187,7 +188,6 @@ func (s *SaslServer) handleRequest(conn net.Conn) {
 			}
 		}
 	}
-	conn.Close()
 }
 
 func (s *SaslServer) checkCredentials(credentialsBase64 string) (string, error) {