From f75ac25e6e93ab167b5f3cfdecbbbf286fdc4fed Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Fri, 24 Jan 2014 14:11:19 +0100
Subject: Implement remote control and global_stats, and add to configuration

---
 src/ParserConfigfile.cpp | 38 ++++++++++++++++++++++++++++++++------
 1 file changed, 32 insertions(+), 6 deletions(-)

(limited to 'src/ParserConfigfile.cpp')

diff --git a/src/ParserConfigfile.cpp b/src/ParserConfigfile.cpp
index e513fa3..df83df7 100644
--- a/src/ParserConfigfile.cpp
+++ b/src/ParserConfigfile.cpp
@@ -63,6 +63,7 @@
 #include "dabInputDmbUdp.h"
 #include "dabInputZmq.h"
 #include "DabMux.h"
+#include "StatsServer.h"
 
 
 #ifdef _WIN32
@@ -144,7 +145,9 @@ void parse_configfile(string configuration_file,
         bool* enableTist,
         unsigned* FICL,
         bool* factumAnalyzer,
-        unsigned long* limit
+        unsigned long* limit,
+        BaseRemoteController* rc,
+        int* statsServerPort
         )
 {
     using boost::property_tree::ptree;
@@ -183,6 +186,22 @@ void parse_configfile(string configuration_file,
 
     *enableTist = pt_general.get("tist", false);
 
+    *statsServerPort = pt_general.get<int>("statsserverport", 0);
+
+    /************** READ REMOTE CONTROL PARAMETERS *************/
+    ptree pt_rc = pt.get_child("remotecontrol");
+    int telnetport = 0;
+    if (pt_rc.get("telnet", 0)) {
+        telnetport = pt_rc.get<int>("port", 0);
+    }
+
+    if (telnetport != 0) {
+        rc = new RemoteControllerTelnet(telnetport);
+    }
+    else {
+        rc = new RemoteControllerDummy();
+    }
+
     /******************** READ ENSEMBLE PARAMETERS *************/
     ptree pt_ensemble = pt.get_child("ensemble");
 
@@ -271,7 +290,7 @@ void parse_configfile(string configuration_file,
         ensemble->subchannels.push_back(subchan);
 
         try {
-            setup_subchannel_from_ptree(subchan, it->second, ensemble, subchanuid);
+            setup_subchannel_from_ptree(subchan, it->second, ensemble, subchanuid, rc);
         }
         catch (runtime_error &e) {
             etiLog.log(error,
@@ -409,7 +428,8 @@ void parse_configfile(string configuration_file,
 void setup_subchannel_from_ptree(dabSubchannel* subchan,
         boost::property_tree::ptree &pt,
         dabEnsemble* ensemble,
-        string subchanuid)
+        string subchanuid,
+        BaseRemoteController* rc)
 {
     using boost::property_tree::ptree;
     using boost::property_tree::ptree_error;
@@ -489,19 +509,25 @@ void setup_subchannel_from_ptree(dabSubchannel* subchan,
         }
         else if (strcmp(subchan->inputProto, "tcp") == 0) {
             input_is_old_style = false;
-            subchan->input = new DabInputZmq(subchanuid);
+            DabInputZmq* inzmq = new DabInputZmq(subchanuid);
+            inzmq->enrol_at(*rc);
+            subchan->input     = inzmq;
             subchan->inputName = full_inputName;
         }
         else if (strcmp(subchan->inputProto, "epmg") == 0) {
             etiLog.level(warn) << "Using untested epmg:// zeromq input";
             input_is_old_style = false;
-            subchan->input = new DabInputZmq(subchanuid);
+            DabInputZmq* inzmq = new DabInputZmq(subchanuid);
+            inzmq->enrol_at(*rc);
+            subchan->input     = inzmq;
             subchan->inputName = full_inputName;
         }
         else if (strcmp(subchan->inputProto, "ipc") == 0) {
             etiLog.level(warn) << "Using untested ipc:// zeromq input";
             input_is_old_style = false;
-            subchan->input = new DabInputZmq(subchanuid);
+            DabInputZmq* inzmq = new DabInputZmq(subchanuid);
+            inzmq->enrol_at(*rc);
+            subchan->input     = inzmq;
             subchan->inputName = full_inputName;
 #endif // defined(HAVE_INPUT_ZEROMQ)
         } else {
-- 
cgit v1.2.3