3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-28 07:58:14 +08:00
Code Issues Projects Releases Wiki Activity

releasing python global lock when doing blocking operations

Browse Source
This commit is contained in:
Martin Sustrik 2009-10-20 18:44:17 +02:00
parent 8b08047cb0
commit 55acf365ea
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bindings/python/pyzmq.cpp
View File

@ -239,7 +239,10 @@ PyObject *socket_send (socket_t *self, PyObject *args, PyObject *kwdict)
memcpy (zmq_msg_data (&data), PyString_AsString (msg),
zmq_msg_size (&data));
Py_BEGIN_ALLOW_THREADS
rc = zmq_send (self->handle, &data, flags);
Py_END_ALLOW_THREADS
int rc2 = zmq_msg_close (&data);
assert (rc2 == 0);
@ -286,7 +289,9 @@ PyObject *socket_recv (socket_t *self, PyObject *args, PyObject *kwdict)
int rc = zmq_msg_init (&msg);
assert (rc == 0);
Py_BEGIN_ALLOW_THREADS
rc = zmq_recv (self->handle, &msg, flags);
Py_END_ALLOW_THREADS
if (rc != 0 && errno == EAGAIN) {
Py_INCREF (Py_None);