Gstreamer: задача элемента 'src' переходит в состояние PAUSE, когда один из элементов в конвейере добавляется динамически - PullRequest
Новая
       92

Gstreamer: задача элемента 'src' переходит в состояние PAUSE, когда один из элементов в конвейере добавляется динамически

0 голосов
/ 28 августа 2018

У меня есть следующий конвейер: 

v4l2src -> queue -> h264parse -> avdec_h264 -> identity ->
imagefreeze(added/removed dynamically) -> glupload -> glcolorconvert ->
gltransformation -> glimagesink
  1. У меня добавлен зонд для элемента identity srcpad.
  2. Исходя из введенного пользователем, я динамически добавляю или удаляю элемент imagefreeze

Вот псевдокод: 

#show live video on rendering window till no user input
#if user_input == 1:
  insert_imagefreeze  #analogous to image being displayed on rendering window
#if user_input == 2:
  delete_imagefreeze  #resume back showing live video as before
  1. Вставка imagefreeze не проблема, работает нормально. Я могу наблюдать результаты, которые я хотел бы получить с imagefreeze

  2. Однако после добавления элемента imagefreeze задача v4l2src переходит в состояние паузы. Вот информационный журнал: 

    0:03:39.608226968 [333m29510[00m      0x1561c00 [36mINFO   [00m [00m             v4l2src gstv4l2src.c:949:gst_v4l2src_create:<source>[00m sync to 0:03:39.066664476 out ts 0:03:39.375180156
0:03:39.608449406 [333m29510[00m      0x1561c00 [36mINFO   [00m [00m             basesrc gstbasesrc.c:2965:gst_base_src_loop:<source>[00m pausing after gst_pad_push() = eos
0:03:39.608561724 [333m29510[00m      0x1561c00 [36mINFO   [00m [00m                task gsttask.c:316:gst_task_func:<source:src>[00m Task going to paused.

Может кто-нибудь объяснить, почему исходный элемент конвейера переходит в состояние паузы после добавления нового элемента в конвейер.

И фрагменты из фактического кода: 

def add_delete(self):
   if ui_input_cnt = 1  #updated based on user input
        self.idsrcpad = self.identity.get_static_pad("src")
        self.in_idle_probe = False
        self.probeID = self.idsrcpad.add_probe(Gst.PadProbeType.IDLE,self.lengthen_pipeline)

   if ui_input_cnt = 2        
        self.probeID2 = self.idsrcpad.add_probe(Gst.PadProbeType.IDLE,self.shorten_pipeline)

def lengthen_pipeline(self,pad,info):
    print("entered callback")
    global pipeline

    #restrict only 1 call to this callback 
    if self.in_idle_probe == True:
        print("callback for now restricted to one call per thread")
        return Gst.PadProbeReturn.OK

    if  self.in_idle_probe == False:
        self.in_idle_probe == True

    #create image freze element
    self.ifreeze = Gst.ElementFactory.make("imagefreeze","ifreeze")
    # increment reference
    self.ifreeze.ref()
    #add imagefreze to pipeline
    pipeline.add(self.ifreeze)
    #sync image freeze state to main pipeline
    self.ifreeze.sync_state_with_parent()

    #unlink identity and upload

    #1.get sink pad of upload and srcpad of identity
    sinkpad = self.upload.get_static_pad("sink")
    srcpad = self.identity.get_static_pad("src")
    print("unlinking identit srcpad - uplaod sinkpad")
    if self.check_and_unlink(srcpad,sinkpad):
        #2.get sink pad of imagefreeze
        sinkpad = self.ifreeze.get_static_pad("sink")

        #3. link identity src pad to image freeze sinkpad
        print("linking identity srcpad - ifreeze sinkpad")
        self.check_and_link(srcpad,sinkpad)

        #4. link imagefreeze src pad to upload sink pad
        #get image freeze srcpad and sinkpad of upload
        srcpad = self.ifreeze.get_static_pad("src")
        sinkpad = self.upload.get_static_pad("sink")
        print("linking ifreeze srcpad - upload sinkpad")
        if self.check_and_link(srcpad,sinkpad):
            return Gst.PadProbeReturn.REMOVE
    else:
        print("ERORR : unlinking")
    return -1

Функции check_and_link(srcpad,sinkpad) и check_and_unlink(srcpad,sinkpad) не более чем проверяют пэды src и sink, а затем связывают и отсоединяют соответственно.

1 Ответ

0 голосов
/ 24 сентября 2018

Приемник отправляет событие EOS, когда динамическое добавление imagefreeze. Это переводит конвейер в состояние PAUSED. Однако, почему приемник получает событие EOS, до сих пор неясно и требует дальнейшего изучения. Более подробная информация о наблюдениях предоставлена ​​ здесь .

...