Application.h

Go to the documentation of this file.

/*
* This file is part of ArmarX.
*
* Copyright (C) 2011-2016, High Performance Humanoid Technologies (H2T), Karlsruhe Institute of Technology (KIT), all rights reserved.
*
* ArmarX is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation.
*
* ArmarX is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* @package    ArmarXCore::core
* @author     Nils Adermann (naderman at naderman dot de)
* @author     Kai Welke (welke at kit dot edu)
* @author     Jan Issac (jan dot issac at gmail dot com)
* @date       2010
* @copyright  http://www.gnu.org/licenses/gpl-2.0.txt
*             GNU General Public License
*/
 
#pragma once
 
#include "../ArmarXManager.h"
#include "../Component.h"               // for Component
#include "../logging/Logging.h"
#include "../system/ArmarXDataPath.h"
#include "../system/ImportExport.h"     // for ARMARXCORE_IMPORT_EXPORT
#include "../system/cmake/CMakePackageFinder.h"
#include "ApplicationOptions.h"
#include "ApplicationNetworkStats.h"    // for ApplicationNetworkStatsPtr
#include "ArmarXCore/core/ArmarXFwd.h"  // for ArmarXManagerPtr
#include "ArmarXCore/core/ManagedIceObjectRegistryInterface.h"
#include "ArmarXCore/core/application/properties/PropertyDefinitionContainer.h"
#include "ArmarXCore/core/exceptions/Exception.h"  // for LocalException
#include "properties/PropertyUser.h"    // for PropertyDefinitionsPtr, etc
 
#include <Ice/Application.h>            // for Application
#include <Ice/BuiltinSequences.h>       // for StringSeq
#include <Ice/PropertiesF.h>            // for PropertiesPtr
#include <IceUtil/Handle.h>             // for Handle, HandleBase
 
#include <string>                       // for string
#include <vector>                       // for vector
#include <mutex>
 
 
namespace Ice
{
    struct InitializationData;
}  // namespace Ice
 
#define xstr(s) stringify(s)
#define stringify(s) #s
 
/**
    \defgroup Application ArmarX Application
    \ingroup DistributedProcessingGrp
 */
 
namespace std
{
    class thread;
}
 
namespace armarx
{
    // forward declarations
    class ManagedIceObjectRegistryInterface;
    class ThreadPool;
    using ThreadPoolPtr = std::shared_ptr<ThreadPool>;
    class ApplicationNetworkStats;
    using ApplicationNetworkStatsPtr = ::IceUtil::Handle<ApplicationNetworkStats>;
 
    /**
     * \typedef ManagedIceObjectRegistryInterfacePtr shared pointer for armarx::ManagedIceObjectRegistryInterface
     */
    using ManagedIceObjectRegistryInterfacePtr = IceUtil::Handle<ManagedIceObjectRegistryInterface>;
 
    /**
     * armarx::Application smart pointer
     */
    class Application;
 
    /**
     * \typedef ApplicationPtr shared pointer for armarx::Application
     */
    using ApplicationPtr = IceUtil::Handle<Application>;
 
    /**
      \class ApplicationPropertyDefinitions
      \brief Application property definition container.
      \ingroup Application
      \see properties
     */
    class ARMARXCORE_IMPORT_EXPORT ApplicationPropertyDefinitions:
        public PropertyDefinitionContainer
    {
    public:
        /**
         * @see armarx::PropertyDefinitionContainer::PropertyDefinitionContainer()
         */
        ApplicationPropertyDefinitions(std::string prefix);
    };
 
