diff options
author | Christian Pointner <equinox@spreadspace.org> | 2012-10-17 17:47:38 +0200 |
---|---|---|
committer | Christian Pointner <equinox@spreadspace.org> | 2012-10-17 17:47:38 +0200 |
commit | f59d1964bab3800730aae754641565750229665c (patch) | |
tree | 08fc84c3faaf95e393ccc1a7fe2e87e811ab3daa /src | |
parent | fixed test.json (diff) |
added audomatic repeater generation
Diffstat (limited to 'src')
-rwxr-xr-x | src/flufigut.py | 20 |
1 files changed, 18 insertions, 2 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index 88e49c4..2f3b2c2 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -243,9 +243,9 @@ for mux_name in mux.keys(): 'properties': {}, } - ### generate streamer components ################################ flow['streamer'] = {} +flow['repeater'] = {} for cluster in stream.keys(): streamer_cnt = stream[cluster]['count'] @@ -288,7 +288,23 @@ for cluster in stream.keys(): for mux_name in stream[cluster]['muxes']: for format in mux[mux_name]['formats'].keys(): for profile in mux[mux_name]['formats'][format]: - feeder = 'muxer-%s-%s-%s' % (mux_name, format, profile) + muxer_feed = 'muxer-%s-%s-%s' % (mux_name, format, profile) + if 'repeater' in stream[cluster]: + repeater_worker = stream[cluster]['repeater'] + if repeater_worker not in worker: + worker[repeater_worker] = -1 + else: + worker[repeater_worker] = 1 + repeater_name = '%s-%s-%s-%s' % (stream[cluster]['repeater'], mux_name, format, profile) + flow['repeater'][repeater_name] = { + 'type': "repeater", + 'desc': "%s for %s %s-%s" % (stream[cluster]['repeater'], mux_name, format, profile), + 'worker': repeater_worker, + 'feeder': muxer_feed } + feeder = repeater_name + else: + feeder = muxer_feed + name = '%s-%s%i-%s-%s-%s' % (stream[cluster]['type'], cluster, idx+1, mux_name, format, profile) mount_point = '/%s-%s-%s.%s' % (mux_name, format, profile, globals['formats'][format]['muxer']) if streamer_cnt > 1: |