openstack/deb-python-eventlet
Code Issues Proposed changes

Dropped keyword arg so that we don't use main_wrapper in GreenPool.spawn_n

Browse Source
This commit is contained in:
Ryan Williams
2010-02-23 22:53:19 -05:00
parent d519696672
commit ef568ce6b1
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
eventlet/greenpool.py
View File

@@ -83,7 +83,7 @@ class GreenPool(object):
gt.link(self._spawn_done) gt.link(self._spawn_done)
return gt return gt
def _spawn_n_impl(self, func, args, kwargs, coro=None): def _spawn_n_impl(self, func, args, kwargs, coro):
try: try:
try: try:
func(*args, **kwargs) func(*args, **kwargs)
@@ -108,11 +108,11 @@ class GreenPool(object):
# itself -- instead, just execute in the current coroutine # itself -- instead, just execute in the current coroutine
current = greenthread.getcurrent() current = greenthread.getcurrent()
if self.sem.locked() and current in self.coroutines_running: if self.sem.locked() and current in self.coroutines_running:
self._spawn_n_impl(function, args, kwargs) self._spawn_n_impl(function, args, kwargs, None)
else: else:
self.sem.acquire() self.sem.acquire()
g = greenthread.spawn_n(self._spawn_n_impl, g = greenthread.spawn_n(self._spawn_n_impl,
function, args, kwargs, coro=True) function, args, kwargs, True)
if not self.coroutines_running: if not self.coroutines_running:
self.no_coros_running = event.Event() self.no_coros_running = event.Event()
self.coroutines_running.add(g) self.coroutines_running.add(g)