ConnectionForwarding.h

Go to the documentation of this file.

#pragma once
#include "DLLInfo.h"
#include <NDEVR/Connection.h>
#include <NDEVR/Translator.h>
namespace NDEVR
{
    /**--------------------------------------------------------------------------------------------------
    \brief Logic for taking all rx data from one Connection and sending it through another Connection and
        vice-versa.
    **/
    class HARDWARE_API ConnectionForwarding : public Device
    {
    public:
        ConnectionForwarding(ProgressInfo* log = nullptr);
        ConnectionForwarding(ConnectionInfo a, ConnectionInfo b, ProgressInfo* log = nullptr);
        ConnectionForwarding(Connection* a, Connection* b, ProgressInfo* log = nullptr);
        ~ConnectionForwarding();
        virtual void update() override;
        virtual bool open(bool start_forward_thread = true);
        virtual bool isOpen() const;
        Connection* a() const { return m_a; }
        Connection* b() const { return m_b; }
        void close();
        void setAConnectionInfo(const ConnectionInfo& info);
        void setBConnectionInfo(const ConnectionInfo& info);
        void setForwardAToB(bool forward);
        void setForwardBToA(bool forward);
        bool forwardAToB() const { return m_forward_a_to_b; }
        bool forwardBToA() const { return m_forward_b_to_a; }
        TimeSpan updateInterval() const override;
        void setUpdateInterval(const TimeSpan& span);
    private:
        virtual void _close();
    protected:
        TimeSpan m_update_span = TimeSpan(0.05);
        Connection* m_a = nullptr;
        Connection* m_b = nullptr;
        bool m_forward_a_to_b = true;
        bool m_forward_b_to_a = true;
        bool m_is_open = false;
        bool m_request_close = false;
    };
}