summaryrefslogtreecommitdiff
path: root/src/flufigut.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/flufigut.py')
-rwxr-xr-xsrc/flufigut.py162
1 files changed, 82 insertions, 80 deletions
diff --git a/src/flufigut.py b/src/flufigut.py
index 83ab005..a47e544 100755
--- a/src/flufigut.py
+++ b/src/flufigut.py
@@ -54,16 +54,20 @@ cf.close();
atmosphere = {}
flow = {}
machines = {}
+globals = config['globals']
+input = config['input']
+transcode = config['transcode']
+stream = config['stream']
### generate porter for all streamer/machines ###################
#
idx = 0
-for streamer in config['streamer']:
+for streamer in stream:
worker = 'streamer%i'%(idx)
port = streamer['config']['port']
found = False
- for machine in config['globals']['machines'].keys():
- if worker in config['globals']['machines'][machine]:
+ for machine in globals['machines'].keys():
+ if worker in globals['machines'][machine]:
if machine in machines:
if 'porter' in machines[machine]:
if port in machines[machine]['porter']:
@@ -101,28 +105,28 @@ for streamer in config['streamer']:
flow['input'] = {}
flow['input']['raw-input'] = {
- 'type': config['input']['source'],
- 'desc': "capture raw AV from %s" % config['input']['source'],
+ 'type': input['source'],
+ 'desc': "capture raw AV from %s" % input['source'],
'worker': 'input',
'properties': {},
}
-for property in config['input'].keys():
+for property in input.keys():
if property == 'samplerate':
- flow['input']['raw-input']['properties'][property] = config['input']['samplerate']
+ flow['input']['raw-input']['properties'][property] = input['samplerate']
elif property == 'resolution':
- flow['input']['raw-input']['properties']['width'] = config['globals']['resolutions'][config['input'][property]]['width']
- flow['input']['raw-input']['properties']['height'] = config['globals']['resolutions'][config['input'][property]]['height']
- flow['input']['raw-input']['properties']['framerate'] = config['globals']['resolutions'][config['input'][property]]['rate']
+ flow['input']['raw-input']['properties']['width'] = globals['resolutions'][input[property]]['width']
+ flow['input']['raw-input']['properties']['height'] = globals['resolutions'][input[property]]['height']
+ flow['input']['raw-input']['properties']['framerate'] = globals['resolutions'][input[property]]['rate']
elif property != 'source':
- flow['input']['raw-input']['properties'][property] = config['input'][property]
+ flow['input']['raw-input']['properties'][property] = input[property]
resolutions = [ ]
-for format in config['transcode'].keys():
- for profile in config['transcode'][format]:
- resolution = config['globals']['profiles'][profile]['video']
+for format in transcode.keys():
+ for profile in transcode[format]:
+ resolution = globals['profiles'][profile]['video']
if resolution not in resolutions:
- if config['input']['resolution'] != resolution:
- if config['globals']['resolutions'][resolution]['rate'] != config['globals']['resolutions'][config['input']['resolution']]['rate']:
+ if input['resolution'] != resolution:
+ if globals['resolutions'][resolution]['rate'] != globals['resolutions'][input['resolution']]['rate']:
print "video rate conversion is not yet supported!!!"
sys.exit(-1)
resolutions.append(resolution)
@@ -130,22 +134,22 @@ for format in config['transcode'].keys():
for resolution in resolutions:
flow['input']['resize-%s' % resolution] = {
'type': 'video-resize',
- 'desc': "resize video to %sx%s" % (config['globals']['resolutions'][resolution]['width'], config['globals']['resolutions'][resolution]['height']),
+ 'desc': "resize video to %sx%s" % (globals['resolutions'][resolution]['width'], globals['resolutions'][resolution]['height']),
'worker': 'input',
'feeder': 'raw-input:video',
'properties': {
- 'width': config['globals']['resolutions'][resolution]['width'],
- 'height': config['globals']['resolutions'][resolution]['height'],
+ 'width': globals['resolutions'][resolution]['width'],
+ 'height': globals['resolutions'][resolution]['height'],
},
}
samplerates = [ ]
-for format in config['globals']['formats'].keys():
- if 'samplerate' in config['globals']['formats'][format]:
- samplerate = config['globals']['formats'][format]['samplerate']
+for format in globals['formats'].keys():
+ if 'samplerate' in globals['formats'][format]:
+ samplerate = globals['formats'][format]['samplerate']
if samplerate not in samplerates:
- if config['input']['samplerate'] != samplerate:
+ if input['samplerate'] != samplerate:
samplerates.append(samplerate)
for samplerate in samplerates:
@@ -160,65 +164,63 @@ for samplerate in samplerates:
}
### generate encoder and muxer components #######################
-flow['encoder'] = {}
+flow['encoder_video'] = {}
+flow['encoder_audio'] = {}
flow['muxer'] = {}
-# for encoder in config['encoder']['video'].keys():
-# for resolution in config['encoder']['video'][encoder].keys():
-# if resolution == config['input']['resolution']:
-# feeder = 'raw-input:video'
-# else:
-# feeder = 'resize-%s' % resolution
-
-# flow['encoder']['encode-%s-%s' % (encoder, resolution)] = {
-# 'type': '%s-encode' % encoder,
-# 'desc': "%s encoder for %sx%s" % (encoder, config['globals']['resolutions'][resolution]['width'], config['globals']['resolutions'][resolution]['height']),
-# 'worker': 'encoder-%s' % encoder,
-# 'feeder': feeder,
-# 'properties': {
-# 'bitrate': config['encoder']['video'][encoder][resolution],
-# },
-# }
-
-# for encoder in config['encoder']['audio'].keys():
-# for audiorate in config['encoder']['audio'][encoder]:
-# if config['globals']['audiorates'][audiorate]['samplerate'] == config['input']['samplerate']:
-# feeder = 'raw-input:audio'
-# else:
-# feeder = 'resample-%s' % config['globals']['audiorates'][audiorate]['samplerate']
-
-# flow['encoder']['encode-%s-%s' % (encoder, audiorate)] = {
-# 'type': '%s-encode' % encoder,
-# 'desc': "%s encoder for %i kbit/s @ %i Hz" % (encoder, config['globals']['audiorates'][audiorate]['bitrate'], config['globals']['audiorates'][audiorate]['samplerate']),
-# 'worker': 'encoder-%s' % encoder,
-# 'feeder': feeder,
-# 'properties': {
-# 'bitrate': config['globals']['audiorates'][audiorate]['bitrate'],
-# },
-# }
-
-# for format in config['muxer'].keys():
-# muxer = config['globals']['formats'][format]['muxer']
-
-# for profile in config['muxer'][format]:
-# resolution = config['globals']['profiles'][profile]['video']
-# arate = config['globals']['profiles'][profile]['audio']
-
-# feeder_audio = 'encoder-%s-%s' % (config['globals']['formats'][format]['audio'], arate)
-# if 'video' in config['globals']['formats'][format]:
-# feeder_video = 'encoder-%s-%s' % (config['globals']['formats'][format]['video'], resolution)
-# else:
-# feeder_video = 'none'
-
-# flow['muxer']['muxer-%s-%s' % (muxer, profile)] = {
-# 'type': '%s-mux' % muxer,
-# 'desc': "%s muxer profile %s" % (format, profile),
-# 'worker': 'muxer-%s' % muxer,
-# 'feeder_audio': feeder_audio,
-# 'feeder_video': feeder_video,
-# 'properties': {},
-# }
+for format in transcode.keys():
+ for profile in transcode[format]:
+ video_encoder = 'none'
+ if 'video' in globals['formats'][format]:
+ encoder = globals['formats'][format]['video']
+ resolution = globals['profiles'][profile]['video']
+ bitrate = globals['bitrates'][encoder][resolution]
+ if resolution == input['resolution']:
+ feeder = 'raw-input:video'
+ else:
+ feeder = 'resize-%s' % resolution
+ video_encoder = 'encode-%s-%s' % (encoder, resolution)
+ flow['encoder_video'][video_encoder] = {
+ 'type': '%s-encode' % encoder,
+ 'desc': "%s encoder for %sx%s" % (encoder, globals['resolutions'][resolution]['width'], globals['resolutions'][resolution]['height']),
+ 'worker': 'encoder-%s' % encoder,
+ 'feeder': feeder,
+ 'properties': {
+ 'bitrate': bitrate,
+ },
+ }
+
+ audio_encoder = 'none'
+ if 'audio' in globals['formats'][format]:
+ encoder = globals['formats'][format]['audio']
+ bitrate = globals['profiles'][profile]['audio']
+ if 'samplerate' in globals['formats'][format]:
+ samplerate = globals['formats'][format]['samplerate']
+ feeder = 'resample-%s' % samplerate
+ else:
+ samplerate = input['samplerate']
+ feeder = 'raw-input:audio'
+ audio_encoder = 'encode-%s-%i-%i' % (encoder, bitrate, samplerate)
+ flow['encoder_audio'][audio_encoder] = {
+ 'type': '%s-encode' % encoder,
+ 'desc': "%s encoder for %i kbit/s @ %i Hz" % (encoder, bitrate, samplerate),
+ 'worker': 'encoder-%s' % encoder,
+ 'feeder': feeder,
+ 'properties': {
+ 'bitrate': bitrate,
+ },
+ }
+ muxer = globals['formats'][format]['muxer']
+ flow['muxer']['muxer-%s-%s' % (muxer, profile)] = {
+ 'type': '%s-mux' % muxer,
+ 'desc': "%s muxer profile %s" % (format, profile),
+ 'worker': 'muxer-%s' % muxer,
+ 'feeder_audio': audio_encoder,
+ 'feeder_video': video_encoder,
+ 'properties': {},
+ }
+
### generate streamer components ################################
flow['streamer'] = {}
@@ -229,7 +231,7 @@ flow['streamer'] = {}
#
env = Environment(loader=FileSystemLoader('../templates/%s/' % (sys.argv[1])), line_statement_prefix = '%%')
template = env.get_template('planet.xml')
-planet = template.render(globals=config['globals'], atmosphere=atmosphere, flow=flow)
+planet = template.render(globals=globals, atmosphere=atmosphere, flow=flow)
sys.stdout.write(planet.encode("utf8"))