mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-12 02:15:31 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/gst.override: use new threading API

Browse source 
Original commit message from CVS:
* gst/gst.override: use new threading API
This commit is contained in:
Johan Dahlin 2004-09-22 16:34:08 +00:00
parent 828449319c
commit 009920d062
3 changed files with 21 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ChangeLog
View file

@ -1,3 +1,7 @@
2004-09-22 Johan Dahlin <johan@gnome.org>
* gst/gst.override: use new threading API
2004-09-13 Thomas Vander Stichele <thomas at apestaart dot org> 2004-09-13 Thomas Vander Stichele <thomas at apestaart dot org>
* gst/__init__.py: * gst/__init__.py:

2
common

@ -1 +1 @@
Subproject commit 5ec931d243c53ddda5b2cbb9a2c21ce89747bcb4 Subproject commit ded6dc5186cb7f8c64cb06a8591b9f787122c6f1

18
gst/gst.override
View file

@ -171,11 +171,11 @@ _wrap_gst_element_set_state(PyGObject *self, PyObject *args, PyObject *kwargs)
if (pyg_flags_get_value(GST_TYPE_ELEMENT_STATE, py_state, (gint *)&state)) if (pyg_flags_get_value(GST_TYPE_ELEMENT_STATE, py_state, (gint *)&state))
return NULL; return NULL;
Py_BEGIN_ALLOW_THREADS; pyg_begin_allow_threads;
ret = gst_element_set_state(GST_ELEMENT(self->obj), state); ret = gst_element_set_state(GST_ELEMENT(self->obj), state);
Py_END_ALLOW_THREADS; pyg_end_allow_threads;
return PyInt_FromLong(ret); return PyInt_FromLong(ret);
} }
@ -833,10 +833,11 @@ pygst_structure_foreach_marshal(GQuark field_id,
PyGstCustomNotify *cunote = user_data; PyGstCustomNotify *cunote = user_data;
PyObject *py_field, *py_value, *retobj; PyObject *py_field, *py_value, *retobj;
gboolean retval = TRUE; gboolean retval = TRUE;
PyGILState_STATE state;
g_assert(cunote->func); g_assert(cunote->func);
pyg_block_threads(); state = pyg_gil_state_ensure();
py_field = Py_BuildValue("s", g_quark_to_string(field_id)); py_field = Py_BuildValue("s", g_quark_to_string(field_id));
py_value = pyg_value_as_pyobject(value, FALSE); py_value = pyg_value_as_pyobject(value, FALSE);
@ -857,7 +858,7 @@ pygst_structure_foreach_marshal(GQuark field_id,
Py_XDECREF(retobj); Py_XDECREF(retobj);
pyg_unblock_threads(); pyg_gil_state_release(state);
return retval; return retval;
} }
@ -936,10 +937,11 @@ pygst_tag_list_foreach_marshal(GstTagList *list,
PyObject *py_list; PyObject *py_list;
PyObject *py_key, *retobj; PyObject *py_key, *retobj;
gboolean retval = TRUE; gboolean retval = TRUE;
PyGILState_STATE state;
g_assert(cunote->func); g_assert(cunote->func);
pyg_block_threads(); state = pyg_gil_state_ensure();
py_list = pyg_boxed_new(GST_TYPE_TAG_LIST, list, TRUE, TRUE); py_list = pyg_boxed_new(GST_TYPE_TAG_LIST, list, TRUE, TRUE);
py_key = Py_BuildValue("s", tag); py_key = Py_BuildValue("s", tag);
@ -962,7 +964,7 @@ pygst_tag_list_foreach_marshal(GstTagList *list,
Py_XDECREF(retobj); Py_XDECREF(retobj);
pyg_unblock_threads(); pyg_gil_state_release(state);
return retval; return retval;
} }
@ -1094,11 +1096,11 @@ override gst_main noargs
static PyObject * static PyObject *
_wrap_gst_main(PyObject *self) _wrap_gst_main(PyObject *self)
{ {
Py_BEGIN_ALLOW_THREADS; pyg_begin_allow_threads;
_pygst_main(); _pygst_main();
Py_END_ALLOW_THREADS; pyg_end_allow_threads;
if (PyErr_Occurred()) if (PyErr_Occurred())
return NULL; return NULL;