SuperComponent.h

Go to the documentation of this file.

#ifndef CONTEXT_BASE_SUPERCOMPONENT_H_
#define CONTEXT_BASE_SUPERCOMPONENT_H_

#include <memory>
#include <string>
#include <vector>

#include "opendavinci/odcore/opendavinci.h"
#include <memory>
#include "opendavinci/odcore/base/KeyValueConfiguration.h"
#include "opendavinci/odcore/base/Mutex.h"
#include "opendavinci/odcore/dmcp/ModuleConfigurationProvider.h"
#include "opendavinci/odcore/dmcp/ModuleStateListener.h"
#include "opendavinci/odcore/dmcp/connection/ConnectionHandler.h"
#include "opendavinci/odcore/io/conference/ContainerConference.h"
#include "opendavinci/generated/odcore/data/dmcp/ModuleExitCodeMessage.h"
#include "opendavinci/generated/odcore/data/dmcp/ModuleStateMessage.h"
#include "opendavinci/generated/odcore/data/dmcp/RuntimeStatistic.h"

namespace odcore { namespace data { namespace dmcp { class ModuleDescriptor; } } }
namespace odcore { namespace data { class Container; } }
namespace odcore { namespace dmcp { namespace connection { class ModuleConnection; } } }
namespace odcore { namespace dmcp { namespace connection { class Server; } } }
namespace odcore { namespace dmcp { namespace discoverer { class Server; } } }

namespace odcontext {
    namespace base {

        using namespace std;

        class OPENDAVINCI_API SuperComponent : protected odcore::dmcp::connection::ConnectionHandler,
                                               protected odcore::dmcp::ModuleStateListener,
                                               public odcore::dmcp::ModuleConfigurationProvider {
            private:
                SuperComponent(const SuperComponent&);

                SuperComponent& operator=(const SuperComponent&);

            public:
                SuperComponent(const string &multicastGroup, const uint32_t &CID, const odcore::base::KeyValueConfiguration &configuration);

                virtual ~SuperComponent();

                odcore::io::conference::ContainerConference& getContainerConference();

            protected:
                virtual odcore::base::KeyValueConfiguration getConfiguration(const odcore::data::dmcp::ModuleDescriptor& md);

                virtual odcore::base::KeyValueConfiguration getGlobalConfiguration() const;

                virtual void onNewModule(std::shared_ptr<odcore::dmcp::connection::ModuleConnection> mc);

                virtual void handleChangeState(const odcore::data::dmcp::ModuleDescriptor& md,
                                               const odcore::data::dmcp::ModuleStateMessage::ModuleState &ms);

                virtual void handleExitCode(const odcore::data::dmcp::ModuleDescriptor& md,
                                            const odcore::data::dmcp::ModuleExitCodeMessage::ModuleExitCode &me);

                virtual void handleRuntimeStatistics(const odcore::data::dmcp::ModuleDescriptor& md,
                                                     const odcore::data::dmcp::RuntimeStatistic& rs);

                virtual void handleConnectionLost(const odcore::data::dmcp::ModuleDescriptor& md);

                virtual void handleUnkownContainer(const odcore::data::dmcp::ModuleDescriptor& md,
                                                   const odcore::data::Container& container);

            private:
                odcore::base::Mutex m_configurationMutex;
                odcore::base::KeyValueConfiguration m_configuration;

                unique_ptr<odcore::dmcp::discoverer::Server> m_discovererServer;
                unique_ptr<odcore::dmcp::connection::Server> m_connectionServer;

                std::shared_ptr<odcore::io::conference::ContainerConference> m_conference;

                vector<std::shared_ptr<odcore::dmcp::connection::ModuleConnection> > m_listOfModuleConnections;
        };

    }
} // odcontext::base

#endif /*CONTEXT_BASE_SUPERCOMPONENT_H_*/