/usr/share/pyshared/txzookeeper/utils.py is in python-txzookeeper 0.9.5-0ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 | #
# Copyright (C) 2010-2011 Canonical Ltd. All Rights Reserved
#
# This file is part of txzookeeper.
#
# Authors:
# Kapil Thangavelu
#
# txzookeeper is free software: you can redistribute it and/or modify
# it under the terms of the GNU Lesser General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# txzookeeper is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public License
# along with txzookeeper. If not, see <http://www.gnu.org/licenses/>.
#
import zookeeper
from twisted.internet.defer import inlineCallbacks
@inlineCallbacks
def retry_change(client, path, change_function):
"""
A utility function to execute a node change function, repeatedly
in the face of transient errors. The node at 'path's content will
be changed by the 'change_function' which is passed the node's
current content and node stat. The output will be used to replace
the node's content. If the new content is identical to the previous
new content, no changes are made. Automatically performs, retries
in the face of errors.
@param client A connected txzookeeper client
@param path A path to a node that will be modified
@param change_function A python function that will receive two parameters
the node_content and the current node stat, and will return the
new node content. The function must not have side-effects as
it will be called again in the event of various error conditions.
"""
while True:
create_mode = False
try:
content, stat = yield client.get(path)
except zookeeper.NoNodeException:
create_mode = True
content, stat = None, None
new_content = yield change_function(content, stat)
if new_content == content:
break
try:
if create_mode:
yield client.create(path, new_content)
else:
yield client.set(path, new_content, version=stat["version"])
break
except (zookeeper.NodeExistsException,
zookeeper.NoNodeException,
zookeeper.BadVersionException):
pass
|