    /**
      \class Application
      \brief Baseclass for all ArmarX applications.
      \ingroup Application
 
      \li helper class for ArmarX main programs
      \li creates an instance of ArmarXManager
      \li generates properties from commandline parameters
      \li provides help and automatic generation of properties
 
      Implements the run method from the Ice::Application interface
      which is called by the automatically generated main.cpp.
      In order to start writing an ArmarX application, inherit from armarx::Application
      and implement the setup method to setup and add the required ManagedIceObjects.
 
      \code
        class ExampleApp :
            virtual public armarx::Application
        {
            void setup(const ManagedIceObjectRegistryInterfacePtr& registry,
                       Ice::PropertiesPtr properties)
            {
                registry->addObject(Component::create<Example>(properties));
            };
        }
      \endcode
 
      The application automatically loads a default config file
      (usually ~/.armarx/default.cfg), which is needed to connect to IceGrid etc.
      This function is also available as a static version: LoadDefaultConfig()
 
      If you only want to use one component (as above), you can use \ref armarx::runSimpleComponentApp.
      In this case, your main function would look like this:
 
      \code
        int main(int argc, char* argv[])
        {
            return armarx::runSimpleComponentApp<ExampleComponent, ApplicationType>(argc, argv, "ExampleAppName", "ExampleComponentConfigName", "ExampleComponentDomain");
        }
      \endcode
 
      If you are using the defaults for ApplicationType (\ref armarx::Application)
      ExampleComponentConfigName (\ref armarx::Component::getDefaultName()) and
      ExampleComponentDomain ("ArmarX"), your main function looks like this:
 
      \code
        int main(int argc, char* argv[])
        {
            return armarx::runSimpleComponentApp<ExampleComponent>(argc, argv, "ExampleAppName");
        }
      \endcode
 
      Application specific configuration files can be passed to the application
      by using the Ice.Config commandline parameter.
      The used configuration file format is those of regular Ice configuration files.
 
      Each entry in Ice configuration files is prefixed with a "DomainName"
      which is "ArmarX" by default.
      This "DomainName" can be changed by overriding armarx::Application::getDomainName()
      to return a different string.
 
      Sometimes it is not possible to pass configuration files via the Ice.Config parameter
      (e.g. when using IceGrid XML deployment files where this paramter is overriden by IceGrid).
      In this case, the commandline parameter ArmarX.Config can be used.
      All files specified in this parameter will be merged into the standard properties
      available inside the armarx::Application.
 
      Special properties:
 
      \li ArmarX.Config
      \li ArmarX.NetworkStats: set to "1" to enable logging of network statistics (use armarx::ProfilerObserver to collect the data)
      \li ArmarX.DependenciesConfig
      \li ArmarX.ProjectDatapath
      \li ArmarX.ProjectName
      \li ArmarX.ProjectDependencies
      \li <DomainName>.DisableLogging
      \li <DomainName>.Verbosity
      \li <DomainName>.DataPath
 
      Internally, an armarx::Application contains an armarx::ArmarXManger which is responsible
      for managing they lifecycle of all components inside an application.
     */
    class ARMARXCORE_IMPORT_EXPORT Application :
        public Ice::Application,
        public PropertyUser
    {
    public:
        /**
         * @brief Application initalizes the Ice::Application base class.
         */
        Application();
        /**
         * Creates the one application instance of type T. T is usually the
         * type of a sublass as defined in a specific component. This method is
         * called from the automatically generated main.cpp.
         *
         * @return shared pointer to the application
         */
        template <class T, typename ...Args>
        static ApplicationPtr createInstance(Args&&... args)
        {
            std::unique_lock lock(instanceMutex);
 
            if (instance)
            {
                throw LocalException("Application instance already created");
            }
 
            instance = ApplicationPtr(new T(std::forward<Args>(args)...));
 
            return instance;
        }
 
        /**
         * Retrieve shared pointer to the application object. Use this in order
         * to access is called from the automatically generated main.cpp.
         *
         * @return shared pointer to the application
         */
        static ApplicationPtr getInstance();
 
        static void setInstance(ApplicationPtr const& inst);
 
        static std::string GetVersion()
        {
#ifdef ARMARX_VERSION
            return xstr(ARMARX_VERSION);
#else
            return "undefined";
#endif
        }
 
        /**
         * Ice::Application replacement for the main function.
         */
        int run(int argc, char* argv[]) override;
 
        /**
         * Set name of the application. Called from main.cpp.
         * This method has an effect only if it is called before Application::main()
         *
         * @param application name
         */
        void setName(const std::string& name);
 
        /**
         * Retrieve name of the application
         *
         * @return application name
         */
        std::string getName() const;
 
        /**
         * Cleans up connections with IceStorm before terminating the app
         *
         * @param signal The signal send to the application
         */
        void interruptCallback(int signal) override;
 
        void registerDataPathsFromDependencies(std::string dependencies);
 
        /**
         * @brief getDefaultPackageNames returns the value of the ArmarX.DefaultPackages property
         * It splits the string by , and returns the elements as a vector.
         * @return
         */
        std::vector<std::string> getArmarXPackageNames();
 
        bool isPackageAutoDiscoveryEnabled();
 
        static std::string GetArmarXConfigDefaultPath(bool envVarExpanded = true);
        static Ice::StringSeq GetDefaultsPaths();
        static void LoadDefaultConfig(Ice::PropertiesPtr properties);
        static const std::string& GetProjectName();
        static const Ice::StringSeq& GetProjectDependencies();
 
        /**
        * Overrides PropertyUser::setIceProperties() which is called internally.
         * Additionally it calls Component::updateIceProperties().
         */
        void setIceProperties(Ice::PropertiesPtr properties) override;
 
        void updateIceProperties(const Ice::PropertyDict& properties) override;
 
        void icePropertiesUpdated(const std::set<std::string>& changedProperties) override;
        static const std::string ArmarXUserConfigDirEnvVar;
 
        const ThreadPoolPtr& getThreadPool() const;
        bool getForbidThreadCreation() const;
        void setForbidThreadCreation(bool value);
        void enableLibLoading(bool enable = true);
 
        void storeCommandLineArguments(int argc, char* argv[]);
        const std::vector<std::string>& getCommandLineArguments() const;
    protected:
        /**
         * @see PropertyUser::createPropertyDefinitions()
         */
        PropertyDefinitionsPtr createPropertyDefinitions() override;
 
        /**
         * Setup method to be implemented by user applications
         *
         * Use this method to add all required ManagedIceObject to the application
         * @see void ManagedIceObjectRegistryInterfacePtr::addObject(ManagedIceObjectPtr object)
         */
        virtual void setup(const ManagedIceObjectRegistryInterfacePtr& registry, Ice::PropertiesPtr properties) = 0;
 
        /**
         * Exec method is the main process of the application. The default
         * implementation only calls
         *
         * <code>
         *     armarXManager->waitForShutdown();
         * </code>
         *
         * If you need to do something in the main process (e.g. processing QT
         * guis) overwrite this method.
         *
         * @return program exit status
         */
        virtual int exec(const ArmarXManagerPtr& armarXManager);
 
        /**
         * @brief Ice::Application::doMain() is called by Ice::Application::main() and does setup of Ice::Communicator before calling the virtual Ice::Application::run() method
         * @param argc
         * @param argv
         * @param initData
         * @return
         */
        int doMain(int argc, char* argv[], const Ice::InitializationData& initData, Ice::Int i) override;
 
        void loadDefaultConfig(int argc, char* argv[], const Ice::InitializationData& initData);
 
        void loadDependentProjectDatapaths();
 
        /**
         * Retrieve the domain name used for property parsing. Overwrite this in your subclass in order to
         * use another domain name then "ArmarX".
         * The domain name is the first part of the property identifier where each part is separated via a "." (e.g. ArmarX.some.property).
         *
         * @return domain name. Defaults to "ArmarX".
         */
        virtual std::string getDomainName();
 
        /**
         * @return an instance of armarx::ArmarXManagerPtr
         */
        ArmarXManagerPtr getArmarXManager();
 
 
 
        /**
        * Print help onto the screen or into a file
               */
        void showHelp(ApplicationOptions::Options& options);
 
        /**
         * Parse options given on the commandline and merge them into the regular properties
         */
        Ice::PropertiesPtr parseOptionsMergeProperties(int argc, char* argv[]);
 
 
        /**
         * @brief handlerInterrupt handles interrupt signals sent to the application (Linux)
         * @param sig
         */
        static void HandlerInterrupt(int sig);
 
 
        /**
         * @brief handlerFault handles signals sendt to the application such as SIGSEGF or SIGABRT (Linux)
         * @param sig
         */
        static void HandlerFault(int sig);
 
    private:
 
        void loadLibrariesFromProperties();
 
        /**
         * Application singleton instance
         */
        static ApplicationPtr instance;
 
        /**
         * Application instance instantiation and access mutex
         */
        static std::mutex instanceMutex;
 
        /**
         * Application instance name
         */
        std::string applicationName;
 
        /**
         * the ArmarXManager
         */
        ArmarXManagerPtr armarXManager;
 
        ApplicationNetworkStatsPtr applicationNetworkStats;
 
        std::shared_ptr<std::thread> shutdownThread;
 
        static std::string ProjectName;
        static Ice::StringSeq ProjectDependendencies;
 
        ThreadPoolPtr threadPool;
        bool forbidThreadCreation = false;
        bool libLoadingEnabled = false;
 
        std::vector<std::string> commandLineArguments;
    };
 
