diff options
author | Jörgen Scott <jorgen.scott@gmail.com> | 2014-12-16 14:49:57 +0100 |
---|---|---|
committer | Jörgen Scott <jorgen.scott@gmail.com> | 2014-12-16 14:49:57 +0100 |
commit | 7e3e3f290e9fbbd314919474ed7bc61c3ce43041 (patch) | |
tree | 186d4a54b6d4c9aa81fd2a4774ae72b6d57a342c /src/OutputUHD.h | |
parent | f4e359f774eef5ec2a006a431a546e915b27f02b (diff) | |
download | dabmod-7e3e3f290e9fbbd314919474ed7bc61c3ce43041.tar.gz dabmod-7e3e3f290e9fbbd314919474ed7bc61c3ce43041.tar.bz2 dabmod-7e3e3f290e9fbbd314919474ed7bc61c3ce43041.zip |
added zmq controller to uhd
Diffstat (limited to 'src/OutputUHD.h')
-rw-r--r-- | src/OutputUHD.h | 20 |
1 files changed, 18 insertions, 2 deletions
diff --git a/src/OutputUHD.h b/src/OutputUHD.h index f50807d..25f7476 100644 --- a/src/OutputUHD.h +++ b/src/OutputUHD.h @@ -181,9 +181,12 @@ struct OutputUHDConfig { class OutputUHD: public ModOutput, public RemoteControllable { public: + OutputUHD( OutputUHDConfig& config, - Logger& logger); + Logger& logger, + zmq::context_t *pContext, + const std::string &zmqCtrlEndpoint); ~OutputUHD(); int process(Buffer* dataIn, Buffer* dataOut); @@ -221,9 +224,22 @@ class OutputUHD: public ModOutput, public RemoteControllable { // muting can only be changed using the remote control bool myMuting; + + private: + // zmq receiving method + //TODO: Should be implemented as an alternative to RemoteControllerTelnet and + //moved to the RemoteControl.h/cpp file instead. + void ZmqCtrl(void); + void RecvAll(zmq::socket_t* pSocket, std::vector<std::string> &message); + void SendOkReply(zmq::socket_t *pSocket); + void SendFailReply(zmq::socket_t *pSocket, const std::string &error); + + // data int myStaticDelay; std::vector<complexf> m_delayBuf; - + zmq::context_t *m_pContext; + std::string m_zmqCtrlEndpoint; + boost::thread *m_pZmqRepThread; size_t lastLen; }; |