/******************************************************************************* | |
* Copyright (c) 2014 IBM Corp. | |
* | |
* All rights reserved. This program and the accompanying materials | |
* are made available under the terms of the Eclipse Public License v1.0 | |
* and Eclipse Distribution License v1.0 which accompany this distribution. | |
* | |
* The Eclipse Public License is available at | |
* http://www.eclipse.org/legal/epl-v10.html | |
* and the Eclipse Distribution License is available at | |
* http://www.eclipse.org/org/documents/edl-v10.php. | |
* | |
* Contributors: | |
* Ian Craggs - initial API and implementation and/or initial documentation | |
*******************************************************************************/ | |
#include "MQTTPacket.h" | |
#include "StackTrace.h" | |
#include <string.h> | |
/** | |
* Deserializes the supplied (wire) buffer into unsubscribe data | |
* @param dup integer returned - the MQTT dup flag | |
* @param packetid integer returned - the MQTT packet identifier | |
* @param maxcount - the maximum number of members allowed in the topicFilters and requestedQoSs arrays | |
* @param count - number of members in the topicFilters and requestedQoSs arrays | |
* @param topicFilters - array of topic filter names | |
* @param buf the raw buffer data, of the correct length determined by the remaining length field | |
* @param buflen the length in bytes of the data in the supplied buffer | |
* @return the length of the serialized data. <= 0 indicates error | |
*/ | |
int MQTTDeserialize_unsubscribe(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[], | |
unsigned char* buf, int len) | |
{ | |
MQTTHeader header = {0}; | |
unsigned char* curdata = buf; | |
unsigned char* enddata = NULL; | |
int rc = 0; | |
int mylen = 0; | |
FUNC_ENTRY; | |
header.byte = readChar(&curdata); | |
if (header.bits.type != UNSUBSCRIBE) | |
goto exit; | |
*dup = header.bits.dup; | |
curdata += (rc = MQTTPacket_decodeBuf(curdata, &mylen)); /* read remaining length */ | |
enddata = curdata + mylen; | |
*packetid = readInt(&curdata); | |
*count = 0; | |
while (curdata < enddata) | |
{ | |
if (!readMQTTLenString(&topicFilters[*count], &curdata, enddata)) | |
goto exit; | |
(*count)++; | |
} | |
rc = 1; | |
exit: | |
FUNC_EXIT_RC(rc); | |
return rc; | |
} | |
/** | |
* Serializes the supplied unsuback data into the supplied buffer, ready for sending | |
* @param buf the buffer into which the packet will be serialized | |
* @param buflen the length in bytes of the supplied buffer | |
* @param packetid integer - the MQTT packet identifier | |
* @return the length of the serialized data. <= 0 indicates error | |
*/ | |
int MQTTSerialize_unsuback(unsigned char* buf, int buflen, unsigned short packetid) | |
{ | |
MQTTHeader header = {0}; | |
int rc = 0; | |
unsigned char *ptr = buf; | |
FUNC_ENTRY; | |
if (buflen < 2) | |
{ | |
rc = MQTTPACKET_BUFFER_TOO_SHORT; | |
goto exit; | |
} | |
header.byte = 0; | |
header.bits.type = UNSUBACK; | |
writeChar(&ptr, header.byte); /* write header */ | |
ptr += MQTTPacket_encode(ptr, 2); /* write remaining length */ | |
writeInt(&ptr, packetid); | |
rc = ptr - buf; | |
exit: | |
FUNC_EXIT_RC(rc); | |
return rc; | |
} | |