From 9c1b6fe0694099d221daf9bc367fa60a8ab8eef5 Mon Sep 17 00:00:00 2001 From: Xiao Liang Date: Wed, 18 Mar 2020 15:56:59 +0800 Subject: [PATCH] NodeDataChanged event should not trigger other watches --- zk/conn.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/zk/conn.go b/zk/conn.go index da9503a2..412e1407 100644 --- a/zk/conn.go +++ b/zk/conn.go @@ -884,8 +884,10 @@ func (c *Conn) recvLoop(conn net.Conn) error { switch res.Type { case EventNodeCreated: wTypes = append(wTypes, watchTypeExist) - case EventNodeDeleted, EventNodeDataChanged: + case EventNodeDeleted: wTypes = append(wTypes, watchTypeExist, watchTypeData, watchTypeChild) + case EventNodeDataChanged: + wTypes = append(wTypes, watchTypeData) case EventNodeChildrenChanged: wTypes = append(wTypes, watchTypeChild) }