diff options
| -rwxr-xr-x | src/flufigut.py | 21 |
1 files changed, 19 insertions, 2 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index b2f56b6..f9f63f2 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -320,6 +320,24 @@ class Planet: self.flow['streamers'][comp_name]['properties']['burst-on-connect'] = 'true' self.flow['streamers'][comp_name]['properties']['burst-time'] = stream[prop] + def __add_stream_mux_instance_plugs(self, comp_name, stream_name, idx, mux, format, profile, globals): + if 'stats' in globals: + self.flow['streamers'][comp_name]['plugs'] = {} + if 'rrd' in globals['stats']: + self.flow['streamers'][comp_name]['plugs']['rrd'] = {} + self.flow['streamers'][comp_name]['plugs']['rrd']['clients'] = "%s/%s_clients.rrd" % (globals['stats']['rrd']['directory'], comp_name) + self.flow['streamers'][comp_name]['plugs']['rrd']['bytes'] = "%s/%s_bytes.rrd" % (globals['stats']['rrd']['directory'], comp_name) + + if 'sfive' in globals['stats']: + self.flow['streamers'][comp_name]['plugs']['sfive'] = {} + self.flow['streamers'][comp_name]['plugs']['sfive']['socket'] = globals['stats']['sfive']['socket'] + self.flow['streamers'][comp_name]['plugs']['sfive']['duration'] = globals['stats']['sfive']['duration'] + self.flow['streamers'][comp_name]['plugs']['sfive']['tags'] = globals['stats']['sfive']['tags'] + self.flow['streamers'][comp_name]['plugs']['sfive']['hostname'] = '%s%i' % (stream_name, idx + 1) + self.flow['streamers'][comp_name]['plugs']['sfive']['content-id'] = mux + self.flow['streamers'][comp_name]['plugs']['sfive']['format'] = format + self.flow['streamers'][comp_name]['plugs']['sfive']['quality'] = profile + def __generate_stream_mux_instance(self, stream_name, stream, mux, format, profile, idx, cnt, porter, globals): muxer_feed = 'muxer-%s-%s-%s' % (mux, format, profile) feeder = muxer_feed @@ -354,8 +372,7 @@ class Planet: } } self.__set_stream_mux_instance_props(comp_name, stream, porter.port, mount_point, hostname_next) - - # TODO: add stats!! + self.__add_stream_mux_instance_plugs(comp_name, stream_name, idx, mux, format, profile, globals) def __generate_stream_instance(self, stream_name, stream, idx, cnt, muxes, globals): port = stream['port'] |