98   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) object;  in gst_stream_combiner_finalize()  local
100   g_mutex_clear (&stream_combiner->lock);  in gst_stream_combiner_finalize()
108   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;  in gst_stream_combiner_chain()  local
112   return gst_pad_push (stream_combiner->srcpad, buf);  in gst_stream_combiner_chain()
132   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;  in gst_stream_combiner_sink_event()  local
140       STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_sink_event()
144         stream_combiner->draining_encoder = TRUE;  in gst_stream_combiner_sink_event()
146       STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_sink_event()
149       STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_sink_event()
150       if (stream_combiner->draining_encoder) {  in gst_stream_combiner_sink_event()
154       STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_sink_event()
157       STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_sink_event()
158       if (stream_combiner->draining_encoder) {  in gst_stream_combiner_sink_event()
160         GST_INFO_OBJECT (stream_combiner, "Done draining the encoder.");  in gst_stream_combiner_sink_event()
162       stream_combiner->draining_encoder = FALSE;  in gst_stream_combiner_sink_event()
163       STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_sink_event()
166       STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_sink_event()
167       if (stream_combiner->draining_encoder) {  in gst_stream_combiner_sink_event()
168         STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_sink_event()
169         GST_INFO_OBJECT (stream_combiner, "Discarding EOS as draining encoder");  in gst_stream_combiner_sink_event()
174       if (!_all_sink_pads_eos (stream_combiner)) {  in gst_stream_combiner_sink_event()
178         GST_DEBUG_OBJECT (stream_combiner, "All sink pads eos, pushing eos");  in gst_stream_combiner_sink_event()
180       STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_sink_event()
191     return gst_pad_push_event (stream_combiner->srcpad, event);  in gst_stream_combiner_sink_event()
199   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;  in gst_stream_combiner_sink_query()  local
201   return gst_pad_peer_query (stream_combiner->srcpad, query);  in gst_stream_combiner_sink_query()
208   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;  in gst_stream_combiner_src_event()  local
215   STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_src_event()
216   if (stream_combiner->current)  in gst_stream_combiner_src_event()
217     sinkpad = stream_combiner->current;  in gst_stream_combiner_src_event()
218   else if (stream_combiner->sinkpads)  in gst_stream_combiner_src_event()
219     sinkpad = (GstPad *) stream_combiner->sinkpads->data;  in gst_stream_combiner_src_event()
220   STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_src_event()
233   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) parent;  in gst_stream_combiner_src_query()  local
242       STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_src_query()
243       if (stream_combiner->current)  in gst_stream_combiner_src_query()
244         sinkpad = stream_combiner->current;  in gst_stream_combiner_src_query()
245       else if (stream_combiner->sinkpads)  in gst_stream_combiner_src_query()
246         sinkpad = (GstPad *) stream_combiner->sinkpads->data;  in gst_stream_combiner_src_query()
247       STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_src_query()
258 gst_stream_combiner_init (GstStreamCombiner * stream_combiner)  in gst_stream_combiner_init()  argument
260   stream_combiner->srcpad =  in gst_stream_combiner_init()
262   gst_pad_set_event_function (stream_combiner->srcpad,  in gst_stream_combiner_init()
264   gst_pad_set_query_function (stream_combiner->srcpad,  in gst_stream_combiner_init()
266   gst_element_add_pad (GST_ELEMENT (stream_combiner), stream_combiner->srcpad);  in gst_stream_combiner_init()
268   g_mutex_init (&stream_combiner->lock);  in gst_stream_combiner_init()
275   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) element;  in gst_stream_combiner_request_new_pad()  local
292   STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_request_new_pad()
293   stream_combiner->sinkpads =  in gst_stream_combiner_request_new_pad()
294       g_list_append (stream_combiner->sinkpads, sinkpad);  in gst_stream_combiner_request_new_pad()
297   stream_combiner->cookie++;  in gst_stream_combiner_request_new_pad()
298   STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_request_new_pad()
308   GstStreamCombiner *stream_combiner = (GstStreamCombiner *) element;  in gst_stream_combiner_release_pad()  local
313   STREAMS_LOCK (stream_combiner);  in gst_stream_combiner_release_pad()
314   tmp = g_list_find (stream_combiner->sinkpads, pad);  in gst_stream_combiner_release_pad()
318     stream_combiner->sinkpads =  in gst_stream_combiner_release_pad()
319         g_list_delete_link (stream_combiner->sinkpads, tmp);  in gst_stream_combiner_release_pad()
320     stream_combiner->cookie++;  in gst_stream_combiner_release_pad()
322     if (pad == stream_combiner->current) {  in gst_stream_combiner_release_pad()
325       stream_combiner->current = NULL;  in gst_stream_combiner_release_pad()
330   STREAMS_UNLOCK (stream_combiner);  in gst_stream_combiner_release_pad()