diff --git a/mitogen/core.py b/mitogen/core.py index 189e6d31..428965eb 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -1063,7 +1063,6 @@ class Latch(object): def get(self, timeout=None, block=True): _vv and IOLOG.debug('%r.get(timeout=%r, block=%r)', self, timeout, block) - self._lock.acquire() try: if self.closed: diff --git a/mitogen/parent.py b/mitogen/parent.py index ebe61fc1..01b558fe 100644 --- a/mitogen/parent.py +++ b/mitogen/parent.py @@ -561,7 +561,7 @@ class KqueuePoller(Poller): self._control(fd, select.KQ_FILTER_WRITE, select.KQ_EV_DELETE) del self._wfds[fd] - def poll(self, broker, timeout=None): + def poll(self, timeout=None): changelist = self._changelist self._changelist = [] events, _ = mitogen.core.io_op(self._kqueue.control, @@ -633,7 +633,7 @@ class EpollPoller(Poller): self._wfds.pop(fd, None) self._control(fd) - def poll(self, broker, timeout=None): + def poll(self, timeout=None): the_timeout = -1 if timeout is not None: the_timeout = timeout