diff options
Diffstat (limited to 'src')
| -rwxr-xr-x | src/flufigut.py | 28 | ||||
| -rwxr-xr-x | src/update.sh | 2 |
2 files changed, 29 insertions, 1 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index 2372fc8..2caeae5 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -62,6 +62,7 @@ globals = config['globals'] input = config['input'] mux = config['mux'] stream = config['stream'] +record = config['record'] if output_format == 'flumotion': @@ -356,6 +357,33 @@ if output_format == 'flumotion': flow['streamer'][name]['properties']['burst-on-connect'] = 'true' flow['streamer'][name]['properties']['burst-time'] = stream[cluster][prop] + ### generate record components ################################ + flow['recorder'] = {} + + for recorder in record.keys(): + record_worker = 'recorder-%s'%(recorder) + if record_worker not in worker: + worker[record_worker] = -1 + else: + worker[record_worker] = 1 + + for mux_name in record[recorder]['muxes']: + format = record[recorder]['muxes'][mux_name]["format"] + profile = record[recorder]['muxes'][mux_name]["profile"] + feeder = 'muxer-%s-%s-%s' % (mux_name, format, profile) + + name = 'recorder-%s-%s-%s' % (mux_name, format, profile) + flow['recorder'][name] = { + 'type': "recorder", + 'desc': "recorder for %s %s-%s" % (mux_name, format, profile), + 'worker': record_worker, + 'feeder': feeder, + 'properties': { } + } + for prop in record[recorder]: + if prop != 'muxes': + flow['recorder'][name]['properties'][prop] = record[recorder][prop] + ### sanity checks, cont'd ####################################### error = 0 diff --git a/src/update.sh b/src/update.sh index bb77181..16781a5 100755 --- a/src/update.sh +++ b/src/update.sh @@ -35,7 +35,7 @@ fi ./manage.sh $1 stop ./manage.sh $1 clean -./flufigut.py flumotion $1 +./flufigut.py flumotion $2 ./manage.sh $1 deploy ./manage.sh $1 start |