diff options
| author | Jenkins <jenkins@review.openstack.org> | 2012-11-05 21:29:16 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2012-11-05 21:29:16 +0000 |
| commit | ac4515559fb7bd1a480f7260b7143ebf84e2202a (patch) | |
| tree | 77bc9b497a7c2e1e6a6004be4f957b4580a82b12 /openstack | |
| parent | bbb9f9a805317d5e05df6075d818c073ab3a5a33 (diff) | |
| parent | aa2e2135f7d04d526ef12c885d9b57712cc2b079 (diff) | |
| download | oslo-ac4515559fb7bd1a480f7260b7143ebf84e2202a.tar.gz oslo-ac4515559fb7bd1a480f7260b7143ebf84e2202a.tar.xz oslo-ac4515559fb7bd1a480f7260b7143ebf84e2202a.zip | |
Merge "Use spawn_n when not capturing return value"
Diffstat (limited to 'openstack')
| -rw-r--r-- | openstack/common/eventlet_backdoor.py | 6 | ||||
| -rw-r--r-- | openstack/common/loopingcall.py | 2 | ||||
| -rw-r--r-- | openstack/common/service.py | 2 |
3 files changed, 5 insertions, 5 deletions
diff --git a/openstack/common/eventlet_backdoor.py b/openstack/common/eventlet_backdoor.py index a86d24c..242c371 100644 --- a/openstack/common/eventlet_backdoor.py +++ b/openstack/common/eventlet_backdoor.py @@ -73,6 +73,6 @@ def initialize_if_enabled(): pprint.pprint(val) sys.displayhook = displayhook - eventlet.spawn(eventlet.backdoor.backdoor_server, - eventlet.listen(('localhost', CONF.backdoor_port)), - locals=backdoor_locals) + eventlet.spawn_n(eventlet.backdoor.backdoor_server, + eventlet.listen(('localhost', CONF.backdoor_port)), + locals=backdoor_locals) diff --git a/openstack/common/loopingcall.py b/openstack/common/loopingcall.py index 36a533c..1d34519 100644 --- a/openstack/common/loopingcall.py +++ b/openstack/common/loopingcall.py @@ -78,7 +78,7 @@ class LoopingCall(object): self.done = done - greenthread.spawn(_inner) + greenthread.spawn_n(_inner) return self.done def stop(self): diff --git a/openstack/common/service.py b/openstack/common/service.py index 002d478..dc2d374 100644 --- a/openstack/common/service.py +++ b/openstack/common/service.py @@ -191,7 +191,7 @@ class ProcessLauncher(object): # Close write to ensure only parent has it open os.close(self.writepipe) # Create greenthread to watch for parent to close pipe - eventlet.spawn(self._pipe_watcher) + eventlet.spawn_n(self._pipe_watcher) # Reseed random number generator random.seed() |