Skip to content
This repository was archived by the owner on Jul 21, 2021. It is now read-only.

Commit 9c1b6fe

Browse files
author
Xiao Liang
committed
NodeDataChanged event should not trigger other watches
1 parent 2cc03de commit 9c1b6fe

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

zk/conn.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -884,8 +884,10 @@ func (c *Conn) recvLoop(conn net.Conn) error {
884884
switch res.Type {
885885
case EventNodeCreated:
886886
wTypes = append(wTypes, watchTypeExist)
887-
case EventNodeDeleted, EventNodeDataChanged:
887+
case EventNodeDeleted:
888888
wTypes = append(wTypes, watchTypeExist, watchTypeData, watchTypeChild)
889+
case EventNodeDataChanged:
890+
wTypes = append(wTypes, watchTypeData)
889891
case EventNodeChildrenChanged:
890892
wTypes = append(wTypes, watchTypeChild)
891893
}

0 commit comments

Comments
 (0)