Merge pull request #1245 from qwu16/casc

Enable cluster cascading feature with master branch

Author: qwu16

scripts/build.json

@@ -117,6 +117,12 @@
     "quicIO" : {
         "path" : "source/agent/addons/quicIO"
     },
+    "quicCascading" : {
+        "path" : "source/agent/addons/quicCascading"
+    },
+    "mediaBridge" : {
+        "path" : "source/agent/addons/quicCascading"
+    },
     "resource-util" : {
         "path" : "source/agent/addons/resourceUtil"
     },

scripts/pack.js

@@ -41,7 +41,7 @@ const originCwd = cwd();
 const osScript = path.join(rootDir, 'scripts/detectOS.sh');
 const osType = execSync(`bash ${osScript}`).toString().toLowerCase();
 
-const experimentalTargets = ['quic-agent'];
+const experimentalTargets = ['quic-agent', 'media-bridge', 'event-bridge'];
 
 var allTargets = [];
 

scripts/release/daemon-bin.sh

@@ -114,6 +114,13 @@ case $startStop in
           > "${stdout}" 2>&1 </dev/null &
         echo $! > ${pid}
         ;;
+      event-bridge )
+        cd ${OWT_HOME}/eventbridge
+        export LD_LIBRARY_PATH=./lib:${LD_LIBRARY_PATH}
+        nohup nice -n ${OWT_NICENESS} \
+          > "${stdout}" 2>&1 </dev/null &
+        echo $! > ${pid}
+        ;;
       conference-agent )
         cd ${OWT_HOME}/conference_agent
         nohup nice -n ${OWT_NICENESS} ./OWT-MCU-Conference-Controller . -U conference\
@@ -176,6 +183,13 @@ case $startStop in
           > "${stdout}" 2>&1 </dev/null &
         echo $! > ${pid}
         ;;
+      media-bridge )
+        cd ${OWT_HOME}/media_bridge
+        export LD_LIBRARY_PATH=./lib:${LD_LIBRARY_PATH}
+        nohup nice -n ${OWT_NICENESS} ./OWT-MCU-Agent . -U mediabridge \
+          > "${stdout}" 2>&1 </dev/null &
+        echo $! > ${pid}
+        ;;
       management-console )
         cd ${OWT_HOME}/management_console
         nohup nice -n ${OWT_NICENESS} node . \

scripts/release/daemon-mcu.sh

@@ -114,6 +114,13 @@ case $startStop in
           > "${stdout}" 2>&1 </dev/null &
         echo $! > ${pid}
         ;;
+      event-bridge )
+        cd ${OWT_HOME}/eventbridge
+        export LD_LIBRARY_PATH=./lib:${LD_LIBRARY_PATH}
+        nohup nice -n ${OWT_NICENESS} node . \
+          > "${stdout}" 2>&1 </dev/null &
+        echo $! > ${pid}
+        ;;
       conference-agent )
         cd ${OWT_HOME}/conference_agent
         nohup nice -n ${OWT_NICENESS} node . -U conference\
@@ -176,6 +183,13 @@ case $startStop in
           > "${stdout}" 2>&1 </dev/null &
         echo $! > ${pid}
         ;;
+      media-bridge )
+        cd ${OWT_HOME}/media_bridge
+        export LD_LIBRARY_PATH=./lib:${LD_LIBRARY_PATH}
+        nohup nice -n ${OWT_NICENESS} node . -U mediabridge\
+          > "${stdout}" 2>&1 </dev/null &
+        echo $! > ${pid}
+        ;;
       analytics-agent )
         cd ${OWT_HOME}/analytics_agent
         export LD_LIBRARY_PATH=./lib:${LD_LIBRARY_PATH}

source/agent/addons/quicCascading/QuicFactory.cc

@@ -0,0 +1,28 @@
+/*
+ * Copyright (C) 2019 Intel Corporation
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#include "QuicFactory.h"
+#include <mutex>
+
+DEFINE_LOGGER(QuicFactory, "QuicFactory");
+
+std::once_flag getQuicFactoryOnce;
+
+std::shared_ptr<QuicFactory> QuicFactory::s_quicFactory = nullptr;
+
+QuicFactory::QuicFactory()
+    : m_quicTransportFactory(std::shared_ptr<owt::quic::QuicTransportFactory>(owt::quic::QuicTransportFactory::Create()))
+{
+}
+
+std::shared_ptr<owt::quic::QuicTransportFactory> QuicFactory::getQuicTransportFactory()
+{
+    std::call_once(getQuicFactoryOnce, []() {
+        QuicFactory* factory = new QuicFactory();
+        s_quicFactory = std::shared_ptr<QuicFactory>(factory);
+    });
+    return s_quicFactory->m_quicTransportFactory;
+}

source/agent/addons/quicCascading/QuicFactory.h

@@ -0,0 +1,33 @@
+/*
+ * Copyright (C) 2019 Intel Corporation
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#ifndef QUIC_QUICFACTORY_H_
+#define QUIC_QUICFACTORY_H_
+
+#include <memory>
+#include <logger.h>
+#include "owt/quic/quic_transport_factory.h"
+
+namespace owt {
+namespace quic {
+    class QuicTransportFactory;
+}
+}
+
+class QuicFactory {
+public:
+    DECLARE_LOGGER();
+    virtual ~QuicFactory() = default;
+    static std::shared_ptr<owt::quic::QuicTransportFactory> getQuicTransportFactory();
+
+private:
+    explicit QuicFactory();
+
+    static std::shared_ptr<QuicFactory> s_quicFactory;
+    std::shared_ptr<owt::quic::QuicTransportFactory> m_quicTransportFactory;
+};
+
+#endif