Commit 5833b7e6 authored by Balazs Lecz's avatar Balazs Lecz
Browse files

Add ExecuteWithUnusedUid() to

Signed-off-by: default avatarBalazs Lecz <>
Reviewed-by: default avatarGuido Trotter <>
parent 649bcdd8
......@@ -328,3 +328,31 @@ def ReleaseUid(uid):
except OSError, err:
raise errors.LockError("Failed to remove user-id lockfile"
" for user-id %s: %s" % (uid, err))
def ExecWithUnusedUid(fn, all_uids, *args, **kwargs):
"""Execute a callable and provide an unused user-id in its kwargs.
This wrapper function provides a simple way to handle the requesting,
unlocking and releasing a user-id.
"fn" is called by passing a "uid" keyword argument that
contains an unused user-id (as a string) selected from the set of user-ids
passed in all_uids.
If there is an error while executing "fn", the user-id is returned
to the pool.
@param fn: a callable
@param all_uids: a set containing all user-ids in the user-id pool
uid = RequestUnusedUid(all_uids)
kwargs["uid"] = str(uid)
return_value = fn(*args, **kwargs)
# The failure of "callabe" means that starting a process with the uid
# failed, so let's put the uid back into the pool.
return return_value
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