aboutsummaryrefslogtreecommitdiffstats
path: root/src/OutputUHD.h
diff options
context:
space:
mode:
authorJörgen Scott <jorgen.scott@gmail.com>2014-12-16 14:49:57 +0100
committerJörgen Scott <jorgen.scott@gmail.com>2014-12-16 14:49:57 +0100
commit7e3e3f290e9fbbd314919474ed7bc61c3ce43041 (patch)
tree186d4a54b6d4c9aa81fd2a4774ae72b6d57a342c /src/OutputUHD.h
parentf4e359f774eef5ec2a006a431a546e915b27f02b (diff)
downloaddabmod-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.h20
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;
};