diff options
Diffstat (limited to 'src/flufigut.py')
| -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: |