Lines Matching refs:queue
178 rtp_timer_queue_get_tail (RtpTimerQueue * queue) in rtp_timer_queue_get_tail() argument
180 return (RtpTimer *) queue->timers.tail; in rtp_timer_queue_get_tail()
184 rtp_timer_queue_set_tail (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_tail() argument
186 queue->timers.tail = (GList *) timer; in rtp_timer_queue_set_tail()
187 g_assert (queue->timers.tail->next == NULL); in rtp_timer_queue_set_tail()
191 rtp_timer_queue_get_head (RtpTimerQueue * queue) in rtp_timer_queue_get_head() argument
193 return (RtpTimer *) queue->timers.head; in rtp_timer_queue_get_head()
197 rtp_timer_queue_set_head (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_set_head() argument
199 queue->timers.head = (GList *) timer; in rtp_timer_queue_set_head()
200 g_assert (queue->timers.head->prev == NULL); in rtp_timer_queue_set_head()
204 rtp_timer_queue_insert_before (RtpTimerQueue * queue, RtpTimer * sibling, in rtp_timer_queue_insert_before() argument
207 if (sibling == rtp_timer_queue_get_head (queue)) { in rtp_timer_queue_insert_before()
208 rtp_timer_queue_set_head (queue, timer); in rtp_timer_queue_insert_before()
217 queue->timers.length++; in rtp_timer_queue_insert_before()
221 rtp_timer_queue_insert_after (RtpTimerQueue * queue, RtpTimer * sibling, in rtp_timer_queue_insert_after() argument
224 if (sibling == rtp_timer_queue_get_tail (queue)) { in rtp_timer_queue_insert_after()
225 rtp_timer_queue_set_tail (queue, timer); in rtp_timer_queue_insert_after()
234 queue->timers.length++; in rtp_timer_queue_insert_after()
238 rtp_timer_queue_insert_tail (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_insert_tail() argument
240 RtpTimer *it = rtp_timer_queue_get_tail (queue); in rtp_timer_queue_insert_tail()
258 g_queue_push_head_link (&queue->timers, (GList *) timer); in rtp_timer_queue_insert_tail()
260 rtp_timer_queue_insert_after (queue, it, timer); in rtp_timer_queue_insert_tail()
264 rtp_timer_queue_insert_head (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_insert_head() argument
266 RtpTimer *it = rtp_timer_queue_get_head (queue); in rtp_timer_queue_insert_head()
286 g_queue_push_tail_link (&queue->timers, (GList *) timer); in rtp_timer_queue_insert_head()
288 rtp_timer_queue_insert_before (queue, it, timer); in rtp_timer_queue_insert_head()
292 rtp_timer_queue_init (RtpTimerQueue * queue) in rtp_timer_queue_init() argument
294 queue->hashtable = g_hash_table_new (NULL, NULL); in rtp_timer_queue_init()
300 RtpTimerQueue *queue = RTP_TIMER_QUEUE (object); in rtp_timer_queue_finalize() local
303 while ((timer = rtp_timer_queue_pop_until (queue, GST_CLOCK_TIME_NONE))) in rtp_timer_queue_finalize()
305 g_hash_table_unref (queue->hashtable); in rtp_timer_queue_finalize()
306 g_assert (queue->timers.length == 0); in rtp_timer_queue_finalize()
362 rtp_timer_queue_find (RtpTimerQueue * queue, guint seqnum) in rtp_timer_queue_find() argument
364 return g_hash_table_lookup (queue->hashtable, GINT_TO_POINTER (seqnum)); in rtp_timer_queue_find()
374 rtp_timer_queue_peek_earliest (RtpTimerQueue * queue) in rtp_timer_queue_peek_earliest() argument
376 return rtp_timer_queue_get_head (queue); in rtp_timer_queue_peek_earliest()
404 rtp_timer_queue_insert (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_insert() argument
408 if (rtp_timer_queue_find (queue, timer->seqnum)) { in rtp_timer_queue_insert()
415 rtp_timer_queue_insert_head (queue, timer); in rtp_timer_queue_insert()
417 rtp_timer_queue_insert_tail (queue, timer); in rtp_timer_queue_insert()
419 g_hash_table_insert (queue->hashtable, in rtp_timer_queue_insert()
438 rtp_timer_queue_reschedule (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_reschedule() argument
444 if (rtp_timer_is_closer_to_head (timer, rtp_timer_queue_get_head (queue))) { in rtp_timer_queue_reschedule()
445 g_queue_unlink (&queue->timers, (GList *) timer); in rtp_timer_queue_reschedule()
446 rtp_timer_queue_insert_head (queue, timer); in rtp_timer_queue_reschedule()
454 g_queue_unlink (&queue->timers, (GList *) timer); in rtp_timer_queue_reschedule()
455 rtp_timer_queue_insert_before (queue, it, timer); in rtp_timer_queue_reschedule()
459 if (rtp_timer_is_closer_to_tail (timer, rtp_timer_queue_get_tail (queue))) { in rtp_timer_queue_reschedule()
460 g_queue_unlink (&queue->timers, (GList *) timer); in rtp_timer_queue_reschedule()
461 rtp_timer_queue_insert_tail (queue, timer); in rtp_timer_queue_reschedule()
469 g_queue_unlink (&queue->timers, (GList *) timer); in rtp_timer_queue_reschedule()
470 rtp_timer_queue_insert_after (queue, it, timer); in rtp_timer_queue_reschedule()
486 rtp_timer_queue_unschedule (RtpTimerQueue * queue, RtpTimer * timer) in rtp_timer_queue_unschedule() argument
490 g_queue_unlink (&queue->timers, (GList *) timer); in rtp_timer_queue_unschedule()
491 g_hash_table_remove (queue->hashtable, GINT_TO_POINTER (timer->seqnum)); in rtp_timer_queue_unschedule()
507 rtp_timer_queue_pop_until (RtpTimerQueue * queue, GstClockTime timeout) in rtp_timer_queue_pop_until() argument
511 timer = (RtpTimer *) g_queue_peek_head_link (&queue->timers); in rtp_timer_queue_pop_until()
516 rtp_timer_queue_unschedule (queue, timer); in rtp_timer_queue_pop_until()
532 rtp_timer_queue_remove_until (RtpTimerQueue * queue, GstClockTime timeout) in rtp_timer_queue_remove_until() argument
536 while ((timer = rtp_timer_queue_pop_until (queue, timeout))) { in rtp_timer_queue_remove_until()
551 rtp_timer_queue_remove_all (RtpTimerQueue * queue) in rtp_timer_queue_remove_all() argument
553 rtp_timer_queue_remove_until (queue, GST_CLOCK_TIME_NONE); in rtp_timer_queue_remove_all()
571 rtp_timer_queue_set_timer (RtpTimerQueue * queue, RtpTimerType type, in rtp_timer_queue_set_timer() argument
577 timer = rtp_timer_queue_find (queue, seqnum); in rtp_timer_queue_set_timer()
604 rtp_timer_queue_reschedule (queue, timer); in rtp_timer_queue_set_timer()
606 rtp_timer_queue_insert (queue, timer); in rtp_timer_queue_set_timer()
622 rtp_timer_queue_set_expected (RtpTimerQueue * queue, guint16 seqnum, in rtp_timer_queue_set_expected() argument
625 rtp_timer_queue_set_timer (queue, RTP_TIMER_EXPECTED, seqnum, timeout, in rtp_timer_queue_set_expected()
641 rtp_timer_queue_set_lost (RtpTimerQueue * queue, guint16 seqnum, in rtp_timer_queue_set_lost() argument
644 rtp_timer_queue_set_timer (queue, RTP_TIMER_LOST, seqnum, timeout, 0, in rtp_timer_queue_set_lost()
659 rtp_timer_queue_set_eos (RtpTimerQueue * queue, GstClockTime timeout, in rtp_timer_queue_set_eos() argument
662 rtp_timer_queue_set_timer (queue, RTP_TIMER_EOS, -1, timeout, 0, 0, offset); in rtp_timer_queue_set_eos()
677 rtp_timer_queue_set_deadline (RtpTimerQueue * queue, guint16 seqnum, in rtp_timer_queue_set_deadline() argument
680 rtp_timer_queue_set_timer (queue, RTP_TIMER_DEADLINE, seqnum, timeout, 0, in rtp_timer_queue_set_deadline()
696 rtp_timer_queue_update_timer (RtpTimerQueue * queue, RtpTimer * timer, in rtp_timer_queue_update_timer() argument
713 g_hash_table_remove (queue->hashtable, GINT_TO_POINTER (timer->seqnum)); in rtp_timer_queue_update_timer()
714 g_hash_table_insert (queue->hashtable, GINT_TO_POINTER (seqnum), timer); in rtp_timer_queue_update_timer()
727 rtp_timer_queue_reschedule (queue, timer); in rtp_timer_queue_update_timer()
729 rtp_timer_queue_insert (queue, timer); in rtp_timer_queue_update_timer()
739 rtp_timer_queue_length (RtpTimerQueue * queue) in rtp_timer_queue_length() argument
741 return queue->timers.length; in rtp_timer_queue_length()