Diff: cyclone_tcp/mqtt/mqtt_client_misc.h

Revision:

0:8918a71cdbe9

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cyclone_tcp/mqtt/mqtt_client_misc.h	Sat Feb 04 18:15:49 2017 +0000
@@ -0,0 +1,69 @@
+/**
+ * @file mqtt_client_misc.h
+ * @brief Helper functions for MQTT client
+ *
+ * @section License
+ *
+ * Copyright (C) 2010-2017 Oryx Embedded SARL. All rights reserved.
+ *
+ * This file is part of CycloneTCP Open.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * as published by the Free Software Foundation; either version 2
+ * of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ *
+ * @author Oryx Embedded SARL (www.oryx-embedded.com)
+ * @version 1.7.6
+ **/
+
+#ifndef _MQTT_CLIENT_MISC_H
+#define _MQTT_CLIENT_MISC_H
+
+//Dependencies
+#include "core/net.h"
+#include "mqtt/mqtt_client.h"
+
+//MQTT client related functions
+void mqttClientChangeState(MqttClientContext *context, MqttClientState newState);
+
+error_t mqttClientCheckKeepAlive(MqttClientContext *context);
+
+error_t mqttSerializeHeader(uint8_t *buffer, size_t *pos, MqttPacketType type,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttSerializeByte(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, uint8_t value);
+
+error_t mqttSerializeShort(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, uint16_t value);
+
+error_t mqttSerializeString(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, const void *string, size_t stringLen);
+
+error_t mqttSerializeData(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, const void *data, size_t dataLen);
+
+error_t mqttDeserializeHeader(uint8_t *buffer, size_t bufferLen, size_t *pos,
+   MqttPacketType *type, bool_t *dup, MqttQosLevel *qos, bool_t *retain, size_t *remainingLen);
+
+error_t mqttDeserializeByte(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, uint8_t *value);
+
+error_t mqttDeserializeShort(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, uint16_t *value);
+
+error_t mqttDeserializeString(uint8_t *buffer, size_t bufferLen,
+   size_t *pos, char_t **string, size_t *stringLen);
+
+#endif
+