Lines Matching refs:queue
27 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
30 rtp_timer_queue_set_timer (queue, RTP_TIMER_EXPECTED, 10, in GST_START_TEST()
32 timer10 = rtp_timer_queue_find (queue, 10); in GST_START_TEST()
44 rtp_timer_queue_set_timer (queue, RTP_TIMER_LOST, 0, in GST_START_TEST()
46 timer0 = rtp_timer_queue_find (queue, 0); in GST_START_TEST()
63 g_object_unref (queue); in GST_START_TEST()
70 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
73 rtp_timer_queue_set_deadline (queue, 1, -1, 0); in GST_START_TEST()
74 rtp_timer_queue_set_deadline (queue, 3, -1, 0); in GST_START_TEST()
75 rtp_timer_queue_set_deadline (queue, 2, -1, 0); in GST_START_TEST()
76 rtp_timer_queue_set_deadline (queue, 0, -1, 0); in GST_START_TEST()
78 timer = rtp_timer_queue_find (queue, 0); in GST_START_TEST()
87 timer = rtp_timer_queue_find (queue, 3); in GST_START_TEST()
96 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
106 timer = rtp_timer_queue_find (queue, 1); in GST_START_TEST()
116 g_object_unref (queue); in GST_START_TEST()
123 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
126 rtp_timer_queue_set_deadline (queue, 3, 1 * GST_SECOND, 0); in GST_START_TEST()
127 rtp_timer_queue_set_deadline (queue, 1, 2 * GST_SECOND, 0); in GST_START_TEST()
128 rtp_timer_queue_set_deadline (queue, 2, 3 * GST_SECOND, 0); in GST_START_TEST()
129 rtp_timer_queue_set_deadline (queue, 0, 4 * GST_SECOND, 0); in GST_START_TEST()
131 timer = rtp_timer_queue_find (queue, 1); in GST_START_TEST()
135 rtp_timer_queue_set_deadline (queue, 1, 1 * GST_SECOND, 0); in GST_START_TEST()
143 rtp_timer_queue_set_deadline (queue, 1, 2 * GST_SECOND, 0); in GST_START_TEST()
152 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
154 rtp_timer_queue_set_deadline (queue, 2, 4 * GST_SECOND, 0); in GST_START_TEST()
162 rtp_timer_queue_set_deadline (queue, 2, 3 * GST_SECOND, 0); in GST_START_TEST()
171 rtp_timer_queue_set_deadline (queue, 2, 2 * GST_SECOND, 0); in GST_START_TEST()
180 rtp_timer_queue_set_deadline (queue, 2, 3 * GST_SECOND, 0); in GST_START_TEST()
189 rtp_timer_queue_set_deadline (queue, 2, GST_SECOND + GST_SECOND / 2, 0); in GST_START_TEST()
198 rtp_timer_queue_set_deadline (queue, 2, 3 * GST_SECOND, 0); in GST_START_TEST()
206 g_object_unref (queue); in GST_START_TEST()
213 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
216 rtp_timer_queue_set_deadline (queue, 2, 2 * GST_SECOND, 0); in GST_START_TEST()
217 rtp_timer_queue_set_deadline (queue, 1, 1 * GST_SECOND, 0); in GST_START_TEST()
218 rtp_timer_queue_set_deadline (queue, 0, -1, 0); in GST_START_TEST()
220 timer = rtp_timer_queue_pop_until (queue, 1 * GST_SECOND); in GST_START_TEST()
225 timer = rtp_timer_queue_pop_until (queue, 1 * GST_SECOND); in GST_START_TEST()
230 timer = rtp_timer_queue_pop_until (queue, 1 * GST_SECOND); in GST_START_TEST()
233 g_object_unref (queue); in GST_START_TEST()
240 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
243 rtp_timer_queue_set_deadline (queue, 2, 2 * GST_SECOND, 0); in GST_START_TEST()
245 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
248 rtp_timer_queue_update_timer (queue, timer, 3, 3 * GST_SECOND, 0, 0, FALSE); in GST_START_TEST()
250 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
252 timer = rtp_timer_queue_find (queue, 3); in GST_START_TEST()
255 fail_unless_equals_int (1, rtp_timer_queue_length (queue)); in GST_START_TEST()
257 g_object_unref (queue); in GST_START_TEST()
264 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
267 rtp_timer_queue_set_deadline (queue, 2, 2 * GST_SECOND, 0); in GST_START_TEST()
269 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
274 rtp_timer_queue_insert (queue, timer); in GST_START_TEST()
276 fail_unless_equals_int (2, rtp_timer_queue_length (queue)); in GST_START_TEST()
278 g_object_unref (queue); in GST_START_TEST()
285 RtpTimerQueue *queue = rtp_timer_queue_new (); in GST_START_TEST() local
288 rtp_timer_queue_set_timer (queue, RTP_TIMER_EXPECTED, 2, 2 * GST_SECOND, in GST_START_TEST()
291 timer = rtp_timer_queue_find (queue, 2); in GST_START_TEST()
297 rtp_timer_queue_update_timer (queue, timer, 2, 3 * GST_SECOND, in GST_START_TEST()
303 g_object_unref (queue); in GST_START_TEST()