Ajout polling du statut du board

This commit is contained in:
2024-02-22 16:11:48 -05:00
parent 098863edb9
commit da2dd28f1c
25 changed files with 1100 additions and 140 deletions
@@ -2,6 +2,7 @@
#include "OtarcikCan.h"
#include "CANDevice.h"
#include "defines.h"
#include "ComputerBoardInterface.h"
CMQTTClientWrapper::CMQTTClientWrapper()
{
@@ -23,6 +24,7 @@ CMQTTClientWrapper::CMQTTClientWrapper()
mMQTTQueueFlushTimer->stop();
mProgramPtr = 0;
mCPUInterface = 0;
mMessagesQueueMode = MQTT_DROP_MSG_MODE;
mDisconnectionIsVoluntary = false;
mIsClientConnecting = false;
@@ -46,6 +48,11 @@ int CMQTTClientWrapper::SetMQTTParams(CCloudParams *Params)
return RET_OK;
}
int CMQTTClientWrapper::SetCPUInterface(CComputerBoardInterface *CPUIF)
{
mCPUInterface = CPUIF;
}
int CMQTTClientWrapper::StartMQTTClient()
{
mMQTTRefreshTimer->start(mMQTTParams.mMQTTTransmitTimeout);
@@ -214,6 +221,11 @@ void CMQTTClientWrapper::MQTTSendTimerExpired()
{
CCANDevice *Device = mCANDevicesList->at(j);
QList<CMQTTMessage> *MessagesList = Device->GetMQTTMessagesList();
if(mCPUInterface)
{
CComputerBoardState tmp =mCPUInterface->GetComputerBoardState();
}
if(MessagesList != 0)
{
for(int i = 0; i < MessagesList->size(); i++)
@@ -231,6 +243,11 @@ void CMQTTClientWrapper::MQTTSendTimerExpired()
{
CCANDevice *Device = mCANDevicesList->at(j);
QList<CMQTTMessage> *MessagesList = Device->GetMQTTMessagesList();
if(mCPUInterface)
{
CComputerBoardState tmp =mCPUInterface->GetComputerBoardState();
}
if(MessagesList != 0)
{
for(int i = 0; i < MessagesList->size(); i++)
@@ -10,8 +10,10 @@
#include <QList>
class COtarcikCan;
class CCANDevice;
class CComputerBoardInterface;
class CMQTTClientWrapper : public QObject
{
@@ -27,6 +29,7 @@ public:
CMQTTClientWrapper();
~CMQTTClientWrapper();
int SetMQTTParams(CCloudParams *Params);
int SetCPUInterface(CComputerBoardInterface *CPUIF);
int ConnectToBroker();
int NewMQTTMessages(QList<CMQTTMessage> MessagesList);
int DisconnectFromBroker();
@@ -50,6 +53,7 @@ private:
QList<CMQTTMessage*> mMQTTMessagesQueue;
bool mIsClientConnecting;
QString mCircularBufferStatusText, mBufferingModeText, mUploadTimeText;
CComputerBoardInterface *mCPUInterface;
int SendNextQueueMessage();