Skip to content

Commit

Permalink
Minor change in noop call
Browse files Browse the repository at this point in the history
  • Loading branch information
gi0baro committed Nov 22, 2024
1 parent 2ed7896 commit 796db42
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 4 deletions.
6 changes: 3 additions & 3 deletions rloop/loop.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
_SubProcessTransport,
_ThreadedChildWatcher,
)
from .utils import _can_use_pidfd, _HAS_IPv6, _ipaddr_info
from .utils import _can_use_pidfd, _HAS_IPv6, _ipaddr_info, _noop


class RLoop(__BaseLoop, __asyncio.AbstractEventLoop):
Expand Down Expand Up @@ -787,7 +787,7 @@ def _signals_clear(self):
self._sig_clear()

def _signals_invoke(self, data):
self._sig_ceval(lambda: None)
self._sig_ceval(_noop)
self._sig_loop_handled = True

sigs = self._signals.copy()
Expand All @@ -803,7 +803,7 @@ def _signals_invoke(self, data):

def _signal_handle(self, signum):
if not self._sig_handle(signum):
self._sig_ceval(lambda: None)
self._sig_ceval(_noop)

#: task factory
def set_task_factory(self, factory):
Expand Down
4 changes: 4 additions & 0 deletions rloop/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -73,3 +73,7 @@ def _ipaddr_info(host, port, family, type, proto, flowinfo=0, scopeid=0):

# "host" is not an IP address.
return None


def _noop():
return
2 changes: 1 addition & 1 deletion src/event_loop.rs
Original file line number Diff line number Diff line change
Expand Up @@ -628,7 +628,7 @@ impl EventLoop {
let noop_ptr = noop.as_ptr();
unsafe {
pyo3::ffi::PyErr_CheckSignals();
pyo3::ffi::PyObject_CallNoArgs(noop_ptr);
pyo3::ffi::compat::PyObject_CallNoArgs(noop_ptr);
}
}

Expand Down

0 comments on commit 796db42

Please sign in to comment.