goto was_eos;
/* Get a unique incrementing id */
- curid = mq->counter++;
+ curid = g_atomic_int_exchange_and_add ((gint *) & mq->counter, 1);
GST_LOG_OBJECT (mq, "SingleQueue %d : about to enqueue buffer %p with id %d",
sq->id, buffer, curid);
if (sq->is_eos)
goto was_eos;
- /* Get an unique incrementing id. protected with the STREAM_LOCK, unserialized
- * events already got pushed and don't end up in the queue. */
- curid = mq->counter++;
+ /* Get an unique incrementing id. */
+ curid = g_atomic_int_exchange_and_add ((gint *) & mq->counter, 1);
item = gst_multi_queue_event_item_new ((GstMiniObject *) event, curid);
gboolean buffering;
gint percent;
- guint32 counter; /* incoming object counter, protected with STREAM_LOCK */
+ guint32 counter; /* incoming object counter, use atomic accesses */
guint32 highid; /* contains highest id of last outputted object */
GMutex * qlock; /* Global queue lock (vs object lock or individual */