summaryrefslogtreecommitdiff
path: root/gamle_frederiksberg
diff options
context:
space:
mode:
authorpaul <paul@web>2023-01-09 21:13:22 +0100
committerIkiWiki <ikiwiki.info>2023-01-09 21:13:22 +0100
commit459e185d1b74ee548a1f6d7b93d95fa9e85d284c (patch)
tree2b06192579f461c0c7219a7b62e8874ed0d9dad0 /gamle_frederiksberg
parent52c802e7afdf3f05857e1a5e62d1d64e54d2af51 (diff)
Diffstat (limited to 'gamle_frederiksberg')
0 files changed, 0 insertions, 0 deletions
generated by cgit v1.2.3 (git 2.46.0) at 2025-07-20 21:32:57 +0000
opt">.zorder = 1
  • self.width = 0
  • self.height = 0
  • class VideoMix(object):
  • log = logging.getLogger('VideoMix')
  • def __init__(self):
  • self.caps = Config.get('mix', 'videocaps')
  • self.names = Config.getlist('mix', 'sources')
  • self.log.info('Configuring Mixer for %u Sources', len(self.names))
  • pipeline = """
  • compositor name=mix !
  • {caps} !
  • identity name=sig !
  • queue !
  • tee name=tee
  • intervideosrc channel=video_background !
  • {caps} !
  • mix.
  • tee. ! queue ! intervideosink channel=video_mix_out
  • """.format(
  • caps=self.caps
  • )
  • if Config.getboolean('previews', 'enabled'):
  • pipeline += """
  • tee. ! queue ! intervideosink channel=video_mix_preview
  • """
  • if Config.getboolean('stream-blanker', 'enabled'):
  • pipeline += """
  • tee. ! queue ! intervideosink channel=video_mix_streamblanker
  • """
  • for idx, name in enumerate(self.names):
  • pipeline += """
  • intervideosrc channel=video_{name}_mixer !
  • {caps} !
  • mix.
  • """.format(
  • name=name,
  • caps=self.caps,
  • idx=idx
  • )
  • self.log.debug('Creating Mixing-Pipeline:\n%s', pipeline)
  • self.mixingPipeline = Gst.parse_launch(pipeline)
  • self.mixingPipeline.use_clock(Clock)
  • self.log.debug('Binding Error & End-of-Stream-Signal on Mixing-Pipeline')
  • self.mixingPipeline.bus.add_signal_watch()
  • self.mixingPipeline.bus.connect("message::eos", self.on_eos)
  • self.mixingPipeline.bus.connect("message::error", self.on_error)
  • self.log.debug('Binding Handoff-Handler for Synchronus mixer manipulation')
  • sig = self.mixingPipeline.get_by_name('sig')
  • sig.connect('handoff', self.on_handoff)
  • self.padStateDirty = False
  • self.padState = list()
  • for idx, name in enumerate(self.names):
  • self.padState.append(PadState())
  • self.log.debug('Initializing Mixer-State')
  • self.compositeMode = CompositeModes.fullscreen
  • self.sourceA = 0
  • self.sourceB = 1
  • self.recalculateMixerState()
  • self.applyMixerState()
  • bgMixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_0')
  • bgMixerpad.set_property('zorder', 0)
  • self.log.debug('Launching Mixing-Pipeline')
  • self.mixingPipeline.set_state(Gst.State.PLAYING)
  • def getInputVideoSize(self):
  • caps = Gst.Caps.from_string(self.caps)
  • struct = caps.get_structure(0)
  • _, width = struct.get_int('width')
  • _, height = struct.get_int('height')
  • return width, height
  • def recalculateMixerState(self):
  • if self.compositeMode == CompositeModes.fullscreen:
  • self.recalculateMixerStateFullscreen()
  • elif self.compositeMode == CompositeModes.side_by_side_equal:
  • self.recalculateMixerStateSideBySideEqual()
  • elif self.compositeMode == CompositeModes.side_by_side_preview:
  • self.recalculateMixerStateSideBySidePreview()
  • elif self.compositeMode == CompositeModes.picture_in_picture:
  • self.recalculateMixerStatePictureInPicture()
  • self.log.debug('Marking Pad-State as Dirty')
  • self.padStateDirty = True
  • def recalculateMixerStateFullscreen(self):
  • self.log.info('Updating Mixer-State for Fullscreen-Composition')
  • for idx, name in enumerate(self.names):
  • pad = self.padState[idx]
  • pad.reset()
  • pad.alpha = float(idx == self.sourceA)
  • def recalculateMixerStateSideBySideEqual(self):
  • self.log.info('Updating Mixer-State for Side-by-side-Equal-Composition')
  • width, height = self.getInputVideoSize()
  • self.log.debug('Video-Size parsed as %ux%u', width, height)
  • try:
  • gutter = Config.getint('side-by-side-equal', 'gutter')
  • self.log.debug('Gutter configured to %u', gutter)
  • except:
  • gutter = int(width / 100)
  • self.log.debug('Gutter calculated to %u', gutter)
  • targetWidth = int((width - gutter) / 2)
  • targetHeight = int(targetWidth / width * height)
  • try:
  • y = Config.getint('side-by-side-equal', 'ypos')
  • self.log.debug('Y-Pos configured to %u', y)
  • except:
  • y = (height - targetHeight) / 2
  • self.log.debug('Y-Pos calculated to %u', y)
  • xa = 0
  • xb = width - targetWidth
  • for idx, name in enumerate(self.names):
  • pad = self.padState[idx]
  • pad.reset()
  • pad.ypos = y
  • pad.width = targetWidth
  • pad.height = targetHeight
  • if idx == self.sourceA:
  • pad.xpos = xa
  • pad.zorder = 1
  • elif idx == self.sourceB:
  • pad.xpos = xb
  • pad.zorder = 2
  • else:
  • pad.alpha = 0
  • def recalculateMixerStateSideBySidePreview(self):
  • self.log.info('Updating Mixer-State for Side-by-side-Preview-Composition')
  • width, height = self.getInputVideoSize()
  • self.log.debug('Video-Size parsed as %ux%u', width, height)
  • try:
  • asize = [int(i) for i in Config.get('side-by-side-preview', 'asize').split('x', 1)]
  • self.log.debug('A-Video-Size configured to %ux%u', asize[0], asize[1])
  • except:
  • asize = [
  • int(width / 1.25), # 80%
  • int(height / 1.25) # 80%
  • ]
  • self.log.debug('A-Video-Size calculated to %ux%u', asize[0], asize[1])
  • try:
  • apos = [int(i) for i in Config.get('side-by-side-preview', 'apos').split('/', 1)]
  • self.log.debug('B-Video-Position configured to %u/%u', apos[0], apos[1])
  • except:
  • apos = [
  • int(width / 100), # 1%
  • int(width / 100) # 1%
  • ]
  • self.log.debug('B-Video-Position calculated to %u/%u', apos[0], apos[1])
  • try:
  • bsize = [int(i) for i in Config.get('side-by-side-preview', 'bsize').split('x', 1)]