remove paho.mqtt.c

deps/paho.mqtt.c/CMakeLists.txt

-CMAKE_MINIMUM_REQUIRED(VERSION 2.8)
-PROJECT(TDengine)
-INCLUDE_DIRECTORIES(inc)
-AUX_SOURCE_DIRECTORY(src SRC)
-ADD_LIBRARY(pahomqtt ${SRC})
\ No newline at end of file

deps/paho.mqtt.c/inc/Base64.h

-/*******************************************************************************
- * Copyright (c) 2018 Wind River Systems, Inc. All Rights Reserved.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution.
- *
- * The Eclipse Public License is available at
- *    https://www.eclipse.org/legal/epl-2.0/
- * and the Eclipse Distribution License is available at
- *   http://www.eclipse.org/org/documents/edl-v10.php.
- *
- * Contributors:
- *    Keith Holman - initial implementation and documentation
- *******************************************************************************/
-
-#if !defined(BASE64_H)
-#define BASE64_H
-
-/** type for size of a buffer, it saves passing around @p size_t (unsigned long long or unsigned long int) */
-typedef unsigned int b64_size_t;
-/** type for raw base64 data */
-typedef unsigned char b64_data_t;
-
-/**
- * Decodes base64 data
- *
- * @param[out]     out                 decoded data
- * @param[in]      out_len             length of output buffer
- * @param[in]      in                  base64 string to decode
- * @param[in]      in_len              length of input buffer
- *
- * @return the amount of data decoded
- *
- * @see Base64_decodeLength
- * @see Base64_encode
- */
-b64_size_t Base64_decode( b64_data_t *out, b64_size_t out_len,
-	const char *in, b64_size_t in_len );
-
-/**
- * Size of buffer required to decode base64 data
- *
- * @param[in]      in                  base64 string to decode
- * @param[in]      in_len              length of input buffer
- *
- * @return the size of buffer the decoded string would require
- *
- * @see Base64_decode
- * @see Base64_encodeLength
- */
-b64_size_t Base64_decodeLength( const char *in, b64_size_t in_len );
-
-/**
- * Encodes base64 data
- *
- * @param[out]     out                 encode base64 string
- * @param[in]      out_len             length of output buffer
- * @param[in]      in                  raw data to encode
- * @param[in]      in_len              length of input buffer
- *
- * @return the amount of data encoded
- *
- * @see Base64_decode
- * @see Base64_encodeLength
- */
-b64_size_t Base64_encode( char *out, b64_size_t out_len,
-	const b64_data_t *in, b64_size_t in_len );
-
-/**
- * Size of buffer required to encode base64 data
- *
- * @param[in]      in                  raw data to encode
- * @param[in]      in_len              length of input buffer
- *
- * @return the size of buffer the encoded string would require
- *
- * @see Base64_decodeLength
- * @see Base64_encode
- */
-b64_size_t Base64_encodeLength( const b64_data_t *in, b64_size_t in_len );
-
-#endif /* BASE64_H */

deps/paho.mqtt.c/inc/Clients.h

