diff options
author | Christian Daniel <cd@maintech.de> | 2013-11-16 23:14:30 +0100 |
---|---|---|
committer | Christian Daniel <cd@maintech.de> | 2013-11-16 23:14:30 +0100 |
commit | eeb7a07683c3a9b84304748f609019046cc696e3 (patch) | |
tree | 1b3291634144d7a9945354cb2d5dda1a78c0b10b /plugins/channel/tcpsrc | |
parent | ba220b717a1ce135ccc756d1382b4bb38ee50f47 (diff) |
switch to new message mechanism without registration-voodoo
Diffstat (limited to 'plugins/channel/tcpsrc')
-rw-r--r-- | plugins/channel/tcpsrc/tcpsrc.cpp | 12 | ||||
-rw-r--r-- | plugins/channel/tcpsrc/tcpsrc.h | 18 | ||||
-rw-r--r-- | plugins/channel/tcpsrc/tcpsrcgui.cpp | 6 |
3 files changed, 18 insertions, 18 deletions
diff --git a/plugins/channel/tcpsrc/tcpsrc.cpp b/plugins/channel/tcpsrc/tcpsrc.cpp index 02a55d2..9cfee43 100644 --- a/plugins/channel/tcpsrc/tcpsrc.cpp +++ b/plugins/channel/tcpsrc/tcpsrc.cpp @@ -5,9 +5,9 @@ #include "tcpsrcgui.h" #include "dsp/dspcommands.h" -MessageRegistrator TCPSrc::MsgTCPSrcConfigure::ID("MsgTCPSrcConfigure"); -MessageRegistrator TCPSrc::MsgTCPSrcConnection::ID("MsgTCPSrcConnection"); -MessageRegistrator TCPSrc::MsgTCPSrcSpectrum::ID("MsgTCPSrcSpectrum"); +MESSAGE_CLASS_DEFINITION(TCPSrc::MsgTCPSrcConfigure, Message) +MESSAGE_CLASS_DEFINITION(TCPSrc::MsgTCPSrcConnection, Message) +MESSAGE_CLASS_DEFINITION(TCPSrc::MsgTCPSrcSpectrum, Message) TCPSrc::TCPSrc(MessageQueue* uiMessageQueue, TCPSrcGUI* tcpSrcGUI, SampleSink* spectrum) { @@ -97,7 +97,7 @@ void TCPSrc::stop() bool TCPSrc::handleMessage(Message* cmd) { - if(cmd->id() == DSPSignalNotification::ID()) { + if(DSPSignalNotification::match(cmd)) { DSPSignalNotification* signal = (DSPSignalNotification*)cmd; qDebug("%d samples/sec, %lld Hz offset", signal->getSampleRate(), signal->getFrequencyOffset()); m_inputSampleRate = signal->getSampleRate(); @@ -106,7 +106,7 @@ bool TCPSrc::handleMessage(Message* cmd) m_sampleDistanceRemain = m_inputSampleRate / m_outputSampleRate; cmd->completed(); return true; - } else if(cmd->id() == MsgTCPSrcConfigure::ID()) { + } else if(DSPSignalNotification::match(cmd)) { MsgTCPSrcConfigure* cfg = (MsgTCPSrcConfigure*)cmd; m_sampleFormat = cfg->getSampleFormat(); m_outputSampleRate = cfg->getOutputSampleRate(); @@ -121,7 +121,7 @@ bool TCPSrc::handleMessage(Message* cmd) m_sampleDistanceRemain = m_inputSampleRate / m_outputSampleRate; cmd->completed(); return true; - } else if(cmd->id() == MsgTCPSrcSpectrum::ID()) { + } else if(MsgTCPSrcSpectrum::match(cmd)) { MsgTCPSrcSpectrum* spc = (MsgTCPSrcSpectrum*)cmd; m_spectrumEnabled = spc->getEnabled(); cmd->completed(); diff --git a/plugins/channel/tcpsrc/tcpsrc.h b/plugins/channel/tcpsrc/tcpsrc.h index a8270ff..012a4df 100644 --- a/plugins/channel/tcpsrc/tcpsrc.h +++ b/plugins/channel/tcpsrc/tcpsrc.h @@ -32,9 +32,9 @@ public: bool handleMessage(Message* cmd); class MsgTCPSrcConnection : public Message { - public: - static MessageRegistrator ID; + MESSAGE_CLASS_DECLARATION + public: bool getConnect() const { return m_connect; } quint32 getID() const { return m_id; } const QHostAddress& getPeerAddress() const { return m_peerAddress; } @@ -52,7 +52,7 @@ public: int m_peerPort; MsgTCPSrcConnection(bool connect, quint32 id, const QHostAddress& peerAddress, int peerPort) : - Message(ID()), + Message(), m_connect(connect), m_id(id), m_peerAddress(peerAddress), @@ -62,9 +62,9 @@ public: protected: class MsgTCPSrcConfigure : public Message { - public: - static MessageRegistrator ID; + MESSAGE_CLASS_DECLARATION + public: SampleFormat getSampleFormat() const { return m_sampleFormat; } Real getOutputSampleRate() const { return m_outputSampleRate; } Real getRFBandwidth() const { return m_rfBandwidth; } @@ -82,7 +82,7 @@ protected: int m_tcpPort; MsgTCPSrcConfigure(SampleFormat sampleFormat, Real outputSampleRate, Real rfBandwidth, int tcpPort) : - Message(ID()), + Message(), m_sampleFormat(sampleFormat), m_outputSampleRate(outputSampleRate), m_rfBandwidth(rfBandwidth), @@ -90,9 +90,9 @@ protected: { } }; class MsgTCPSrcSpectrum : public Message { - public: - static MessageRegistrator ID; + MESSAGE_CLASS_DECLARATION + public: bool getEnabled() const { return m_enabled; } static MsgTCPSrcSpectrum* create(bool enabled) @@ -104,7 +104,7 @@ protected: bool m_enabled; MsgTCPSrcSpectrum(bool enabled) : - Message(ID()), + Message(), m_enabled(enabled) { } }; diff --git a/plugins/channel/tcpsrc/tcpsrcgui.cpp b/plugins/channel/tcpsrc/tcpsrcgui.cpp index 5e8f13d..a7dcab2 100644 --- a/plugins/channel/tcpsrc/tcpsrcgui.cpp +++ b/plugins/channel/tcpsrc/tcpsrcgui.cpp @@ -98,11 +98,11 @@ bool TCPSrcGUI::deserialize(const QByteArray& data) bool TCPSrcGUI::handleMessage(Message* message) { - if(message->id() == TCPSrc::MsgTCPSrcConnection::ID()) { + if(TCPSrc::MsgTCPSrcConnection::match(message)) { TCPSrc::MsgTCPSrcConnection* con = (TCPSrc::MsgTCPSrcConnection*)message; if(con->getConnect()) - addConnection(con->id(), con->getPeerAddress(), con->getPeerPort()); - else delConnection(con->id()); + addConnection(con->getID(), con->getPeerAddress(), con->getPeerPort()); + else delConnection(con->getID()); message->completed(); return true; } else { |