QPID-4967 - Bug fixes, added a lock to serialize calls into the Python interpreter.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1529307 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 13 insertions, 0 deletions

diff --git a/qpid/extras/dispatch/src/python_embedded.c b/qpid/extras/dispatch/src/python_embedded.c
index c7c8f82dfc..6b235c7406 100644
--- a/qpid/extras/dispatch/src/python_embedded.c
+++ b/qpid/extras/dispatch/src/python_embedded.c
@@ -452,6 +452,7 @@ static void dx_io_rx_handler(void *context, dx_message_t *msg, int link_id)
         return;
     }
 
+    sys_mutex_lock(lock);
     PyObject *pAP   = dx_field_to_py(ap_map);
     PyObject *pBody = dx_field_to_py(body_map);
 
@@ -465,6 +466,7 @@ static void dx_io_rx_handler(void *context, dx_message_t *msg, int link_id)
     if (pValue) {
         Py_DECREF(pValue);
     }
+    sys_mutex_unlock(lock);
 }
 
 
@@ -658,3 +660,14 @@ static void dx_python_setup()
         dispatch_module = m;
     }
 }
+
+void dx_python_lock()
+{
+    sys_mutex_lock(lock);
+}
+
+void dx_python_unlock()
+{
+    sys_mutex_unlock(lock);
+}
+