summaryrefslogtreecommitdiffstats
path: root/gst
diff options
context:
space:
mode:
Diffstat (limited to 'gst')
-rw-r--r--gst/debug/breakmydata.c20
-rw-r--r--gst/debug/gstnavseek.c16
-rw-r--r--gst/debug/progressreport.c28
-rw-r--r--gst/debug/testplugin.c8
-rw-r--r--gst/matroska/matroska-demux.c20
5 files changed, 46 insertions, 46 deletions
diff --git a/gst/debug/breakmydata.c b/gst/debug/breakmydata.c
index f9e3be2a..724ac4fd 100644
--- a/gst/debug/breakmydata.c
+++ b/gst/debug/breakmydata.c
@@ -163,7 +163,7 @@ gst_break_my_data_set_property (GObject * object, guint prop_id,
{
GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
- GST_LOCK (bmd);
+ GST_OBJECT_LOCK (bmd);
switch (prop_id) {
case ARG_SEED:
@@ -183,7 +183,7 @@ gst_break_my_data_set_property (GObject * object, guint prop_id,
break;
}
- GST_UNLOCK (bmd);
+ GST_OBJECT_UNLOCK (bmd);
}
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);
- GST_LOCK (bmd);
+ GST_OBJECT_LOCK (bmd);
switch (prop_id) {
case ARG_SEED:
@@ -212,7 +212,7 @@ gst_break_my_data_get_property (GObject * object, guint prop_id, GValue * value,
break;
}
- GST_UNLOCK (bmd);
+ GST_OBJECT_UNLOCK (bmd);
}
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);
- GST_LOCK (bmd);
+ GST_OBJECT_LOCK (bmd);
if (bmd->skipped < bmd->skip) {
i = bmd->skip - bmd->skipped;
@@ -256,7 +256,7 @@ gst_break_my_data_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
/* don't overflow */
bmd->skipped += MIN (G_MAXUINT - bmd->skipped, GST_BUFFER_SIZE (buf));
- GST_UNLOCK (bmd);
+ GST_OBJECT_UNLOCK (bmd);
return GST_FLOW_OK;
}
@@ -266,10 +266,10 @@ gst_break_my_data_start (GstBaseTransform * 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->skipped = 0;
- GST_UNLOCK (bmd);
+ GST_OBJECT_UNLOCK (bmd);
return TRUE;
}
@@ -279,10 +279,10 @@ gst_break_my_data_stop (GstBaseTransform * trans)
{
GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
- GST_LOCK (bmd);
+ GST_OBJECT_LOCK (bmd);
g_rand_free (bmd->rand);
bmd->rand = NULL;
- GST_UNLOCK (bmd);
+ GST_OBJECT_UNLOCK (bmd);
return TRUE;
}
diff --git a/gst/debug/gstnavseek.c b/gst/debug/gstnavseek.c
index fc1e7430..ac642cda 100644
--- a/gst/debug/gstnavseek.c
+++ b/gst/debug/gstnavseek.c
@@ -254,9 +254,9 @@ gst_navseek_set_property (GObject * object, guint prop_id,
switch (prop_id) {
case ARG_SEEKOFFSET:
- GST_LOCK (navseek);
+ GST_OBJECT_LOCK (navseek);
navseek->seek_offset = g_value_get_double (value);
- GST_UNLOCK (navseek);
+ GST_OBJECT_UNLOCK (navseek);
break;
default:
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) {
case ARG_SEEKOFFSET:
- GST_LOCK (navseek);
+ GST_OBJECT_LOCK (navseek);
g_value_set_double (value, navseek->seek_offset);
- GST_UNLOCK (navseek);
+ GST_OBJECT_UNLOCK (navseek);
break;
default:
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)) {
case GST_EVENT_EOS:
- GST_LOCK (navseek);
+ GST_OBJECT_LOCK (navseek);
if (navseek->loop)
gst_navseek_segseek (navseek);
- GST_UNLOCK (navseek);
+ GST_OBJECT_UNLOCK (navseek);
break;
default:
break;
@@ -305,7 +305,7 @@ gst_navseek_transform_ip (GstBaseTransform * basetrans, GstBuffer * buf)
{
GstNavSeek *navseek = GST_NAVSEEK (basetrans);
- GST_LOCK (navseek);
+ GST_OBJECT_LOCK (navseek);
if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
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;
}
diff --git a/gst/debug/progressreport.c b/gst/debug/progressreport.c
index d60579b2..09e015c7 100644
--- a/gst/debug/progressreport.c
+++ b/gst/debug/progressreport.c
@@ -167,7 +167,7 @@ gst_progress_report_report (GstProgressReport * filter, GTimeVal cur_time)
gint hh, mm, ss, i;
glong run_time;
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
run_time = cur_time.tv_sec - filter->start_time.tv_sec;
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_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
gst_object_unref (peer_pad);
}
@@ -285,16 +285,16 @@ gst_progress_report_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
filter = GST_PROGRESS_REPORT (trans);
/* Check if update_freq seconds have passed since the last update */
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
need_update =
((cur_time.tv_sec - filter->last_report.tv_sec) >= filter->update_freq);
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
if (need_update) {
gst_progress_report_report (filter, cur_time);
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
filter->last_report = cur_time;
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
}
return GST_FLOW_OK;
@@ -330,14 +330,14 @@ gst_progress_report_set_property (GObject * object, guint prop_id,
switch (prop_id) {
case ARG_UPDATE_FREQ:
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
filter->update_freq = g_value_get_int (value);
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
break;
case ARG_SILENT:
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
filter->silent = g_value_get_boolean (value);
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
break;
default:
break;
@@ -354,14 +354,14 @@ gst_progress_report_get_property (GObject * object, guint prop_id,
switch (prop_id) {
case ARG_UPDATE_FREQ:
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
g_value_set_int (value, filter->update_freq);
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
break;
case ARG_SILENT:
- GST_LOCK (filter);
+ GST_OBJECT_LOCK (filter);
g_value_set_boolean (value, filter->silent);
- GST_UNLOCK (filter);
+ GST_OBJECT_UNLOCK (filter);
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
diff --git a/gst/debug/testplugin.c b/gst/debug/testplugin.c
index e5ad0db1..d176e09c 100644
--- a/gst/debug/testplugin.c
+++ b/gst/debug/testplugin.c
@@ -263,9 +263,9 @@ gst_test_set_property (GObject * object, guint prop_id,
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
} else {
/* expected values */
- GST_LOCK (test);
+ GST_OBJECT_LOCK (test);
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;
}
- GST_LOCK (test);
+ GST_OBJECT_LOCK (test);
if (prop_id % 2) {
/* real values */
@@ -291,7 +291,7 @@ gst_test_get_property (GObject * object, guint prop_id, GValue * value,
g_value_copy (&test->values[id], value);
}
- GST_UNLOCK (test);
+ GST_OBJECT_UNLOCK (test);
}
gboolean
diff --git a/gst/matroska/matroska-demux.c b/gst/matroska/matroska-demux.c
index 8200ab27..0b03e31e 100644
--- a/gst/matroska/matroska-demux.c
+++ b/gst/matroska/matroska-demux.c
@@ -954,9 +954,9 @@ gst_matroska_demux_handle_src_query (GstPad * pad, GstQuery * query)
break;
}
- GST_LOCK (demux);
+ GST_OBJECT_LOCK (demux);
gst_query_set_position (query, GST_FORMAT_TIME, demux->pos);
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
res = TRUE;
break;
@@ -972,9 +972,9 @@ gst_matroska_demux_handle_src_query (GstPad * pad, GstQuery * query)
break;
}
- GST_LOCK (demux);
+ GST_OBJECT_LOCK (demux);
gst_query_set_duration (query, GST_FORMAT_TIME, demux->duration);
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
res = TRUE;
break;
@@ -1079,14 +1079,14 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
/* check sanity before we start flushing and all that */
if (cur_type == GST_SEEK_TYPE_SET) {
- GST_LOCK (demux);
+ GST_OBJECT_LOCK (demux);
if (!gst_matroskademux_do_index_seek (demux, cur)) {
GST_DEBUG ("No matching seek entry in index");
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
return FALSE;
}
GST_DEBUG ("Seek position looks sane");
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
}
flush = !!(flags & GST_SEEK_FLAG_FLUSH);
@@ -1104,7 +1104,7 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
* forever. */
GST_STREAM_LOCK (demux->sinkpad);
- GST_LOCK (demux);
+ GST_OBJECT_LOCK (demux);
/* if nothing configured, play complete file */
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,
GST_FORMAT_TIME, entry->time, demux->segment_stop, entry->time);
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
GST_DEBUG ("Stopping flush");
if (flush) {
@@ -1197,7 +1197,7 @@ seek_error:
/* 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? */
GST_DEBUG ("Got a seek error");
- GST_UNLOCK (demux);
+ GST_OBJECT_UNLOCK (demux);
GST_STREAM_UNLOCK (demux->sinkpad);
return FALSE;
generated by cgit (git 2.34.1) at 2025-06-14 22:51:46 +0000