-/*******************************************************************************
- * Copyright (c) 2009, 2020 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs - add SSL support
- *    Ian Craggs - fix for bug 413429 - connectionLost not called
- *    Ian Craggs - change will payload to binary
- *    Ian Craggs - password to binary
- *    Ian Craggs - MQTT 5 support
- *******************************************************************************/
-
-#if !defined(CLIENTS_H)
-#define CLIENTS_H
-
-#include "MQTTTime.h"
-#if defined(OPENSSL)
-#if defined(_WIN32) || defined(_WIN64)
-#include <winsock2.h>
-#endif
-#include <openssl/ssl.h>
-#endif
-#include "MQTTClient.h"
-#include "LinkedList.h"
-#include "MQTTClientPersistence.h"
-
-/**
- * Stored publication data to minimize copying
- */
-typedef struct
-{
-	char *topic;
-	int topiclen;
-	char* payload;
-	int payloadlen;
-	int refcount;
-} Publications;
-
-/**
- * Client publication message data
- */
-typedef struct
-{
-	int qos;
-	int retain;
-	int msgid;
-	int MQTTVersion;
-	MQTTProperties properties;
-	Publications *publish;
-	START_TIME_TYPE lastTouch;		    /**> used for retry and expiry */
-	char nextMessageType;	/**> PUBREC, PUBREL, PUBCOMP */
-	int len;				/**> length of the whole structure+data */
-} Messages;
-
-/**
- * Client will message data
- */
-typedef struct
-{
-	char *topic;
-	int payloadlen;
-	void *payload;
-	int retained;
-	int qos;
-} willMessages;
-
-typedef struct
-{
-	int socket;
-	START_TIME_TYPE lastSent;
-	START_TIME_TYPE lastReceived;
-	START_TIME_TYPE lastPing;
-#if defined(OPENSSL)
-	SSL* ssl;
-	SSL_CTX* ctx;
-	char *https_proxy;
-	char *https_proxy_auth;
-#endif
-	char *http_proxy;
-	char *http_proxy_auth;
-	int websocket; /**< socket has been upgraded to use web sockets */
-	char *websocket_key;
-	const MQTTClient_nameValue* httpHeaders;
-} networkHandles;
-
-
-/* connection states */
-/** no connection in progress, see connected value */
-#define NOT_IN_PROGRESS  0x0
-/** TCP connection in progress */
-#define TCP_IN_PROGRESS  0x1
-/** SSL connection in progress */
-#define SSL_IN_PROGRESS  0x2
-/** Websocket connection in progress */
-#define WEBSOCKET_IN_PROGRESS   0x3
-/** TCP completed, waiting for MQTT ACK */
-#define WAIT_FOR_CONNACK 0x4
-/** Proxy connection in progress */
-#define PROXY_CONNECT_IN_PROGRESS 0x5
-/** Disconnecting */
-#define DISCONNECTING    -2
-
-/**
- * Data related to one client
- */
-typedef struct
-{
-	char* clientID;					      /**< the string id of the client */
-	const char* username;					/**< MQTT v3.1 user name */
-	int passwordlen;              /**< MQTT password length */
-	const void* password;					/**< MQTT v3.1 binary password */
-	unsigned int cleansession : 1;	/**< MQTT V3 clean session flag */
-	unsigned int cleanstart : 1;		/**< MQTT V5 clean start flag */
-	unsigned int connected : 1;		/**< whether it is currently connected */
-	unsigned int good : 1; 			  /**< if we have an error on the socket we turn this off */
-	unsigned int ping_outstanding : 1;
-	signed int connect_state : 4;
-	networkHandles net;             /**< network info for this client */
-	int msgID;                      /**< the MQTT message id */
-	int keepAliveInterval;          /**< the MQTT keep alive interval */
-	int retryInterval;
-	int maxInflightMessages;        /**< the max number of inflight outbound messages we allow */
-	willMessages* will;             /**< the MQTT will message, if any */
-	List* inboundMsgs;              /**< inbound in flight messages */
-	List* outboundMsgs;				/**< outbound in flight messages */
-	List* messageQueue;             /**< inbound complete but undelivered messages */
-	unsigned int qentry_seqno;
-	void* phandle;                  /**< the persistence handle */
-	MQTTClient_persistence* persistence; /**< a persistence implementation */
-	void* context; /* calling context - used when calling disconnect_internal */
-	int MQTTVersion;                /**< the version of MQTT being used, 3, 4 or 5 */
-	int sessionExpiry;              /**< MQTT 5 session expiry */
-#if defined(OPENSSL)
-	MQTTClient_SSLOptions *sslopts; /**< the SSL/TLS connect options */
-	SSL_SESSION* session;           /**< SSL session pointer for fast handhake */
-#endif
-} Clients;
-
-int clientIDCompare(void* a, void* b);
-int clientSocketCompare(void* a, void* b);
-
-/**
- * Configuration data related to all clients
- */
-typedef struct
-{
-	const char* version;
-	List* clients;
-} ClientStates;
-
-#endif

deps/paho.mqtt.c/inc/Heap.h

