centersl/docker-docs
1
0
Fork 0
mirror of https://github.com/docker/docs.git synced 2026-04-03 09:49:05 +07:00
Code Issues Packages Projects Releases Wiki Activity

fix zookeeper single Key watch

Browse Source 
Signed-off-by: Alexandre Beslic <abronan@docker.com>
This commit is contained in:
Alexandre Beslic
2015-06-03 13:10:44 -07:00
parent 83f97f73e8
commit 710da6479e
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/store/zookeeper.go
View File

@@ -121,7 +121,7 @@ func (s *Zookeeper) Exists(key string) (bool, error) {
// Providing a non-nil stopCh can be used to stop watching.
func (s *Zookeeper) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, error) {
fkey := normalize(key)
resp, meta, eventCh, err := s.client.GetW(fkey)
pair, err := s.Get(key)
if err != nil {
return nil, err
}
@@ -131,9 +131,13 @@ func (s *Zookeeper) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, e
go func() {
defer close(watchCh)
// GetW returns the current value before setting the watch.
watchCh <- &KVPair{key, resp, uint64(meta.Version)}
// Get returns the current value before setting the watch.
watchCh <- pair
for {
_, _, eventCh, err := s.client.GetW(fkey)
if err != nil {
return
}
select {
case e := <-eventCh:
if e.Type == zk.EventNodeDataChanged {