[Checkins] SVN: zc.zk/trunk/src/zc/zk/ Fixed: register_server broke when registering at /
Jim Fulton
jim at zope.com
Sat Dec 10 16:41:49 UTC 2011
Log message for revision 123662:
Fixed: register_server broke when registering at /
Changed:
U zc.zk/trunk/src/zc/zk/__init__.py
U zc.zk/trunk/src/zc/zk/tests.py
-=-
Modified: zc.zk/trunk/src/zc/zk/__init__.py
===================================================================
--- zc.zk/trunk/src/zc/zk/__init__.py 2011-12-10 16:41:45 UTC (rev 123661)
+++ zc.zk/trunk/src/zc/zk/__init__.py 2011-12-10 16:41:48 UTC (rev 123662)
@@ -178,7 +178,9 @@
addr = '%s:%s' % addr
path = self.resolve(path)
zc.zk.event.notify(RegisteringServer(addr, path, kw))
- self.create(path + '/' + addr, encode(kw), acl, zookeeper.EPHEMERAL)
+ if path != '/':
+ path += '/'
+ self.create(path + addr, encode(kw), acl, zookeeper.EPHEMERAL)
test_sleep = 0
def _async(self, completion, meth, *args):
Modified: zc.zk/trunk/src/zc/zk/tests.py
===================================================================
--- zc.zk/trunk/src/zc/zk/tests.py 2011-12-10 16:41:45 UTC (rev 123661)
+++ zc.zk/trunk/src/zc/zk/tests.py 2011-12-10 16:41:48 UTC (rev 123662)
@@ -1024,6 +1024,18 @@
"""
+def register_server_at_root():
+ """
+ >>> zk = zc.zk.ZooKeeper('zookeeper.example.com:2181')
+ >>> zk.register_server('/', 'a:b')
+ >>> zk.print_tree() # doctest: +ELLIPSIS
+ /a:b
+ pid = 2318
+ /fooservice
+ ...
+ >>> zk.close()
+ """
+
event = threading.Event()
def check_async(show=True, expected_status=0):
event.clear()
More information about the checkins
mailing list