-/*******************************************************************************
- * Copyright (c) 2009, 2020 IBM Corp. and others
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs - use tree data structure instead of list
- *******************************************************************************/
-
-
-#if !defined(HEAP_H)
-#define HEAP_H
-
-#if defined(HIGH_PERFORMANCE)
-#define NO_HEAP_TRACKING 1
-#endif
-
-#define PAHO_MEMORY_ERROR -99
-
-#include "MQTTExportDeclarations.h"
-
-#include <stdio.h>
-#include <stdlib.h>
-
-#if !defined(NO_HEAP_TRACKING)
-
-#if !defined(TREE_C)
-/**
- * redefines malloc to use "mymalloc" so that heap allocation can be tracked
- * @param x the size of the item to be allocated
- * @return the pointer to the item allocated, or NULL
- */
-#define malloc(x) mymalloc(__FILE__, __LINE__, x)
-
-/**
- * redefines realloc to use "myrealloc" so that heap allocation can be tracked
- * @param a the heap item to be reallocated
- * @param b the new size of the item
- * @return the new pointer to the heap item
- */
-#define realloc(a, b) myrealloc(__FILE__, __LINE__, a, b)
-
-/**
- * redefines free to use "myfree" so that heap allocation can be tracked
- * @param x the size of the item to be freed
- */
-#define free(x) myfree(__FILE__, __LINE__, x)
-
-#endif
-
-/**
- * Information about the state of the heap.
- */
-typedef struct
-{
-	size_t current_size;	/**< current size of the heap in bytes */
-	size_t max_size;		/**< max size the heap has reached in bytes */
-} heap_info;
-
-#if defined(__cplusplus)
- extern "C" {
-#endif
-
-void* mymalloc(char*, int, size_t size);
-void* myrealloc(char*, int, void* p, size_t size);
-void myfree(char*, int, void* p);
-
-void Heap_scan(FILE* file);
-int Heap_initialize(void);
-void Heap_terminate(void);
-LIBMQTT_API heap_info* Heap_get_info(void);
-int HeapDump(FILE* file);
-int HeapDumpString(FILE* file, char* str);
-void* Heap_findItem(void* p);
-void Heap_unlink(char* file, int line, void* p);
-#ifdef __cplusplus
-     }
-#endif
-
-#endif
-
-#endif

deps/paho.mqtt.c/inc/LinkedList.h

-/*******************************************************************************
- * Copyright (c) 2009, 2020 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs - updates for the async client
- *    Ian Craggs - change size types from int to size_t
- *******************************************************************************/
-
-#if !defined(LINKEDLIST_H)
-#define LINKEDLIST_H
-
-#include <stdlib.h> /* for size_t definition */
-
-/*BE
-defm defList(T)
-
-def T concat Item
-{
-	at 4
-	n32 ptr T concat Item suppress "next"
-	at 0
-	n32 ptr T concat Item suppress "prev"
-	at 8
-	n32 ptr T id2str(T)
-}
-
-def T concat List
-{
-	n32 ptr T concat Item suppress "first"
-	n32 ptr T concat Item suppress "last"
-	n32 ptr T concat Item suppress "current"
-	n32 dec "count"
-	n32 suppress "size"
-}
-endm
-
-defList(INT)
-defList(STRING)
-defList(TMP)
-
-BE*/
-
-/**
- * Structure to hold all data for one list element
- */
-typedef struct ListElementStruct
-{
-	struct ListElementStruct *prev, /**< pointer to previous list element */
-							*next;	/**< pointer to next list element */
-	void* content;					/**< pointer to element content */
-} ListElement;
-
-
-/**
- * Structure to hold all data for one list
- */
-typedef struct
-{
-	ListElement *first,	/**< first element in the list */
-				*last,	/**< last element in the list */
-				*current;	/**< current element in the list, for iteration */
-	int count;  /**< no of items */
-	size_t size;  /**< heap storage used */
-} List;
-
-void ListZero(List*);
-List* ListInitialize(void);
-
-ListElement* ListAppend(List* aList, void* content, size_t size);
-void ListAppendNoMalloc(List* aList, void* content, ListElement* newel, size_t size);
-ListElement* ListInsert(List* aList, void* content, size_t size, ListElement* index);
-
-int ListRemove(List* aList, void* content);
-int ListRemoveItem(List* aList, void* content, int(*callback)(void*, void*));
-void* ListDetachHead(List* aList);
-int ListRemoveHead(List* aList);
-void* ListPopTail(List* aList);
-
-int ListDetach(List* aList, void* content);
-int ListDetachItem(List* aList, void* content, int(*callback)(void*, void*));
-
-void ListFree(List* aList);
-void ListEmpty(List* aList);
-void ListFreeNoContent(List* aList);
-
-ListElement* ListNextElement(List* aList, ListElement** pos);
-ListElement* ListPrevElement(List* aList, ListElement** pos);
-
-ListElement* ListFind(List* aList, void* content);
-ListElement* ListFindItem(List* aList, void* content, int(*callback)(void*, void*));
-
-int intcompare(void* a, void* b);
-int stringcompare(void* a, void* b);
-
-#endif

