diff options
| author | Julien Danjou <julien@danjou.info> | 2014-08-04 15:51:14 +0200 |
|---|---|---|
| committer | Julien Danjou <julien@danjou.info> | 2014-08-07 18:12:51 +0200 |
| commit | d38fe0301d991300a29ab09175f110356fe47653 (patch) | |
| tree | 9c865c49977e7cb4409d77902280fc447c6a878e /tooz/drivers/ipc.py | |
| parent | 30588b877a813d1ced820313855dfb9826e2c083 (diff) | |
| download | tooz-d38fe0301d991300a29ab09175f110356fe47653.tar.gz | |
Switch to URL for loading backends0.3
This allow to pass options in a single string, which is going to be
easier for managing options.
Change-Id: I32409c09153b8abaf2b36c31f0bbf658a9d653bc
Diffstat (limited to 'tooz/drivers/ipc.py')
| -rw-r--r-- | tooz/drivers/ipc.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tooz/drivers/ipc.py b/tooz/drivers/ipc.py index 748dac2..50cbbda 100644 --- a/tooz/drivers/ipc.py +++ b/tooz/drivers/ipc.py @@ -44,7 +44,7 @@ class IPCLock(locking.Lock): class IPCDriver(coordination.CoordinationDriver): - def __init__(self, member_id, lock_timeout=30): + def __init__(self, member_id, parsed_url, options): """Initialize the IPC driver. :param lock_timeout: how many seconds to wait when trying to acquire @@ -55,7 +55,7 @@ class IPCDriver(coordination.CoordinationDriver): lock_timeout """ super(IPCDriver, self).__init__() - self.lock_timeout = lock_timeout + self.lock_timeout = int(options.get('lock_timeout', ['30'])[-1]) def get_lock(self, name): return IPCLock(name, self.lock_timeout) |