Node.h

Go to the documentation of this file.

// **********************************************************************
//
// Copyright (c) 2018-present ZeroC, Inc. All rights reserved.
//
// **********************************************************************

#pragma once

#include <DataStorm/Config.h>
#include <DataStorm/InternalI.h>

namespace DataStorm
{

template<typename, typename, typename> class Topic;

class DATASTORM_API NodeShutdownException : public std::exception
{
public:

    virtual const char* what() const noexcept;
};

class DATASTORM_API Node
{
public:

    Node(std::shared_ptr<Ice::Communicator> communicator) noexcept;

    template<class... T>
    Node(int& argc, const char* argv[], T&&... iceArgs) : _ownsCommunicator(true)
    {
        init(argc, argv, std::forward<T>(iceArgs)...);
    }

    template<class... T>
    Node(int& argc, char* argv[], T&&... iceArgs) : _ownsCommunicator(true)
    {
        init(argc, argv, std::forward<T>(iceArgs)...);
    }

#ifdef _WIN32

    template<class... T>
    Node(int& argc, const wchar_t* argv[], T&&... iceArgs) : _ownsCommunicator(true)
    {
        init(argc, argv, std::forward<T>(iceArgs)...);
    }

    template<class... T>
    Node(int& argc, wchar_t* argv[], T&&... iceArgs) : _ownsCommunicator(true)
    {
        init(argc, argv, std::forward<T>(iceArgs)...);
    }
#endif

    template<class... T>
    Node(T&&... iceArgs) : _ownsCommunicator(true)
    {
        init(Ice::initialize(std::forward<T>(iceArgs)...));
    }

    Node(Node&& node) noexcept;

    ~Node();

    void shutdown() noexcept;

    bool isShutdown() const noexcept;

    void waitForShutdown() const noexcept;

    Node& operator=(Node&& node) noexcept;

    std::shared_ptr<Ice::Communicator> getCommunicator() const noexcept;

    std::shared_ptr<Ice::Connection> getSessionConnection(const std::string& ident) const noexcept;

private:

    template<typename V, class... T> void init(int& argc, V argv, T&&... iceArgs)
    {
        auto communicator = Ice::initialize(argc, argv, std::forward<T>(iceArgs)...);
        auto args = Ice::argsToStringSeq(argc, argv);
        communicator->getProperties()->parseCommandLineOptions("DataStorm", args);
        Ice::stringSeqToArgs(args, argc, argv);
        init(communicator);
    }

    void init(const std::shared_ptr<Ice::Communicator>&) noexcept;

    std::shared_ptr<DataStormI::Instance> _instance;
    std::shared_ptr<DataStormI::TopicFactory> _factory;
    bool _ownsCommunicator;

    template<typename, typename, typename> friend class Topic;
};

}