deps/paho.mqtt.c/inc/Log.h

-/*******************************************************************************
- * Copyright (c) 2009, 2013 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs - updates for the async client
- *******************************************************************************/
-
-#if !defined(LOG_H)
-#define LOG_H
-
-/*BE
-map LOG_LEVELS
-{
-	"TRACE_MAXIMUM" 1
-	"TRACE_MEDIUM" 2
-	"TRACE_MINIMUM" 3
-	"TRACE_PROTOCOL" 4
-
-	"ERROR" 5
-	"SEVERE" 6
-	"FATAL" 7
-}
-BE*/
-
-enum LOG_LEVELS {
-	INVALID_LEVEL = -1,
-	TRACE_MAXIMUM = 1,
-	TRACE_MEDIUM,
-	TRACE_MINIMUM,
-	TRACE_PROTOCOL,
-	LOG_ERROR,
-	LOG_SEVERE,
-	LOG_FATAL,
-};
-
-
-/*BE
-def trace_settings_type
-{
-   n32 map LOG_LEVELS "trace_level"
-   n32 dec "max_trace_entries"
-   n32 dec "trace_output_level"
-}
-BE*/
-typedef struct
-{
-	enum LOG_LEVELS trace_level;	/**< trace level */
-	int max_trace_entries;		/**< max no of entries in the trace buffer */
-	enum LOG_LEVELS trace_output_level;		/**< trace level to output to destination */
-} trace_settings_type;
-
-extern trace_settings_type trace_settings;
-
-#define LOG_PROTOCOL TRACE_PROTOCOL
-#define TRACE_MAX TRACE_MAXIMUM
-#define TRACE_MIN TRACE_MINIMUM
-#define TRACE_MED TRACE_MEDIUM
-
-typedef struct
-{
-	const char* name;
-	const char* value;
-} Log_nameValue;
-
-int Log_initialize(Log_nameValue*);
-void Log_terminate(void);
-
-void Log(enum LOG_LEVELS, int, const char *, ...);
-void Log_stackTrace(enum LOG_LEVELS, int, int, int, const char*, int, int*);
-
-typedef void Log_traceCallback(enum LOG_LEVELS level, const char *message);
-void Log_setTraceCallback(Log_traceCallback* callback);
-void Log_setTraceLevel(enum LOG_LEVELS level);
-
-#endif

deps/paho.mqtt.c/inc/MQTTClientPersistence.h

