diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-07-20 16:12:47 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-07-20 19:38:18 -0700 |
| commit | 8511d4c33a778c1b6f95d39c1c82c4c59731c95f (patch) | |
| tree | d10e27043cc46f748928e00b8b13b5b6a26b5540 /tooz/drivers/ipc.py | |
| parent | e0aff95336fa86a88b8c9c09de191858969da582 (diff) | |
| download | tooz-8511d4c33a778c1b6f95d39c1c82c4c59731c95f.tar.gz | |
Use futurist to allow for executor providing and unifying
Depends-On: Ifd7b6e11863cae3d34fd5475a364ebb7c28811fc
Change-Id: Ie5f800c1620451e605e8d28673631b7436019279
Diffstat (limited to 'tooz/drivers/ipc.py')
| -rw-r--r-- | tooz/drivers/ipc.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/tooz/drivers/ipc.py b/tooz/drivers/ipc.py index 5a21677..d57fc1d 100644 --- a/tooz/drivers/ipc.py +++ b/tooz/drivers/ipc.py @@ -139,6 +139,7 @@ class IPCDriver(coordination.CoordinationDriver): def __init__(self, member_id, parsed_url, options): """Initialize the IPC driver.""" super(IPCDriver, self).__init__() + self._executor = utils.ProxyExecutor.build("IPC", options) def _start(self): self._group_list = sysv_ipc.SharedMemory( @@ -146,10 +147,10 @@ class IPCDriver(coordination.CoordinationDriver): sysv_ipc.IPC_CREAT, size=self._SEGMENT_SIZE) self._lock = self.get_lock(self._INTERNAL_LOCK_NAME) - self._executor = futures.ThreadPoolExecutor(max_workers=1) + self._executor.start() def _stop(self): - self._executor.shutdown(wait=True) + self._executor.stop() try: self._group_list.detach() self._group_list.remove() |