Make sure recvFunc is called before responding on the recvChan

zlfu9527 · Aug 10, 2013 · c4c0b85 · c4c0b85
1 parent baf3580
commit c4c0b85
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zk/conn.go b/zk/conn.go
@@ -518,10 +518,10 @@ func (c *Conn) recvLoop(conn net.Conn) error {
 				} else {
 					_, err = decodePacket(buf[16:16+blen], req.recvStruct)
 				}
-				req.recvChan <- response{res.Zxid, err}
 				if req.recvFunc != nil {
 					req.recvFunc(req, &res, err)
 				}
+				req.recvChan <- response{res.Zxid, err}
 				if req.opcode == opClose {
 					return io.EOF
 				}