    class DummyApplication : public Application
    {
        // Application interface
    protected:
        void setup(const ManagedIceObjectRegistryInterfacePtr& registry, Ice::PropertiesPtr properties) override
        {
        }
    };
}
 
namespace armarx::internal
{
    template<class ComponentT, class AppT>
    /**
     * @see runSimpleComponentApp<ComponentT, AppT>.
     * @brief Used by runSimpleComponentApp<ComponentT, AppT>.
     * This class can't be defined in function, since this causes problems with gcc and c++03
     */
    class SimpleSingleComponentApp : virtual public AppT
    {
        void setup(const ManagedIceObjectRegistryInterfacePtr& registry, Ice::PropertiesPtr properties) override
        {
            registry->addObject(Component::create<ComponentT>(properties, "", appConfigDomain));
        }
 
    public:
        std::string appConfigName;
        std::string appConfigDomain;
    };
}
 
namespace armarx
{
    /**
     * @brief Creates and runs an application (of AppT) for the given component (ComponentT).
     * @param argc CL parameter count
     * @param argv CL parameters
     * @param appName The application's name.
     * @param configName The config name, passed to the create call.
     * @param configDomain The config domain, passed to the create call.
     * @return The application's return code (app->main(argc, argv))
     *
     * For a component COMP the following application is created
     * \code{.cpp}
     * class SimpleSingleComponentApp : virtual public Application
     *  {
     *      void setup(const ManagedIceObjectRegistryInterfacePtr& registry, Ice::PropertiesPtr properties)
     *      {
     *          registry->addObject(Component::create<COMP>(properties));
     *      }
     *  };
     * \endcode
     * Following code is executed
     * \code{.cpp}
     * armarx::ApplicationPtr app = armarx::Application::createInstance<SimpleSingleComponentApp>() ;
     * app->setName(appName);
     * return app->main(argc, argv);
     * \endcode
     */
    template<class ComponentT, class AppT = armarx::Application>
    int runSimpleComponentApp(int argc, char* argv[], std::string appName, const std::string& configName = "", const std::string& configDomain = "ArmarX", bool enableLibLoading = false)
    {
        armarx::ApplicationPtr app = AppT::template createInstance<internal::SimpleSingleComponentApp<ComponentT, AppT> >();
 
        auto sApp = IceUtil::Handle<internal::SimpleSingleComponentApp<ComponentT, AppT> >::dynamicCast(app);
        sApp->appConfigDomain = configDomain;
        sApp->appConfigName = configName;
        app->enableLibLoading(enableLibLoading);
        app->setName(appName);
        app->storeCommandLineArguments(argc, argv);
        return app->main(argc, argv);
    }
 
