diff options
Diffstat (limited to 'src/flufigut.py')
-rwxr-xr-x | src/flufigut.py | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index 953fa35..6882299 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -275,10 +275,44 @@ class Planet: self.__generate_muxer(mux_name, format, profile, globals, audio_encoder, video_encoder) # + # streams + def _generate_streams(self, streams, globals): + self.flow['repeaters'] = {} + self.flow['streamers'] = {} + pass + + # + # records + def _generate_records(self, records, globals): + self.flow['recorders'] = {} + + for _, record in records.items(): + for mux in record['muxes']: + format = record['muxes'][mux]["format"] + profile = record['muxes'][mux]["profile"] + feeder = 'mux-%s-%s-%s' % (mux, format, profile) + + comp_name = 'record-%s-%s-%s' % (mux, format, profile) + comp_desc = 'recorder for %s %s-%s' % (mux, format, profile), + + self.flow['recorders'][comp_name] = { + 'type': "recorder", + 'desc': comp_desc, + 'worker': None, + 'feeder': feeder, + 'properties': {} + } + for prop in record: + if prop != 'muxes': + self.flow['recorders'][comp_name]['properties'][prop] = record[prop] + + # # all def generate(self, desc): self._generate_inputs(desc.inputs, desc.globals) self._generate_muxes(desc.muxes, desc.inputs, desc.globals) + self._generate_streams(desc.streams, desc.globals) + self._generate_records(desc.records, desc.globals) # Main ######################################################## |