Environment.hpp

Go to the documentation of this file.

#pragma once
#include <Pothos/Config.hpp>
#include <Pothos/Object/Object.hpp>
#include <Pothos/Proxy/Proxy.hpp>
#include <Pothos/Util/RefHolder.hpp>
#include <Pothos/Callable/Callable.hpp>
#include <utility> //std::forward
#include <memory>
#include <string>
#include <vector>
#include <map>
#include <iosfwd>

namespace Pothos {

typedef std::map<std::string, std::string> ProxyEnvironmentArgs;

typedef std::pair<std::string, Pothos::Callable> ProxyConvertPair;

class POTHOS_API ProxyEnvironment :
    public Util::RefHolder,
    public std::enable_shared_from_this<ProxyEnvironment>
{
public:
    typedef std::shared_ptr<ProxyEnvironment> Sptr;

    static Sptr make(const std::string &name, const ProxyEnvironmentArgs &args = ProxyEnvironmentArgs());

    virtual ~ProxyEnvironment(void);

    virtual std::string getNodeId(void) const;

    virtual std::string getUniquePid(void) const;

    static std::string getLocalUniquePid(void);

    virtual std::string getPeeringAddress(void);

    virtual std::string getName(void) const = 0;

    virtual Proxy findProxy(const std::string &name) = 0;

    virtual Proxy convertObjectToProxy(const Object &local);

    template <typename ValueType>
    Proxy makeProxy(ValueType &&local);

    virtual Object convertProxyToObject(const Proxy &proxy);

    virtual void serialize(const Proxy &proxy, std::ostream &os) = 0;

    virtual Proxy deserialize(std::istream &is) = 0;
};

} //namespace Pothos

template <typename ValueType>
Pothos::Proxy Pothos::ProxyEnvironment::makeProxy(ValueType &&local)
{
    return convertObjectToProxy(Pothos::Object(std::forward<ValueType>(local)));
}