Ian Craggs
Low level MQTTSN packet library, part of the Eclipse Paho project: http://eclipse.org/paho
Dependents: MQTTSN sara-n200-hello-mqtt-sn MQTTSN_2
The master source for this project is held at: https://github.com/eclipse/paho.mqtt-sn.embedded-c
Diff: MQTTSNSubscribeServer.c
- Revision:
- 1:7fa362fa563f
- Parent:
- 0:c524a894b5e8
--- a/MQTTSNSubscribeServer.c Thu Feb 26 15:59:36 2015 +0000
+++ b/MQTTSNSubscribeServer.c Wed Jan 06 14:19:27 2016 +0000
@@ -44,14 +44,14 @@
if (enddata - curdata > buflen)
goto exit;
- if (readChar(&curdata) != MQTTSN_SUBSCRIBE)
+ if (MQTTSNPacket_readChar(&curdata) != MQTTSN_SUBSCRIBE)
goto exit;
- flags.all = readChar(&curdata);
+ flags.all = MQTTSNPacket_readChar(&curdata);
*dup = flags.bits.dup;
*qos = flags.bits.QoS;
- *packetid = readInt(&curdata);
+ *packetid = MQTTSNPacket_readInt(&curdata);
topicFilter->type = flags.bits.topicIdType;
@@ -61,11 +61,11 @@
topicFilter->data.long_.name = (char*)curdata;
}
else if (topicFilter->type == MQTTSN_TOPIC_TYPE_PREDEFINED)
- topicFilter->data.id = readInt(&curdata);
+ topicFilter->data.id = MQTTSNPacket_readInt(&curdata);
else if (topicFilter->type == MQTTSN_TOPIC_TYPE_SHORT)
{
- topicFilter->data.short_name[0] = readChar(&curdata);
- topicFilter->data.short_name[1] = readChar(&curdata);
+ topicFilter->data.short_name[0] = MQTTSNPacket_readChar(&curdata);
+ topicFilter->data.short_name[1] = MQTTSNPacket_readChar(&curdata);
}
rc = 1;
@@ -100,15 +100,15 @@
goto exit;
}
ptr += MQTTSNPacket_encode(ptr, len); /* write length */
- writeChar(&ptr, MQTTSN_SUBACK); /* write message type */
+ MQTTSNPacket_writeChar(&ptr, MQTTSN_SUBACK); /* write message type */
flags.all = 0;
flags.bits.QoS = qos;
- writeChar(&ptr, flags.all);
+ MQTTSNPacket_writeChar(&ptr, flags.all);
- writeInt(&ptr, topicid);
- writeInt(&ptr, packetid);
- writeChar(&ptr, returncode);
+ MQTTSNPacket_writeInt(&ptr, topicid);
+ MQTTSNPacket_writeInt(&ptr, packetid);
+ MQTTSNPacket_writeChar(&ptr, returncode);
rc = ptr - buf;
exit: