IQ.Lvbs/pycapnp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Unlock the GIL for all capnp functions that do IO

Browse Source 
IO might block, and its rude to block while holding the GIL, since that
prevents other threads from running.
This commit is contained in:
Mike Laiosa
2023-10-15 23:33:44 -07:00
committed by Jacob Alexander
parent a30fd77a1c
commit 09f7cd0d08
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
capnp/lib/capnp.pyx
View File

@@ -3739,7 +3739,9 @@ cdef class _StreamFdMessageReader(_MessageReader):
cdef schema_cpp.ReaderOptions opts = make_reader_opts(traversal_limit_in_words, nesting_limit) cdef schema_cpp.ReaderOptions opts = make_reader_opts(traversal_limit_in_words, nesting_limit)
self._parent = file self._parent = file
self.thisptr = new schema_cpp.StreamFdMessageReader(file.fileno(), opts) cdef int fd = file.fileno()
with nogil:
self.thisptr = new schema_cpp.StreamFdMessageReader(fd, opts)
def __dealloc__(self): def __dealloc__(self):
del self.thisptr del self.thisptr
@@ -3842,7 +3844,9 @@ cdef class _PackedFdMessageReader(_MessageReader):
cdef schema_cpp.ReaderOptions opts = make_reader_opts(traversal_limit_in_words, nesting_limit) cdef schema_cpp.ReaderOptions opts = make_reader_opts(traversal_limit_in_words, nesting_limit)
self._parent = file self._parent = file
self.thisptr = new schema_cpp.PackedFdMessageReader(file.fileno(), opts) cdef int fd = file.fileno()
with nogil:
self.thisptr = new schema_cpp.PackedFdMessageReader(fd, opts)
def __dealloc__(self): def __dealloc__(self):
del self.thisptr del self.thisptr
@@ -4251,7 +4255,8 @@ def _write_message_to_fd(int fd, _MessageBuilder message):
:rtype: void :rtype: void
""" """
schema_cpp.writeMessageToFd(fd, deref(message.thisptr)) with nogil:
schema_cpp.writeMessageToFd(fd, deref(message.thisptr))
def _write_packed_message_to_fd(int fd, _MessageBuilder message): def _write_packed_message_to_fd(int fd, _MessageBuilder message):
@@ -4278,7 +4283,8 @@ def _write_packed_message_to_fd(int fd, _MessageBuilder message):
:rtype: void :rtype: void
""" """
schema_cpp.writePackedMessageToFd(fd, deref(message.thisptr)) with nogil:
schema_cpp.writePackedMessageToFd(fd, deref(message.thisptr))
_global_schema_parser = None _global_schema_parser = None