video/gst-hlssink3-examples
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Sync video with playback

Browse source
This commit is contained in:
Rafael Caricio 2021-10-18 10:39:43 +02:00
parent a040c29830
commit 16d59ca2c0
Signed by: rafaelcaricio
GPG key ID: 3C86DBCE8E93C947
1 changed files with 31 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
hlssink3_server.py
View file

@ -2,7 +2,6 @@ import math
import sys import sys
import traceback import traceback
import logging import logging
from enum import Enum
from typing import Optional from typing import Optional
import gi import gi
@ -31,6 +30,8 @@ class FileHlsOrigin:
self.origin.set_property('uri', self.uri) self.origin.set_property('uri', self.uri)
self.origin.connect("pad-added", self.on_origin_pad_added) self.origin.connect("pad-added", self.on_origin_pad_added)
self.video_multi = gst_element("tee", "video_multi")
self.videoconvert = gst_element("videoconvert") self.videoconvert = gst_element("videoconvert")
self.audioconvert = gst_element("audioconvert") self.audioconvert = gst_element("audioconvert")
audio_encoder = gst_element("avenc_aac") audio_encoder = gst_element("avenc_aac")
@ -61,14 +62,22 @@ class FileHlsOrigin:
audio_queue = gst_element("queue") audio_queue = gst_element("queue")
hlssink3 = gst_element("hlssink3", "hls") hlssink3 = gst_element("hlssink3", "hls")
hlssink3.set_property("location", "segment%05d.ts") # hlssink3.set_property("playlist-type", "event")
# hlssink3.set_property("playlist-type", "vod")
hlssink3.set_property("playlist-type", None)
hlssink3.set_property("location", "part-%07d.ts")
hlssink3.set_property("playlist-location", "master.m3u8") hlssink3.set_property("playlist-location", "master.m3u8")
hlssink3.set_property("target-duration", target_duration_secs) hlssink3.set_property("target-duration", target_duration_secs)
hlssink3.set_property("playlist-length", 15) hlssink3.set_property("playlist-length", 15)
hlssink3.set_property("max-files", 16) hlssink3.set_property("max-files", 30)
hlssink3.set_property("send-keyframe-requests", False)
fakesink = gst_element("fakesink")
fakesink.set_property("sync", True)
self.pipeline.add(self.origin) self.pipeline.add(self.origin)
self.pipeline.add(self.videoconvert) self.pipeline.add(self.videoconvert)
self.pipeline.add(self.video_multi)
self.pipeline.add(self.audioconvert) self.pipeline.add(self.audioconvert)
self.pipeline.add(audio_encoder) self.pipeline.add(audio_encoder)
self.pipeline.add(video_queue) self.pipeline.add(video_queue)
@ -79,6 +88,7 @@ class FileHlsOrigin:
self.pipeline.add(h264parse) self.pipeline.add(h264parse)
self.pipeline.add(audio_queue) self.pipeline.add(audio_queue)
self.pipeline.add(hlssink3) self.pipeline.add(hlssink3)
self.pipeline.add(fakesink)
self.pipeline.link(self.origin) self.pipeline.link(self.origin)
Gst.Element.link_many( Gst.Element.link_many(
@ -94,6 +104,9 @@ class FileHlsOrigin:
audio_encoder_src.link(hls_sink) audio_encoder_src.link(hls_sink)
self.link_with_request(self.video_multi, self.videoconvert)
self.link_with_request(self.video_multi, fakesink)
def on_origin_pad_added(self, _src, new_pad): def on_origin_pad_added(self, _src, new_pad):
new_pad_caps = new_pad.get_current_caps() new_pad_caps = new_pad.get_current_caps()
new_pad_struct = new_pad_caps.get_structure(0) new_pad_struct = new_pad_caps.get_structure(0)
@ -108,15 +121,27 @@ class FileHlsOrigin:
elif new_pad_type.startswith('video/'): elif new_pad_type.startswith('video/'):
log.debug(f"Video pad added to origin element: {new_pad_type}") log.debug(f"Video pad added to origin element: {new_pad_type}")
videoconvert_sink = self.videoconvert.get_static_pad('sink') video_multi_sink = self.video_multi.get_static_pad('sink')
if videoconvert_sink.is_linked(): if video_multi_sink.is_linked():
log.warning("Already linked video contents source. Ignoring..") log.warning("Already linked video contents source. Ignoring..")
return return
new_pad.link(videoconvert_sink) new_pad.link(video_multi_sink)
else: else:
log.error(f"New unexpected pad added to origin element with type: {new_pad_type}") log.error(f"New unexpected pad added to origin element with type: {new_pad_type}")
@staticmethod
def link_with_request(src_elem, sink_elem):
# capture source pad
src_pad_templ = src_elem.get_pad_template("src_%u")
src_pad = src_elem.request_pad(src_pad_templ)
# capture sink pad
sink_pad = sink_elem.get_static_pad('sink')
# link both
src_pad.link(sink_pad)
def main(): def main():
Gst.init(None) Gst.init(None)