-/*******************************************************************************
- * Copyright (c) 2009, 2012 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *******************************************************************************/
-
-/**
- * @file
- * \brief This structure represents a persistent data store, used to store 
- * outbound and inbound messages, in order to achieve reliable messaging.
- *
- * The MQTT Client persists QoS1 and QoS2 messages in order to meet the
- * assurances of delivery associated with these @ref qos levels. The messages 
- * are saved in persistent storage
- * The type and context of the persistence implementation are specified when 
- * the MQTT client is created (see MQTTClient_create()). The default 
- * persistence type (::MQTTCLIENT_PERSISTENCE_DEFAULT) uses a file system-based
- * persistence mechanism. The <i>persistence_context</i> argument passed to 
- * MQTTClient_create() when using the default peristence is a string 
- * representing the location of the persistence directory. If the context 
- * argument is NULL, the working directory will be used. 
- *
- * To use memory-based persistence, an application passes 
- * ::MQTTCLIENT_PERSISTENCE_NONE as the <i>persistence_type</i> to 
- * MQTTClient_create(). This can lead to message loss in certain situations, 
- * but can be appropriate in some cases (see @ref qos).
- *
- * Client applications can provide their own persistence mechanism by passing
- * ::MQTTCLIENT_PERSISTENCE_USER as the <i>persistence_type</i>. To implement a
- * custom persistence mechanism, the application must pass an initialized
- * ::MQTTClient_persistence structure as the <i>persistence_context</i> 
- * argument to MQTTClient_create().
- *
- * If the functions defined return an ::MQTTCLIENT_PERSISTENCE_ERROR then the 
- * state of the persisted data should remain as it was prior to the function 
- * being called. For example, if Persistence_put() returns 
- * ::MQTTCLIENT_PERSISTENCE_ERROR, then it is assumed tha tthe persistent store
- * does not contain the data that was passed to the function. Similarly,  if 
- * Persistence_remove() returns ::MQTTCLIENT_PERSISTENCE_ERROR then it is 
- * assumed that the data to be removed is still held in the persistent store.
- *
- * It is up to the persistence implementation to log any error information that
- * may be required to diagnose a persistence mechanism failure.
- */
-
-/*
-/// @cond EXCLUDE
-*/
-#if !defined(MQTTCLIENTPERSISTENCE_H)
-#define MQTTCLIENTPERSISTENCE_H
-/*
-/// @endcond
-*/
-
-/**
-  * This <i>persistence_type</i> value specifies the default file system-based 
-  * persistence mechanism (see MQTTClient_create()).
-  */
-#define MQTTCLIENT_PERSISTENCE_DEFAULT 0
-/**
-  * This <i>persistence_type</i> value specifies a memory-based 
-  * persistence mechanism (see MQTTClient_create()).
-  */
-#define MQTTCLIENT_PERSISTENCE_NONE 1
-/**
-  * This <i>persistence_type</i> value specifies an application-specific 
-  * persistence mechanism (see MQTTClient_create()).
-  */
-#define MQTTCLIENT_PERSISTENCE_USER 2
-
-/** 
-  * Application-specific persistence functions must return this error code if 
-  * there is a problem executing the function. 
-  */
-#define MQTTCLIENT_PERSISTENCE_ERROR -2
-
-/**
-  * @brief Initialize the persistent store.
-  * 
-  * Either open the existing persistent store for this client ID or create a new
-  * one if one doesn't exist. If the persistent store is already open, return 
-  * without taking any action.
-  *
-  * An application can use the same client identifier to connect to many
-  * different servers. The <i>clientid</i> in conjunction with the 
-  * <i>serverURI</i> uniquely identifies the persistence store required.
-  *
-  * @param handle The address of a pointer to a handle for this persistence 
-  * implementation. This function must set handle to a valid reference to the 
-  * persistence following a successful return. 
-  * The handle pointer is passed as an argument to all the other
-  * persistence functions. It may include the context parameter and/or any other
-  * data for use by the persistence functions.
-  * @param clientID The client identifier for which the persistent store should 
-  * be opened.
-  * @param serverURI The connection string specified when the MQTT client was
-  * created (see MQTTClient_create()).
-  * @param context A pointer to any data required to initialize the persistent
-  * store (see ::MQTTClient_persistence).
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_open)(void** handle, const char* clientID, const char* serverURI, void* context);
-
-/**
-  * @brief Close the persistent store referred to by the handle.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_close)(void* handle); 
-
-/**
-  * @brief Put the specified data into the persistent store.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @param key A string used as the key for the data to be put in the store. The
-  * key is later used to retrieve data from the store with Persistence_get().
-  * @param bufcount The number of buffers to write to the persistence store.
-  * @param buffers An array of pointers to the data buffers associated with 
-  * this <i>key</i>.
-  * @param buflens An array of lengths of the data buffers. <i>buflen[n]</i> 
-  * gives the length of <i>buffer[n]</i>.
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_put)(void* handle, char* key, int bufcount, char* buffers[], int buflens[]);
-
-/**
-  * @brief Retrieve the specified data from the persistent store. 
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @param key A string that is the key for the data to be retrieved. This is 
-  * the same key used to save the data to the store with Persistence_put().
-  * @param buffer The address of a pointer to a buffer. This function sets the
-  * pointer to point at the retrieved data, if successful.
-  * @param buflen The address of an int that is set to the length of 
-  * <i>buffer</i> by this function if successful.
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_get)(void* handle, char* key, char** buffer, int* buflen);
-
-/**
-  * @brief Remove the data for the specified key from the store.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @param key A string that is the key for the data to be removed from the
-  * store. This is the same key used to save the data to the store with 
-  * Persistence_put().
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_remove)(void* handle, char* key);
-
-/**
-  * @brief Returns the keys in this persistent data store.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @param keys The address of a pointer to pointers to strings. Assuming
-  * successful execution, this function allocates memory to hold the returned
-  * keys (strings used to store the data with Persistence_put()). It also 
-  * allocates memory to hold an array of pointers to these strings. <i>keys</i>
-  * is set to point to the array of pointers to strings.
-  * @param nkeys A pointer to the number of keys in this persistent data store. 
-  * This function sets the number of keys, if successful.
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_keys)(void* handle, char*** keys, int* nkeys);
-
-/**
-  * @brief Clears the persistence store, so that it no longer contains any 
-  * persisted data.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @return Return 0 if the function completes successfully, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_clear)(void* handle);
-
-/**
-  * @brief Returns whether any data has been persisted using the specified key.
-  *
-  * @param handle The handle pointer from a successful call to 
-  * Persistence_open().
-  * @param key The string to be tested for existence in the store.
-  * @return Return 0 if the key was found in the store, otherwise return
-  * ::MQTTCLIENT_PERSISTENCE_ERROR.
-  */
-typedef int (*Persistence_containskey)(void* handle, char* key);
-
-/**
-  * @brief A structure containing the function pointers to a persistence 
-  * implementation and the context or state that will be shared across all 
-  * the persistence functions.
-  */
-typedef struct {
-  /** 
-    * A pointer to any data required to initialize the persistent store.
-    */
-	void* context;
-  /** 
-    * A function pointer to an implementation of Persistence_open().
-    */
-	Persistence_open popen;
-  /** 
-    * A function pointer to an implementation of Persistence_close().
-    */
-	Persistence_close pclose;
-  /**
-    * A function pointer to an implementation of Persistence_put().
-    */
-	Persistence_put pput;
-  /** 
-    * A function pointer to an implementation of Persistence_get().
-    */
-	Persistence_get pget;
-  /** 
-    * A function pointer to an implementation of Persistence_remove().
-    */
-	Persistence_remove premove;
-  /** 
-    * A function pointer to an implementation of Persistence_keys().
-    */
-	Persistence_keys pkeys;
-  /** 
-    * A function pointer to an implementation of Persistence_clear().
-    */
-	Persistence_clear pclear;
-  /** 
-    * A function pointer to an implementation of Persistence_containskey().
-    */
-	Persistence_containskey pcontainskey;
-} MQTTClient_persistence;
-
-#endif

