mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-04-23 09:04:15 +00:00
*.*: Ran scripts/update-macros. Oh yes.
Original commit message from CVS: 2005-11-21 Andy Wingo <wingo@pobox.com> * *.h: * *.c: Ran scripts/update-macros. Oh yes.
This commit is contained in:
parent
bba99aa3da
commit
0d470f58ca
11 changed files with 75 additions and 70 deletions
|
@ -1,3 +1,8 @@
|
||||||
|
2005-11-21 Andy Wingo <wingo@pobox.com>
|
||||||
|
|
||||||
|
* *.h:
|
||||||
|
* *.c: Ran scripts/update-macros. Oh yes.
|
||||||
|
|
||||||
2005-11-21 Tim-Philipp Müller <tim at centricular dot net>
|
2005-11-21 Tim-Philipp Müller <tim at centricular dot net>
|
||||||
|
|
||||||
* gst/matroska/matroska-demux.c: (gst_matroska_demux_sync_streams):
|
* gst/matroska/matroska-demux.c: (gst_matroska_demux_sync_streams):
|
||||||
|
|
|
@ -292,7 +292,7 @@ gst_text_overlay_set_property (GObject * object, guint prop_id,
|
||||||
{
|
{
|
||||||
GstTextOverlay *overlay = GST_TEXT_OVERLAY (object);
|
GstTextOverlay *overlay = GST_TEXT_OVERLAY (object);
|
||||||
|
|
||||||
GST_LOCK (overlay);
|
GST_OBJECT_LOCK (overlay);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_TEXT:{
|
case ARG_TEXT:{
|
||||||
|
@ -362,7 +362,7 @@ gst_text_overlay_set_property (GObject * object, guint prop_id,
|
||||||
|
|
||||||
overlay->need_render = TRUE;
|
overlay->need_render = TRUE;
|
||||||
|
|
||||||
GST_UNLOCK (overlay);
|
GST_OBJECT_UNLOCK (overlay);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
|
|
@ -707,7 +707,7 @@ gst_flacenc_set_property (GObject * object, guint prop_id,
|
||||||
{
|
{
|
||||||
GstFlacEnc *this = GST_FLACENC (object);
|
GstFlacEnc *this = GST_FLACENC (object);
|
||||||
|
|
||||||
GST_LOCK (this);
|
GST_OBJECT_LOCK (this);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case PROP_QUALITY:
|
case PROP_QUALITY:
|
||||||
|
@ -766,7 +766,7 @@ gst_flacenc_set_property (GObject * object, guint prop_id,
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (this);
|
GST_OBJECT_UNLOCK (this);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
@ -775,7 +775,7 @@ gst_flacenc_get_property (GObject * object, guint prop_id,
|
||||||
{
|
{
|
||||||
GstFlacEnc *this = GST_FLACENC (object);
|
GstFlacEnc *this = GST_FLACENC (object);
|
||||||
|
|
||||||
GST_LOCK (this);
|
GST_OBJECT_LOCK (this);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case PROP_QUALITY:
|
case PROP_QUALITY:
|
||||||
|
@ -841,7 +841,7 @@ gst_flacenc_get_property (GObject * object, guint prop_id,
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (this);
|
GST_OBJECT_UNLOCK (this);
|
||||||
}
|
}
|
||||||
|
|
||||||
static GstStateChangeReturn
|
static GstStateChangeReturn
|
||||||
|
|
|
@ -55,33 +55,33 @@ gst_bin_find_unconnected_pad (GstBin * bin, GstPadDirection direction)
|
||||||
const GList *pads = NULL;
|
const GList *pads = NULL;
|
||||||
GstElement *element = NULL;
|
GstElement *element = NULL;
|
||||||
|
|
||||||
GST_LOCK (bin);
|
GST_OBJECT_LOCK (bin);
|
||||||
elements = bin->children;
|
elements = bin->children;
|
||||||
/* traverse all elements looking for unconnected pads */
|
/* traverse all elements looking for unconnected pads */
|
||||||
while (elements && pad == NULL) {
|
while (elements && pad == NULL) {
|
||||||
element = GST_ELEMENT (elements->data);
|
element = GST_ELEMENT (elements->data);
|
||||||
GST_LOCK (element);
|
GST_OBJECT_LOCK (element);
|
||||||
pads = element->pads;
|
pads = element->pads;
|
||||||
while (pads) {
|
while (pads) {
|
||||||
GstPad *testpad = GST_PAD (pads->data);
|
GstPad *testpad = GST_PAD (pads->data);
|
||||||
|
|
||||||
/* check if the direction matches */
|
/* check if the direction matches */
|
||||||
if (GST_PAD_DIRECTION (testpad) == direction) {
|
if (GST_PAD_DIRECTION (testpad) == direction) {
|
||||||
GST_LOCK (testpad);
|
GST_OBJECT_LOCK (testpad);
|
||||||
if (GST_PAD_PEER (testpad) == NULL) {
|
if (GST_PAD_PEER (testpad) == NULL) {
|
||||||
GST_UNLOCK (testpad);
|
GST_OBJECT_UNLOCK (testpad);
|
||||||
/* found it ! */
|
/* found it ! */
|
||||||
pad = testpad;
|
pad = testpad;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
GST_UNLOCK (testpad);
|
GST_OBJECT_UNLOCK (testpad);
|
||||||
}
|
}
|
||||||
pads = g_list_next (pads);
|
pads = g_list_next (pads);
|
||||||
}
|
}
|
||||||
GST_UNLOCK (element);
|
GST_OBJECT_UNLOCK (element);
|
||||||
elements = g_list_next (elements);
|
elements = g_list_next (elements);
|
||||||
}
|
}
|
||||||
GST_UNLOCK (bin);
|
GST_OBJECT_UNLOCK (bin);
|
||||||
|
|
||||||
return pad;
|
return pad;
|
||||||
}
|
}
|
||||||
|
|
|
@ -163,7 +163,7 @@ gst_break_my_data_set_property (GObject * object, guint prop_id,
|
||||||
{
|
{
|
||||||
GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
|
GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
|
||||||
|
|
||||||
GST_LOCK (bmd);
|
GST_OBJECT_LOCK (bmd);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_SEED:
|
case ARG_SEED:
|
||||||
|
@ -183,7 +183,7 @@ gst_break_my_data_set_property (GObject * object, guint prop_id,
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (bmd);
|
GST_OBJECT_UNLOCK (bmd);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
@ -192,7 +192,7 @@ gst_break_my_data_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
{
|
{
|
||||||
GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
|
GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
|
||||||
|
|
||||||
GST_LOCK (bmd);
|
GST_OBJECT_LOCK (bmd);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_SEED:
|
case ARG_SEED:
|
||||||
|
@ -212,7 +212,7 @@ gst_break_my_data_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (bmd);
|
GST_OBJECT_UNLOCK (bmd);
|
||||||
}
|
}
|
||||||
|
|
||||||
static GstFlowReturn
|
static GstFlowReturn
|
||||||
|
@ -223,7 +223,7 @@ gst_break_my_data_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
|
||||||
|
|
||||||
g_return_val_if_fail (gst_buffer_is_writable (buf), GST_FLOW_ERROR);
|
g_return_val_if_fail (gst_buffer_is_writable (buf), GST_FLOW_ERROR);
|
||||||
|
|
||||||
GST_LOCK (bmd);
|
GST_OBJECT_LOCK (bmd);
|
||||||
|
|
||||||
if (bmd->skipped < bmd->skip) {
|
if (bmd->skipped < bmd->skip) {
|
||||||
i = bmd->skip - bmd->skipped;
|
i = bmd->skip - bmd->skipped;
|
||||||
|
@ -256,7 +256,7 @@ gst_break_my_data_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
|
||||||
/* don't overflow */
|
/* don't overflow */
|
||||||
bmd->skipped += MIN (G_MAXUINT - bmd->skipped, GST_BUFFER_SIZE (buf));
|
bmd->skipped += MIN (G_MAXUINT - bmd->skipped, GST_BUFFER_SIZE (buf));
|
||||||
|
|
||||||
GST_UNLOCK (bmd);
|
GST_OBJECT_UNLOCK (bmd);
|
||||||
|
|
||||||
return GST_FLOW_OK;
|
return GST_FLOW_OK;
|
||||||
}
|
}
|
||||||
|
@ -266,10 +266,10 @@ gst_break_my_data_start (GstBaseTransform * trans)
|
||||||
{
|
{
|
||||||
GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
|
GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
|
||||||
|
|
||||||
GST_LOCK (bmd);
|
GST_OBJECT_LOCK (bmd);
|
||||||
bmd->rand = g_rand_new_with_seed (bmd->seed);
|
bmd->rand = g_rand_new_with_seed (bmd->seed);
|
||||||
bmd->skipped = 0;
|
bmd->skipped = 0;
|
||||||
GST_UNLOCK (bmd);
|
GST_OBJECT_UNLOCK (bmd);
|
||||||
|
|
||||||
return TRUE;
|
return TRUE;
|
||||||
}
|
}
|
||||||
|
@ -279,10 +279,10 @@ gst_break_my_data_stop (GstBaseTransform * trans)
|
||||||
{
|
{
|
||||||
GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
|
GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
|
||||||
|
|
||||||
GST_LOCK (bmd);
|
GST_OBJECT_LOCK (bmd);
|
||||||
g_rand_free (bmd->rand);
|
g_rand_free (bmd->rand);
|
||||||
bmd->rand = NULL;
|
bmd->rand = NULL;
|
||||||
GST_UNLOCK (bmd);
|
GST_OBJECT_UNLOCK (bmd);
|
||||||
|
|
||||||
return TRUE;
|
return TRUE;
|
||||||
}
|
}
|
||||||
|
|
|
@ -254,9 +254,9 @@ gst_navseek_set_property (GObject * object, guint prop_id,
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_SEEKOFFSET:
|
case ARG_SEEKOFFSET:
|
||||||
GST_LOCK (navseek);
|
GST_OBJECT_LOCK (navseek);
|
||||||
navseek->seek_offset = g_value_get_double (value);
|
navseek->seek_offset = g_value_get_double (value);
|
||||||
GST_UNLOCK (navseek);
|
GST_OBJECT_UNLOCK (navseek);
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
||||||
|
@ -272,9 +272,9 @@ gst_navseek_get_property (GObject * object, guint prop_id,
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_SEEKOFFSET:
|
case ARG_SEEKOFFSET:
|
||||||
GST_LOCK (navseek);
|
GST_OBJECT_LOCK (navseek);
|
||||||
g_value_set_double (value, navseek->seek_offset);
|
g_value_set_double (value, navseek->seek_offset);
|
||||||
GST_UNLOCK (navseek);
|
GST_OBJECT_UNLOCK (navseek);
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
||||||
|
@ -289,10 +289,10 @@ gst_navseek_event (GstBaseTransform * trans, GstEvent * event)
|
||||||
|
|
||||||
switch (GST_EVENT_TYPE (event)) {
|
switch (GST_EVENT_TYPE (event)) {
|
||||||
case GST_EVENT_EOS:
|
case GST_EVENT_EOS:
|
||||||
GST_LOCK (navseek);
|
GST_OBJECT_LOCK (navseek);
|
||||||
if (navseek->loop)
|
if (navseek->loop)
|
||||||
gst_navseek_segseek (navseek);
|
gst_navseek_segseek (navseek);
|
||||||
GST_UNLOCK (navseek);
|
GST_OBJECT_UNLOCK (navseek);
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
break;
|
break;
|
||||||
|
@ -305,7 +305,7 @@ gst_navseek_transform_ip (GstBaseTransform * basetrans, GstBuffer * buf)
|
||||||
{
|
{
|
||||||
GstNavSeek *navseek = GST_NAVSEEK (basetrans);
|
GstNavSeek *navseek = GST_NAVSEEK (basetrans);
|
||||||
|
|
||||||
GST_LOCK (navseek);
|
GST_OBJECT_LOCK (navseek);
|
||||||
|
|
||||||
if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
|
if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
|
||||||
if (navseek->grab_seg_start) {
|
if (navseek->grab_seg_start) {
|
||||||
|
@ -321,7 +321,7 @@ gst_navseek_transform_ip (GstBaseTransform * basetrans, GstBuffer * buf)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (navseek);
|
GST_OBJECT_UNLOCK (navseek);
|
||||||
|
|
||||||
return GST_FLOW_OK;
|
return GST_FLOW_OK;
|
||||||
}
|
}
|
||||||
|
|
|
@ -167,7 +167,7 @@ gst_progress_report_report (GstProgressReport * filter, GTimeVal cur_time)
|
||||||
gint hh, mm, ss, i;
|
gint hh, mm, ss, i;
|
||||||
glong run_time;
|
glong run_time;
|
||||||
|
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
run_time = cur_time.tv_sec - filter->start_time.tv_sec;
|
run_time = cur_time.tv_sec - filter->start_time.tv_sec;
|
||||||
|
|
||||||
hh = (run_time / 3600) % 100;
|
hh = (run_time / 3600) % 100;
|
||||||
|
@ -252,7 +252,7 @@ gst_progress_report_report (GstProgressReport * filter, GTimeVal cur_time)
|
||||||
GST_OBJECT_NAME (filter), hh, mm, ss);
|
GST_OBJECT_NAME (filter), hh, mm, ss);
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
|
|
||||||
gst_object_unref (peer_pad);
|
gst_object_unref (peer_pad);
|
||||||
}
|
}
|
||||||
|
@ -285,16 +285,16 @@ gst_progress_report_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
|
||||||
filter = GST_PROGRESS_REPORT (trans);
|
filter = GST_PROGRESS_REPORT (trans);
|
||||||
|
|
||||||
/* Check if update_freq seconds have passed since the last update */
|
/* Check if update_freq seconds have passed since the last update */
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
need_update =
|
need_update =
|
||||||
((cur_time.tv_sec - filter->last_report.tv_sec) >= filter->update_freq);
|
((cur_time.tv_sec - filter->last_report.tv_sec) >= filter->update_freq);
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
|
|
||||||
if (need_update) {
|
if (need_update) {
|
||||||
gst_progress_report_report (filter, cur_time);
|
gst_progress_report_report (filter, cur_time);
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
filter->last_report = cur_time;
|
filter->last_report = cur_time;
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
}
|
}
|
||||||
|
|
||||||
return GST_FLOW_OK;
|
return GST_FLOW_OK;
|
||||||
|
@ -330,14 +330,14 @@ gst_progress_report_set_property (GObject * object, guint prop_id,
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_UPDATE_FREQ:
|
case ARG_UPDATE_FREQ:
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
filter->update_freq = g_value_get_int (value);
|
filter->update_freq = g_value_get_int (value);
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
break;
|
break;
|
||||||
case ARG_SILENT:
|
case ARG_SILENT:
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
filter->silent = g_value_get_boolean (value);
|
filter->silent = g_value_get_boolean (value);
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
break;
|
break;
|
||||||
|
@ -354,14 +354,14 @@ gst_progress_report_get_property (GObject * object, guint prop_id,
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case ARG_UPDATE_FREQ:
|
case ARG_UPDATE_FREQ:
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
g_value_set_int (value, filter->update_freq);
|
g_value_set_int (value, filter->update_freq);
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
break;
|
break;
|
||||||
case ARG_SILENT:
|
case ARG_SILENT:
|
||||||
GST_LOCK (filter);
|
GST_OBJECT_LOCK (filter);
|
||||||
g_value_set_boolean (value, filter->silent);
|
g_value_set_boolean (value, filter->silent);
|
||||||
GST_UNLOCK (filter);
|
GST_OBJECT_UNLOCK (filter);
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
||||||
|
|
|
@ -263,9 +263,9 @@ gst_test_set_property (GObject * object, guint prop_id,
|
||||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
||||||
} else {
|
} else {
|
||||||
/* expected values */
|
/* expected values */
|
||||||
GST_LOCK (test);
|
GST_OBJECT_LOCK (test);
|
||||||
g_value_copy (value, &test->values[prop_id / 2 - 1]);
|
g_value_copy (value, &test->values[prop_id / 2 - 1]);
|
||||||
GST_UNLOCK (test);
|
GST_OBJECT_UNLOCK (test);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -281,7 +281,7 @@ gst_test_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_LOCK (test);
|
GST_OBJECT_LOCK (test);
|
||||||
|
|
||||||
if (prop_id % 2) {
|
if (prop_id % 2) {
|
||||||
/* real values */
|
/* real values */
|
||||||
|
@ -291,7 +291,7 @@ gst_test_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
g_value_copy (&test->values[id], value);
|
g_value_copy (&test->values[id], value);
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_UNLOCK (test);
|
GST_OBJECT_UNLOCK (test);
|
||||||
}
|
}
|
||||||
|
|
||||||
gboolean
|
gboolean
|
||||||
|
|
|
@ -954,9 +954,9 @@ gst_matroska_demux_handle_src_query (GstPad * pad, GstQuery * query)
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_LOCK (demux);
|
GST_OBJECT_LOCK (demux);
|
||||||
gst_query_set_position (query, GST_FORMAT_TIME, demux->pos);
|
gst_query_set_position (query, GST_FORMAT_TIME, demux->pos);
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
|
|
||||||
res = TRUE;
|
res = TRUE;
|
||||||
break;
|
break;
|
||||||
|
@ -972,9 +972,9 @@ gst_matroska_demux_handle_src_query (GstPad * pad, GstQuery * query)
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_LOCK (demux);
|
GST_OBJECT_LOCK (demux);
|
||||||
gst_query_set_duration (query, GST_FORMAT_TIME, demux->duration);
|
gst_query_set_duration (query, GST_FORMAT_TIME, demux->duration);
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
|
|
||||||
res = TRUE;
|
res = TRUE;
|
||||||
break;
|
break;
|
||||||
|
@ -1079,14 +1079,14 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
|
||||||
|
|
||||||
/* check sanity before we start flushing and all that */
|
/* check sanity before we start flushing and all that */
|
||||||
if (cur_type == GST_SEEK_TYPE_SET) {
|
if (cur_type == GST_SEEK_TYPE_SET) {
|
||||||
GST_LOCK (demux);
|
GST_OBJECT_LOCK (demux);
|
||||||
if (!gst_matroskademux_do_index_seek (demux, cur)) {
|
if (!gst_matroskademux_do_index_seek (demux, cur)) {
|
||||||
GST_DEBUG ("No matching seek entry in index");
|
GST_DEBUG ("No matching seek entry in index");
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
GST_DEBUG ("Seek position looks sane");
|
GST_DEBUG ("Seek position looks sane");
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
}
|
}
|
||||||
|
|
||||||
flush = !!(flags & GST_SEEK_FLAG_FLUSH);
|
flush = !!(flags & GST_SEEK_FLAG_FLUSH);
|
||||||
|
@ -1104,7 +1104,7 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
|
||||||
* forever. */
|
* forever. */
|
||||||
GST_STREAM_LOCK (demux->sinkpad);
|
GST_STREAM_LOCK (demux->sinkpad);
|
||||||
|
|
||||||
GST_LOCK (demux);
|
GST_OBJECT_LOCK (demux);
|
||||||
|
|
||||||
/* if nothing configured, play complete file */
|
/* if nothing configured, play complete file */
|
||||||
if (cur == GST_CLOCK_TIME_NONE)
|
if (cur == GST_CLOCK_TIME_NONE)
|
||||||
|
@ -1168,7 +1168,7 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
|
||||||
newsegment_event = gst_event_new_newsegment (FALSE, demux->segment_rate,
|
newsegment_event = gst_event_new_newsegment (FALSE, demux->segment_rate,
|
||||||
GST_FORMAT_TIME, entry->time, demux->segment_stop, entry->time);
|
GST_FORMAT_TIME, entry->time, demux->segment_stop, entry->time);
|
||||||
|
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
|
|
||||||
GST_DEBUG ("Stopping flush");
|
GST_DEBUG ("Stopping flush");
|
||||||
if (flush) {
|
if (flush) {
|
||||||
|
@ -1197,7 +1197,7 @@ seek_error:
|
||||||
/* FIXME: shouldn't we either make it a real error or start the task
|
/* FIXME: shouldn't we either make it a real error or start the task
|
||||||
* function again so that things can continue from where they left off? */
|
* function again so that things can continue from where they left off? */
|
||||||
GST_DEBUG ("Got a seek error");
|
GST_DEBUG ("Got a seek error");
|
||||||
GST_UNLOCK (demux);
|
GST_OBJECT_UNLOCK (demux);
|
||||||
GST_STREAM_UNLOCK (demux->sinkpad);
|
GST_STREAM_UNLOCK (demux->sinkpad);
|
||||||
|
|
||||||
return FALSE;
|
return FALSE;
|
||||||
|
|
|
@ -128,12 +128,12 @@ gst_ossdmabuffer_func (GstRingBuffer * buf)
|
||||||
struct count_info count;
|
struct count_info count;
|
||||||
GstOssDMABuffer *obuf = (GstOssDMABuffer *) buf;
|
GstOssDMABuffer *obuf = (GstOssDMABuffer *) buf;
|
||||||
|
|
||||||
GST_LOCK (buf);
|
GST_OBJECT_LOCK (buf);
|
||||||
while (obuf->running) {
|
while (obuf->running) {
|
||||||
if (buf->state == GST_RINGBUFFER_STATE_PLAYING) {
|
if (buf->state == GST_RINGBUFFER_STATE_PLAYING) {
|
||||||
int segsize;
|
int segsize;
|
||||||
|
|
||||||
GST_UNLOCK (buf);
|
GST_OBJECT_UNLOCK (buf);
|
||||||
|
|
||||||
segsize = buf->spec.segsize;
|
segsize = buf->spec.segsize;
|
||||||
|
|
||||||
|
@ -152,13 +152,13 @@ gst_ossdmabuffer_func (GstRingBuffer * buf)
|
||||||
|
|
||||||
gst_ringbuffer_callback (buf, count.blocks);
|
gst_ringbuffer_callback (buf, count.blocks);
|
||||||
|
|
||||||
GST_LOCK (buf);
|
GST_OBJECT_LOCK (buf);
|
||||||
} else {
|
} else {
|
||||||
GST_OSSDMABUFFER_SIGNAL (obuf);
|
GST_OSSDMABUFFER_SIGNAL (obuf);
|
||||||
GST_OSSDMABUFFER_WAIT (obuf);
|
GST_OSSDMABUFFER_WAIT (obuf);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
GST_UNLOCK (buf);
|
GST_OBJECT_UNLOCK (buf);
|
||||||
}
|
}
|
||||||
|
|
||||||
static gboolean
|
static gboolean
|
||||||
|
@ -256,12 +256,12 @@ gst_ossdmabuffer_acquire (GstRingBuffer * buf, GstRingBufferSpec * spec)
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_LOCK (obuf);
|
GST_OBJECT_LOCK (obuf);
|
||||||
obuf->running = TRUE;
|
obuf->running = TRUE;
|
||||||
obuf->thread = g_thread_create ((GThreadFunc) gst_ossdmabuffer_func,
|
obuf->thread = g_thread_create ((GThreadFunc) gst_ossdmabuffer_func,
|
||||||
buf, TRUE, NULL);
|
buf, TRUE, NULL);
|
||||||
GST_OSSDMABUFFER_WAIT (obuf);
|
GST_OSSDMABUFFER_WAIT (obuf);
|
||||||
GST_UNLOCK (obuf);
|
GST_OBJECT_UNLOCK (obuf);
|
||||||
|
|
||||||
return TRUE;
|
return TRUE;
|
||||||
}
|
}
|
||||||
|
@ -273,10 +273,10 @@ gst_ossdmabuffer_release (GstRingBuffer * buf)
|
||||||
|
|
||||||
gst_buffer_unref (buf->data);
|
gst_buffer_unref (buf->data);
|
||||||
|
|
||||||
GST_LOCK (obuf);
|
GST_OBJECT_LOCK (obuf);
|
||||||
obuf->running = FALSE;
|
obuf->running = FALSE;
|
||||||
GST_OSSDMABUFFER_SIGNAL (obuf);
|
GST_OSSDMABUFFER_SIGNAL (obuf);
|
||||||
GST_UNLOCK (obuf);
|
GST_OBJECT_UNLOCK (obuf);
|
||||||
|
|
||||||
g_thread_join (obuf->thread);
|
g_thread_join (obuf->thread);
|
||||||
|
|
||||||
|
|
|
@ -46,11 +46,11 @@ typedef struct _GstOssDMABuffer GstOssDMABuffer;
|
||||||
typedef struct _GstOssDMABufferClass GstOssDMABufferClass;
|
typedef struct _GstOssDMABufferClass GstOssDMABufferClass;
|
||||||
|
|
||||||
#define GST_OSSDMABUFFER_THREAD(buf) (GST_OSSDMABUFFER(buf)->thread)
|
#define GST_OSSDMABUFFER_THREAD(buf) (GST_OSSDMABUFFER(buf)->thread)
|
||||||
#define GST_OSSDMABUFFER_LOCK GST_LOCK
|
#define GST_OSSDMABUFFER_LOCK GST_OBJECT_LOCK
|
||||||
#define GST_OSSDMABUFFER_UNLOCK GST_UNLOCK
|
#define GST_OSSDMABUFFER_UNLOCK GST_OBJECT_UNLOCK
|
||||||
#define GST_OSSDMABUFFER_COND(buf) (GST_OSSDMABUFFER(buf)->cond)
|
#define GST_OSSDMABUFFER_COND(buf) (GST_OSSDMABUFFER(buf)->cond)
|
||||||
#define GST_OSSDMABUFFER_SIGNAL(buf) (g_cond_signal (GST_OSSDMABUFFER_COND (buf)))
|
#define GST_OSSDMABUFFER_SIGNAL(buf) (g_cond_signal (GST_OSSDMABUFFER_COND (buf)))
|
||||||
#define GST_OSSDMABUFFER_WAIT(buf) (g_cond_wait (GST_OSSDMABUFFER_COND (buf), GST_GET_LOCK (buf)))
|
#define GST_OSSDMABUFFER_WAIT(buf) (g_cond_wait (GST_OSSDMABUFFER_COND (buf), GST_OBJECT_GET_LOCK (buf)))
|
||||||
|
|
||||||
struct _GstOssDMABuffer {
|
struct _GstOssDMABuffer {
|
||||||
GstRingBuffer buffer;
|
GstRingBuffer buffer;
|
||||||
|
|
Loading…
Reference in a new issue