summaryrefslogtreecommitdiff
path: root/example-scripts/ffmpeg/source-testvideo-as-cam2.sh
diff options
context:
space:
mode:
authorMaZderMind <git@mazdermind.de>2016-08-05 16:52:30 +0200
committerMaZderMind <git@mazdermind.de>2016-08-05 16:52:30 +0200
commit01adc30f691c2497d790d5d3cf97c7d96a7f705b (patch)
treeccd2673de4f27c0c21ee2a381b70a717bb989a4b /example-scripts/ffmpeg/source-testvideo-as-cam2.sh
parentc85ac490eb984a24c79178ea8fd8d310b24de6eb (diff)
moves close-button to the right with a space in between to avoid clicking it, fixes #79
Diffstat (limited to 'example-scripts/ffmpeg/source-testvideo-as-cam2.sh')
0 files changed, 0 insertions, 0 deletions
generated by cgit v1.2.3 (git 2.46.0) at 2025-09-03 23:02:54 +0000
class="hl opt">, videocaps):
  • # make video soure part of pipeline
  • video_device = "device={}".format(args.video_dev) \
  • if args.video_dev else ""
  • monitor = """
  • tee name=t !
  • queue !
  • videoconvert !
  • fpsdisplaysink sync=false
  • t. ! queue !
  • """ if args.monitor else ""
  • if args.video_source == 'dv':
  • video_src = """
  • dv1394src name=videosrc {video_device} !
  • dvdemux name=demux !
  • queue !
  • dvdec !
  • {monitor}
  • deinterlace mode=1 !
  • videoconvert !
  • videorate !
  • videoscale !
  • """
  • elif args.video_source == 'hdv':
  • video_src = """
  • hdv1394src {video_device} do-timestamp=true name=videosrc !
  • tsdemux name=demux!
  • queue !
  • decodebin !
  • {monitor}
  • deinterlace mode=1 !
  • videorate !
  • videoscale !
  • videoconvert !
  • """
  • elif args.video_source == 'hdmi2usb':
  • # https://hdmi2usb.tv
  • # Note: this code works with 720p
  • video_src = """
  • v4l2src {video_device} name=videosrc !
  • queue !
  • image/jpeg,width=1280,height=720 !
  • jpegdec !
  • {monitor}
  • videoconvert !
  • videorate !
  • """
  • elif args.video_source == 'ximage':
  • video_src = """
  • ximagesrc name=videosrc
  • use-damage=false !
  • {monitor}
  • videoconvert !
  • videorate !
  • videoscale !
  • """
  • # startx=0 starty=0 endx=1919 endy=1079 !
  • elif args.video_source == 'blackmagichdmi':
  • video_src = """
  • decklinkvideosrc mode=17 connection=2 !
  • {monitor}
  • videoconvert !
  • videorate !
  • videoscale !
  • """
  • elif args.video_source == 'test':
  • video_src = """
  • videotestsrc name=videosrc
  • pattern=ball
  • foreground-color=0x00ff0000 background-color=0x00440000 !
  • {monitor}
  • """
  • video_src = video_src.format(video_device=video_device, monitor=monitor)
  • video_src += videocaps + "!\n"
  • return video_src
  • def mk_audio_src(args, audiocaps):
  • audio_device = "device={}".format(args.audio_dev) \
  • if args.audio_dev else ""
  • if args.audio_source in ['dv', 'hdv']:
  • # this only works if video is from DV also.
  • # or some gst source that gets demux ed
  • audio_src = """
  • demux. !
  • audioconvert !
  • """
  • elif args.audio_source == 'pulse':
  • audio_src = """
  • pulsesrc {audio_device} name=audiosrc !
  • """.format(audio_device=audio_device)
  • elif args.audio_source == 'alsa':
  • audio_src = """
  • alsasrc {audio_device} name=audiosrc !
  • """.format(audio_device=audio_device)
  • elif args.audio_source == 'blackmagichdmi':
  • audio_src = """
  • decklinkaudiosrc !
  • """
  • elif args.audio_source == 'test':
  • audio_src = """
  • audiotestsrc name=audiosrc freq=330 !
  • """
  • audio_src += audiocaps + "!\n"
  • return audio_src
  • def mk_mux(args):
  • mux = """
  • mux.
  • matroskamux name=mux !
  • """
  • return mux
  • def mk_client(args):
  • core_ip = socket.gethostbyname(args.host)
  • client = """
  • tcpclientsink host={host} port={port}
  • """.format(host=core_ip, port=args.port)
  • return client
  • def mk_pipeline(args, server_caps):
  • video_src = mk_video_src(args, server_caps['videocaps'])
  • audio_src = mk_audio_src(args, server_caps['audiocaps'])
  • mux = mk_mux(args)
  • client = mk_client(args)
  • pipeline = video_src + "mux.\n" + audio_src + mux + client
  • # remove blank lines to make it more human readable
  • pipeline = pipeline.replace("\n\n", "\n")
  • return pipeline
  • def get_server_caps():
  • # fetch config from server
  • server_config = Connection.fetchServerConfig()
  • server_caps = {'videocaps': server_config['mix']['videocaps'],
  • 'audiocaps': server_config['mix']['audiocaps']}
  • return server_caps
  • def run_pipeline(pipeline, args):
  • core_ip = socket.gethostbyname(args.host)
  • clock = GstNet.NetClientClock.new('voctocore', core_ip, 9998, 0)
  • print('obtained NetClientClock from host', clock)
  • print('waiting for NetClientClock to sync…')
  • clock.wait_for_sync(Gst.CLOCK_TIME_NONE)
  • print('starting pipeline')
  • senderPipeline = Gst.parse_launch(pipeline)
  • senderPipeline.use_clock(clock)
  • src = senderPipeline.get_by_name('src')
  • def on_eos(bus, message):
  • print('Received EOS-Signal')
  • sys.exit(1)
  • def on_error(bus, message):
  • print('Received Error-Signal')
  • (error, debug) = message.parse_error()
  • print('Error-Details: #%u: %s' % (error.code, debug))
  • sys.exit(1)
  • # Binding End-of-Stream-Signal on Source-Pipeline
  • senderPipeline.bus.add_signal_watch()
  • senderPipeline.bus.connect("message::eos", on_eos)
  • senderPipeline.bus.connect("message::error", on_error)
  • print("playing")
  • senderPipeline.set_state(Gst.State.PLAYING)
  • mainloop = GObject.MainLoop()
  • try:
  • mainloop.run()
  • except KeyboardInterrupt:
  • print('Terminated via Ctrl-C')
  • print('Shutting down...')
  • senderPipeline.set_state(Gst.State.NULL)
  • print('Done.')
  • return
  • def get_args():
  • parser = argparse.ArgumentParser(
  • description='''Vocto-ingest Client with Net-time support.
  • Gst caps are retrieved from the server.
  • Run without parameters: send test av to localhost:10000
  • '''
  • )
  • parser.add_argument('-v', '--verbose', action='count', default=0,
  • help="Also print INFO and DEBUG messages.")
  • parser.add_argument('--video-source', action='store',
  • choices=['dv', 'hdv', 'hdmi2usb',
  • 'blackmagichdmi', 'ximage', 'test'],
  • default='test',
  • help="Where to get video from")
  • parser.add_argument('--video-dev', action='store',
  • help="video device")
  • parser.add_argument('--audio-source', action='store',
  • choices=['dv', 'alsa', 'pulse',