deps/paho.mqtt.c/inc/MQTTExportDeclarations.h

-/*******************************************************************************
- * Copyright (c) 2020, 2020 Andreas Walter
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution.
- *
- * The Eclipse Public License is available at
- *    https://www.eclipse.org/legal/epl-2.0/
- * and the Eclipse Distribution License is available at
- *   http://www.eclipse.org/org/documents/edl-v10.php.
- *
- * Contributors:
- *    Andreas Walter - initially moved export declarations into separate fle
- *******************************************************************************/
-
-#if !defined(EXPORTDECLARATIONS_H)
-#define EXPORTDECLARATIONS_H
-
-#if defined(_WIN32) || defined(_WIN64)
-#   if defined(PAHO_MQTT_EXPORTS)
-#       define LIBMQTT_API __declspec(dllexport)
-#   elif defined(PAHO_MQTT_IMPORTS)
-#       define LIBMQTT_API __declspec(dllimport)
-#   else
-#       define LIBMQTT_API
-#   endif
-#else
-#    if defined(PAHO_MQTT_EXPORTS)
-#       define LIBMQTT_API  __attribute__ ((visibility ("default")))
-#    else
-#       define LIBMQTT_API extern
-#    endif
-#endif
-
-#endif

deps/paho.mqtt.c/inc/MQTTPacketOut.h

