Lines Matching refs:mpad
166 GstMplexPad *mpad = (GstMplexPad *) walk->data; in gst_mplex_finalize() local
168 if (mpad->pad) in gst_mplex_finalize()
169 gst_object_unref (mpad->pad); in gst_mplex_finalize()
170 mpad->pad = NULL; in gst_mplex_finalize()
217 GstMplexPad *mpad; in gst_mplex_reset() local
219 mpad = (GstMplexPad *) walk->data; in gst_mplex_reset()
221 mpad->needed = 0; in gst_mplex_reset()
222 mpad->eos = FALSE; in gst_mplex_reset()
223 gst_adapter_clear (mpad->adapter); in gst_mplex_reset()
224 if (mpad->bs) { in gst_mplex_reset()
225 delete mpad->bs; in gst_mplex_reset()
227 mpad->bs = NULL; in gst_mplex_reset()
230 if (!mpad->pad) { in gst_mplex_reset()
231 g_cond_clear (&mpad->cond); in gst_mplex_reset()
232 g_object_unref (mpad->adapter); in gst_mplex_reset()
233 g_free (mpad); in gst_mplex_reset()
235 nlist = g_slist_append (nlist, mpad); in gst_mplex_reset()
274 GstMplexPad *mpad; in gst_mplex_setcaps() local
351 mpad = (GstMplexPad *) gst_pad_get_element_private (pad); in gst_mplex_setcaps()
352 g_return_val_if_fail (mpad, FALSE); in gst_mplex_setcaps()
353 inputstream = new GstMplexIBitStream (mpad); in gst_mplex_setcaps()
354 mpad->bs = inputstream; in gst_mplex_setcaps()
400 GstMplexPad *mpad; in gst_mplex_loop() local
402 mpad = (GstMplexPad *) walk->data; in gst_mplex_loop()
403 mpad->bs->ReadBuffer (); in gst_mplex_loop()
455 GstMplexPad *mpad; in gst_mplex_sink_event() local
459 mpad = (GstMplexPad *) gst_pad_get_element_private (sinkpad); in gst_mplex_sink_event()
460 g_return_val_if_fail (mpad, FALSE); in gst_mplex_sink_event()
470 GST_MPLEX_SIGNAL (mplex, mpad); in gst_mplex_sink_event()
480 gst_adapter_clear (mpad->adapter); in gst_mplex_sink_event()
491 mpad->eos = TRUE; in gst_mplex_sink_event()
492 GST_MPLEX_SIGNAL (mplex, mpad); in gst_mplex_sink_event()
514 while (mplex->srcresult == GST_FLOW_OK && !mpad->needed) in gst_mplex_sink_event()
515 GST_MPLEX_WAIT (mplex, mpad); in gst_mplex_sink_event()
546 GstMplexPad *mpad; in gst_mplex_chain() local
549 mpad = (GstMplexPad *) gst_pad_get_element_private (sinkpad); in gst_mplex_chain()
550 g_return_val_if_fail (mpad, GST_FLOW_ERROR); in gst_mplex_chain()
553 if (G_UNLIKELY (!mpad->bs)) { in gst_mplex_chain()
563 if (G_UNLIKELY (mpad->eos)) in gst_mplex_chain()
569 gst_adapter_push (mpad->adapter, buffer); in gst_mplex_chain()
571 while (gst_adapter_available (mpad->adapter) >= mpad->needed) { in gst_mplex_chain()
572 GST_MPLEX_SIGNAL (mplex, mpad); in gst_mplex_chain()
573 GST_MPLEX_WAIT (mplex, mpad); in gst_mplex_chain()
578 if (G_UNLIKELY (mpad->eos)) in gst_mplex_chain()
617 GstMplexPad *mpad; in gst_mplex_request_new_pad() local
633 mpad = g_new0 (GstMplexPad, 1); in gst_mplex_request_new_pad()
634 mpad->adapter = gst_adapter_new (); in gst_mplex_request_new_pad()
635 g_cond_init (&mpad->cond); in gst_mplex_request_new_pad()
637 mpad->pad = newpad; in gst_mplex_request_new_pad()
641 gst_pad_set_element_private (newpad, mpad); in gst_mplex_request_new_pad()
643 mplex->pads = g_slist_append (mplex->pads, mpad); in gst_mplex_request_new_pad()
652 GstMplexPad *mpad; in gst_mplex_release_pad() local
655 mpad = (GstMplexPad *) gst_pad_get_element_private (pad); in gst_mplex_release_pad()
656 g_return_if_fail (mpad); in gst_mplex_release_pad()
662 mpad->eos = TRUE; in gst_mplex_release_pad()
663 g_assert (mpad->pad == pad); in gst_mplex_release_pad()
664 mpad->pad = NULL; in gst_mplex_release_pad()
666 GST_MPLEX_SIGNAL (mplex, mpad); in gst_mplex_release_pad()