add mutex.Unlock()

withlin · Dec 28, 2018 · 38010bc · 38010bc
1 parent 3bb2622
commit 38010bc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/client/simple_canal_connector.go b/client/simple_canal_connector.go
@@ -421,6 +421,9 @@ func readHeaderLength() int {
 //readNextPacket 通过长度去读取数据包
 func readNextPacket() ([]byte,error) {
 	mutex.Lock()
+	defer func(){
+		mutex.Unlock()
+	}()
 	rdr := bufio.NewReader(conn)
 	data := make([]byte, 0, 4*1024)
 	n, err := io.ReadFull(rdr, data[:4])
@@ -437,7 +440,6 @@ func readNextPacket() ([]byte,error) {
 		return  nil,err
 	}
 	data = data[:n]
-	mutex.Unlock()
 	return data,nil
 }