-/*******************************************************************************
- * Copyright (c) 2009, 2018 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs, Allan Stockdill-Mander - SSL updates
- *    Ian Craggs - MQTT 3.1.1 support
- *    Ian Craggs - MQTT 5.0 support
- *******************************************************************************/
-
-#if !defined(MQTTPACKETOUT_H)
-#define MQTTPACKETOUT_H
-
-#include "MQTTPacket.h"
-
-int MQTTPacket_send_connect(Clients* client, int MQTTVersion,
-		MQTTProperties* connectProperties, MQTTProperties* willProperties);
-void* MQTTPacket_connack(int MQTTVersion, unsigned char aHeader, char* data, size_t datalen);
-void MQTTPacket_freeConnack(Connack* pack);
-
-int MQTTPacket_send_pingreq(networkHandles* net, const char* clientID);
-
-int MQTTPacket_send_subscribe(List* topics, List* qoss, MQTTSubscribe_options* opts, MQTTProperties* props,
-		int msgid, int dup, Clients* client);
-void* MQTTPacket_suback(int MQTTVersion, unsigned char aHeader, char* data, size_t datalen);
-
-int MQTTPacket_send_unsubscribe(List* topics, MQTTProperties* props, int msgid, int dup, Clients* client);
-void* MQTTPacket_unsuback(int MQTTVersion, unsigned char aHeader, char* data, size_t datalen);
-
-#endif

deps/paho.mqtt.c/inc/MQTTPersistenceDefault.h

-/*******************************************************************************
- * Copyright (c) 2009, 2018 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *******************************************************************************/
-
-#if !defined(MQTTPERSISTENCEDEFAULT_H)
-#define MQTTPERSISTENCEDEFAULT_H
-
-/** 8.3 filesystem */
-#define MESSAGE_FILENAME_LENGTH 8    
-/** Extension of the filename */
-#define MESSAGE_FILENAME_EXTENSION ".msg"
-
-/* prototypes of the functions for the default file system persistence */
-int pstopen(void** handle, const char* clientID, const char* serverURI, void* context); 
-int pstclose(void* handle); 
-int pstput(void* handle, char* key, int bufcount, char* buffers[], int buflens[]); 
-int pstget(void* handle, char* key, char** buffer, int* buflen); 
-int pstremove(void* handle, char* key); 
-int pstkeys(void* handle, char*** keys, int* nkeys); 
-int pstclear(void* handle); 
-int pstcontainskey(void* handle, char* key);
-
-int pstmkdir(char *pPathname);
-
-#endif
-

deps/paho.mqtt.c/inc/MQTTProtocol.h

-/*******************************************************************************
- * Copyright (c) 2009, 2014 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v2.0
- * and Eclipse Distribution License v1.0 which accompany this distribution. 
- *
- * The Eclipse Public License is available at 
- *    https://www.eclipse.org/legal/epl-2.0/
- * 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
- *    Ian Craggs - MQTT 3.1.1 updates
- *******************************************************************************/
-
-#if !defined(MQTTPROTOCOL_H)
-#define MQTTPROTOCOL_H
-
-#include "LinkedList.h"
-#include "MQTTPacket.h"
-#include "Clients.h"
-
-#define MAX_MSG_ID 65535
-#define MAX_CLIENTID_LEN 65535
-
-typedef struct
-{
-	int socket;
-	Publications* p;
-} pending_write;
-
-
-typedef struct
-{
-	List publications;
-	unsigned int msgs_received;
-	unsigned int msgs_sent;
-	List pending_writes; /* for qos 0 writes not complete */
-} MQTTProtocol;
-
-
-#include "MQTTProtocolOut.h"
-
-#endif