12345678910111213141516171819202122232425262728293031323334353637383940 |
- #include "querymsg.h"
- #include <QCoreApplication>
- #include <iostream>
- static int gnquery = 1;
- querymsg::querymsg(QObject *parent) : QObject(parent)
- {
- mmsg = QDBusMessage::createSignal("/catarc/adc", "adciv.interface", "modulemsgquery");
- mmsg<<1;
- bool bconnect = QDBusConnection::sessionBus().connect(QString(),"/catarc/adc", "adciv.interface", "modulemsgres",this,SLOT(onQuery(QByteArray)));
- QTimer * timer = new QTimer();
- connect(timer,SIGNAL(timeout()),this,SLOT(onTimer()));
- timer->start(5000);
- std::cout<<gnquery<<".query:"<<std::endl;
- QDBusConnection::sessionBus().send(mmsg);
- }
- void querymsg::onTimer()
- {
- gnquery++;
- std::cout<<gnquery<<".query:"<<std::endl;
- QDBusConnection::sessionBus().send(mmsg);
- // QCoreApplication::exit();
- }
- void querymsg::onQuery(QByteArray ba)
- {
- if(ba.size() < sizeof(iv::modulemsg_type))
- {
- std::cout<<" querymsg::onQuery size error."<<std::endl;
- return;
- }
- iv::modulemsg_type xmodulemsg;
- memcpy((char *)&xmodulemsg,ba.data(),sizeof(iv::modulemsg_type));
- std::cout<<xmodulemsg.mstrmsgname<<"\t"<<xmodulemsg.mnBufSize<<"\t"<<xmodulemsg.mnMsgBufCount<<std::endl;
- }
|