    /**
     * @brief Do not use! Use \ref armarx::runMultipleComponentsApp()
     */
    class MultipleComponentsApplication : public Application
    {
    public:
        MultipleComponentsApplication(std::vector<ComponentPtr> components) :
            components(components) {}
 
    private:
        std::vector<ComponentPtr> components;
 
        // Application interface
    protected:
        void setup(const ManagedIceObjectRegistryInterfacePtr& registry, Ice::PropertiesPtr properties) override
        {
            for (ComponentPtr comp : components)
            {
                registry->addObject(comp);
            }
        }
    };
 
    template<class ComponentType>
    std::vector<ComponentPtr> createComponents(ComponentType comp)
    {
        return {comp};
    }
 
    template<class ComponentType, class... ComponentTypes >
    std::vector<ComponentPtr> createComponents(ComponentType comp, ComponentTypes... components)
    {
        std::vector<ComponentPtr> result {comp};
        std::vector<ComponentPtr> tempResult = createComponents(components...);
        result.insert(result.end(), tempResult.begin(), tempResult.end());
        return result;
    }
 
    template<class... ComponentTypes >
    std::vector<ComponentPtr> createComponentsUtil(ComponentTypes&& ... components)
    {
        std::vector<ComponentPtr> result;
        std::vector<ComponentPtr> tempResult = createComponents(components...);
        result.insert(result.end(), tempResult.begin(), tempResult.end());
        return result;
    }
 
    /**
     * Convenience function to create an app with multiple components easily.
     *
     * Usage:
     * \code{.cpp}
     * main(int argc, char * argv[])
     * {
     *     armarx::ApplicationPtr app;
     *     std::vector<ComponentPtr> components;
     *     std::tie(app, components) = runMultipleComponentsApp < ConditionHandler, SystemObserver, DebugObserver > (argc, argv, "ArmarXCoreApps");
     *     return app->main(argc, argv);
     * }
     * \endcode
     *
     * \return returns a tuple of the created Application and a vector of the created components. The order of the components is the same as the template parameter list.
     */
    template<class... ComponentTypes >
    std::tuple<armarx::ApplicationPtr, std::vector<ComponentPtr> > runMultipleComponentsApp(int argc, char* argv[], std::string appName, const std::string& configDomain = "ArmarX")
    {
        Ice::PropertiesPtr props = Ice::createProperties(argc, argv);
        std::vector<ComponentPtr> comps = createComponentsUtil(Component::create<ComponentTypes>(props, "", configDomain)...);
        armarx::ApplicationPtr app = new MultipleComponentsApplication(comps);
 
        app->setName(appName);
        return std::make_tuple(app, comps);
    }
 
}