mirror of
https://github.com/eclipse/paho.mqtt-sn.embedded-c.git
synced 2025-12-16 08:56:51 +01:00
@@ -116,6 +116,7 @@ typedef struct
|
|||||||
unsigned char version; /**< MQTT version number */
|
unsigned char version; /**< MQTT version number */
|
||||||
} Connect;
|
} Connect;
|
||||||
|
|
||||||
|
#define MQTTPacket_Connect_Initializer {{0}, 0, nullptr, nullptr, nullptr, nullptr, 0, 0}
|
||||||
#define MQTTPacket_willOptions_initializer { {'M', 'Q', 'T', 'W'}, 0, {NULL, {0, NULL}}, {NULL, {0, NULL}}, 0, 0 }
|
#define MQTTPacket_willOptions_initializer { {'M', 'Q', 'T', 'W'}, 0, {NULL, {0, NULL}}, {NULL, {0, NULL}}, 0, 0 }
|
||||||
#define MQTTPacket_connectData_initializer { {'M', 'Q', 'T', 'C'}, 0, 4, {NULL, {0, NULL}}, 60, 1, 0, \
|
#define MQTTPacket_connectData_initializer { {'M', 'Q', 'T', 'C'}, 0, 4, {NULL, {0, NULL}}, 60, 1, 0, \
|
||||||
MQTTPacket_willOptions_initializer, {NULL, {0, NULL}}, {NULL, {0, NULL}} }
|
MQTTPacket_willOptions_initializer, {NULL, {0, NULL}}, {NULL, {0, NULL}} }
|
||||||
@@ -173,6 +174,7 @@ typedef struct
|
|||||||
int payloadlen; /**< payload length */
|
int payloadlen; /**< payload length */
|
||||||
} Publish;
|
} Publish;
|
||||||
|
|
||||||
|
#define MQTTPacket_Publish_Initializer {{0}, nullptr, 0, 0, nullptr, 0}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Data for one of the ack packets.
|
* Data for one of the ack packets.
|
||||||
|
|||||||
@@ -44,7 +44,7 @@ Client::Client(bool secure)
|
|||||||
_clientId = nullptr;
|
_clientId = nullptr;
|
||||||
_willTopic = nullptr;
|
_willTopic = nullptr;
|
||||||
_willMsg = nullptr;
|
_willMsg = nullptr;
|
||||||
_connectData = {0, 0, 0, 0, 0, 0, 0};
|
_connectData = MQTTPacket_Connect_Initializer;
|
||||||
_network = new Network(secure);
|
_network = new Network(secure);
|
||||||
_secureNetwork = secure;
|
_secureNetwork = secure;
|
||||||
_sensorNetype = true;
|
_sensorNetype = true;
|
||||||
|
|||||||
@@ -39,7 +39,6 @@ public:
|
|||||||
private:
|
private:
|
||||||
void sendStoredPublish(Client* client);
|
void sendStoredPublish(Client* client);
|
||||||
|
|
||||||
char _pbuf[MQTTSNGW_MAX_PACKET_SIZE * 3];
|
|
||||||
Gateway* _gateway;
|
Gateway* _gateway;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -44,7 +44,7 @@ MQTTGWPacket* MQTTSNPublishHandler::handlePublish(Client* client, MQTTSNPacket*
|
|||||||
uint8_t* payload;
|
uint8_t* payload;
|
||||||
MQTTSN_topicid topicid;
|
MQTTSN_topicid topicid;
|
||||||
int payloadlen;
|
int payloadlen;
|
||||||
Publish pub = {0, 0, 0, 0, 0, 0};
|
Publish pub = MQTTPacket_Publish_Initializer;
|
||||||
|
|
||||||
char shortTopic[2];
|
char shortTopic[2];
|
||||||
|
|
||||||
|
|||||||
@@ -443,7 +443,7 @@ TopicIdMapElement* TopicIdMap::add(uint16_t msgId, uint16_t topicId, MQTTSN_topi
|
|||||||
{
|
{
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
if ( getElement(msgId) > 0 )
|
if ( getElement(msgId) )
|
||||||
{
|
{
|
||||||
erase(msgId);
|
erase(msgId);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user