Topology.hpp

Go to the documentation of this file.

#pragma once
#include <Pothos/Config.hpp>
#include <Pothos/Framework/Connectable.hpp>
#include <Pothos/Framework/ThreadPool.hpp>
#include <Pothos/Object/Object.hpp>
#include <string>
#include <memory>
#include <iosfwd>

namespace Pothos {

class POTHOS_API Topology : public Connectable
{
public:

    static std::shared_ptr<Topology> make(void);

    static std::shared_ptr<Topology> make(const std::string &json);

    Topology(void);

    ~Topology(void);

    void setThreadPool(const ThreadPool &threadPool);

    const ThreadPool &getThreadPool(void) const;

    std::vector<PortInfo> inputPortInfo(void);

    std::vector<PortInfo> outputPortInfo(void);

    void commit(void);

    bool waitInactive(const double idleDuration = 0.1, const double timeout = 1.0);

    template <
        typename SrcType, typename SrcPortType,
        typename DstType, typename DstPortType>
    void connect(
        SrcType &&src, const SrcPortType &srcPort,
        DstType &&dst, const DstPortType &dstPort);

    template <
        typename SrcType, typename SrcPortType,
        typename DstType, typename DstPortType>
    void disconnect(
        SrcType &&src, const SrcPortType &srcPort,
        DstType &&dst, const DstPortType &dstPort);

    void disconnectAll(const bool recursive = false);

    void _connect(
        const Object &src, const std::string &srcPort,
        const Object &dst, const std::string &dstPort);

    void _disconnect(
        const Object &src, const std::string &srcPort,
        const Object &dst, const std::string &dstPort);

    void registerCallable(const std::string &name, const Callable &call);

    std::string queryJSONStats(void);

    std::string dumpJSON(const std::string &request = "{}");

    std::string toDotMarkup(const std::string &request = "{}");

    Object opaqueCallMethod(const std::string &name, const Object *inputArgs, const size_t numArgs) const;

protected:
    virtual Object opaqueCallHandler(const std::string &name, const Object *inputArgs, const size_t numArgs);

private:
    Topology(const Topology &){} // non construction-copyable
    Topology &operator=(const Topology &){return *this;} // non copyable
public:
    struct Impl;
    std::shared_ptr<Impl> _impl;
};

} //namespace Pothos