MQTTPacket library (clone of https://os.mbed.com/teams/mqtt/code/MQTTPacket/)
MQTTPacket.h
- Committer:
- icraggs
- Date:
- 2014-04-10
- Revision:
- 2:bc3bc0e3b764
- Parent:
- 0:7734401cc1b4
- Child:
- 4:c502573c6016
File content as of revision 2:bc3bc0e3b764:
/******************************************************************************* * 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 *******************************************************************************/ #ifndef MQTTPACKET_H_ #define MQTTPACKET_H_ #if defined(__cplusplus) /* If this is a C++ compiler, use C linkage */ extern "C" { #endif enum errors { MQTTPACKET_BUFFER_TOO_SHORT = -2, MQTTPACKET_READ_ERROR = -1, MQTTPACKET_READ_COMPLETE, }; enum msgTypes { CONNECT = 1, CONNACK, PUBLISH, PUBACK, PUBREC, PUBREL, PUBCOMP, SUBSCRIBE, SUBACK, UNSUBSCRIBE, UNSUBACK, PINGREQ, PINGRESP, DISCONNECT }; /** * Bitfields for the MQTT header byte. */ typedef union { /*unsigned*/ char byte; /**< the whole byte */ #if defined(REVERSED) struct { unsigned int type : 4; /**< message type nibble */ unsigned int dup : 1; /**< DUP flag bit */ unsigned int qos : 2; /**< QoS value, 0, 1 or 2 */ unsigned int retain : 1; /**< retained flag bit */ } bits; #else struct { unsigned int retain : 1; /**< retained flag bit */ unsigned int qos : 2; /**< QoS value, 0, 1 or 2 */ unsigned int dup : 1; /**< DUP flag bit */ unsigned int type : 4; /**< message type nibble */ } bits; #endif } MQTTHeader; typedef struct { int len; char* data; } MQTTLenString; typedef struct { char* cstring; MQTTLenString lenstring; } MQTTString; #define MQTTString_initializer {NULL, {0, NULL}} int MQTTstrlen(MQTTString mqttstring); #include "MQTTConnect.h" #include "MQTTPublish.h" #include "MQTTSubscribe.h" #include "MQTTUnsubscribe.h" int MQTTDeserialize_ack(int* type, int* dup, int* packetid, char* buf, int buflen); int MQTTPacket_len(int rem_len); int MQTTPacket_encode(char* buf, int length); int MQTTPacket_decode(int (*getcharfn)(char*, int), int* value); int MQTTPacket_decodeBuf(char* buf, int* value); int readInt(char** pptr); char readChar(char** pptr); void writeChar(char** pptr, char c); void writeInt(char** pptr, int anInt); int readMQTTLenString(MQTTString* mqttstring, char** pptr, char* enddata); void writeCString(char** pptr, char* string); void writeMQTTString(char** pptr, MQTTString mqttstring); int MQTTPacket_read(char* buf, int buflen, int (*getfn)(char*, int)); #ifdef __cplusplus /* If this is a C++ compiler, use C linkage */ } #endif #endif /* MQTTPACKET_H_ */