Commit f518c990 authored by Jeremy Hylton's avatar Jeremy Hylton

Untested update to make this code work with ZEO 2 by default.

parent 426ba922
...@@ -15,8 +15,11 @@ Options: ...@@ -15,8 +15,11 @@ Options:
-d days -- pack objects more than days old -d days -- pack objects more than days old
-1 -- Connect to a ZEO 1 server
-W -- wait for server to come up. Normally the script tries to -W -- wait for server to come up. Normally the script tries to
connect for 10 seconds, then exits with an error. connect for 10 seconds, then exits with an error. The -W
option is only supported with ZEO 1.
You must specify either -p and -h or -U. You must specify either -p and -h or -U.
""" """
...@@ -43,7 +46,7 @@ def connect(storage): ...@@ -43,7 +46,7 @@ def connect(storage):
return return
raise RuntimeError, "Unable to connect to ZEO server" raise RuntimeError, "Unable to connect to ZEO server"
def pack(addr, storage, days, wait): def pack1(addr, storage, days, wait):
cs = ClientStorage(addr, storage=storage, wait_for_server_on_startup=wait) cs = ClientStorage(addr, storage=storage, wait_for_server_on_startup=wait)
if wait: if wait:
# _startup() is an artifact of the way ZEO 1.0 works. The # _startup() is an artifact of the way ZEO 1.0 works. The
...@@ -57,6 +60,11 @@ def pack(addr, storage, days, wait): ...@@ -57,6 +60,11 @@ def pack(addr, storage, days, wait):
cs.pack(wait=1, days=days) cs.pack(wait=1, days=days)
cs.close() cs.close()
def pack2(addr, storage, days, wait):
cs = ClientStorage(addr, storage=storage, wait=1)
cs.pack(wait=1, days=days)
cs.close()
def usage(exit=1): def usage(exit=1):
print __doc__ print __doc__
print " ".join(sys.argv) print " ".join(sys.argv)
...@@ -69,8 +77,9 @@ def main(): ...@@ -69,8 +77,9 @@ def main():
storage = '1' storage = '1'
days = 0 days = 0
wait = 0 wait = 0
zeoversion = 2
try: try:
opts, args = getopt.getopt(sys.argv[1:], 'p:h:U:S:d:W') opts, args = getopt.getopt(sys.argv[1:], 'p:h:U:S:d:W1')
for o, a in opts: for o, a in opts:
if o == '-p': if o == '-p':
port = int(a) port = int(a)
...@@ -84,6 +93,8 @@ def main(): ...@@ -84,6 +93,8 @@ def main():
days = int(a) days = int(a)
elif o == '-W': elif o == '-W':
wait = 1 wait = 1
elif o == '-1':
zeoversion = 1
except Exception, err: except Exception, err:
print err print err
usage() usage()
...@@ -97,7 +108,10 @@ def main(): ...@@ -97,7 +108,10 @@ def main():
usage() usage()
addr = host, port addr = host, port
pack(addr, storage, days, wait) if zeoversion == 1:
pack1(addr, storage, days, wait)
else:
pack(addr, storage, days)
if __name__ == "__main__": if __name__ == "__main__":
try: try:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment