diff options
| author | Joshua Harlow <harlowja@gmail.com> | 2015-03-10 17:44:29 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2015-03-10 17:44:29 -0700 |
| commit | 5eee5a7c0cb5a9c3f12d146b380cf826f377cb91 (patch) | |
| tree | 750592e4e9fa80168d48147564551f88e10d217b | |
| parent | f4c4fb6428478edd54e638a09fb70a58064aa907 (diff) | |
| parent | 4d57aa9741c6bca12fc18601799439b3989cffad (diff) | |
| download | zake-5eee5a7c0cb5a9c3f12d146b380cf826f377cb91.tar.gz | |
Merge pull request #14 from danfletcher4242/master
Changed attribute name "_child_watches" to "_child_watchers".
| -rw-r--r-- | zake/fake_client.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/zake/fake_client.py b/zake/fake_client.py index 5ae9cf2..0728112 100644 --- a/zake/fake_client.py +++ b/zake/fake_client.py @@ -69,7 +69,7 @@ class FakeClient(object): def __init__(self, handler=None, storage=None, server_version=None): self._listeners = set() - self._child_watches = collections.defaultdict(list) + self._child_watchers = collections.defaultdict(list) self._data_watchers = collections.defaultdict(list) if handler is None: self._handler = k_threading.SequentialThreadingHandler() @@ -157,7 +157,7 @@ class FakeClient(object): @property def child_watches(self): - return self._child_watches + return self._child_watchers @property def data_watches(self): @@ -249,7 +249,7 @@ class FakeClient(object): if not self._connected: self._connected = True with self._watches_lock: - self._child_watches.clear() + self._child_watchers.clear() self._data_watchers.clear() self.storage.attach(self) self.handler.start() @@ -314,7 +314,7 @@ class FakeClient(object): paths = self.storage.get_children(path) if watch: with self._watches_lock: - self._child_watches[path].append(watch) + self._child_watchers[path].append(watch) if include_data: children_with_data = [] for (child_path, data) in six.iteritems(paths): @@ -361,7 +361,7 @@ class FakeClient(object): def fire_child_watches(self, child_watches): for (paths, event) in child_watches: - self._fire_watches(paths, event, self._child_watches) + self._fire_watches(paths, event, self._child_watchers) def fire_data_watches(self, data_watches): for (paths, event) in data_watches: @@ -400,7 +400,7 @@ class FakeClient(object): if self._connected: self._connected = False with self._watches_lock: - self._child_watches.clear() + self._child_watchers.clear() self._data_watchers.clear() self.storage.purge(self) self._fire_state_change(k_states.KazooState.LOST) |