| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960 |
- /*******************************************************************************
- * Copyright (c) 2009, 2017 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
- * Ian Craggs, Allan Stockdill-Mander - SSL updates
- * Ian Craggs - MQTT 3.1.1 updates
- * Rong Xiang, Ian Craggs - C++ compatibility
- * Ian Craggs - add debug definition of MQTTStrdup for when needed
- *******************************************************************************/
- #if !defined(MQTTPROTOCOLCLIENT_H)
- #define MQTTPROTOCOLCLIENT_H
- #include "LinkedList.h"
- #include "MQTTPacket.h"
- #include "Log.h"
- #include "MQTTProtocol.h"
- #include "Messages.h"
- #include "MQTTProperties.h"
- #define MAX_MSG_ID 65535
- #define MAX_CLIENTID_LEN 65535
- int MQTTProtocol_startPublish(Clients* pubclient, Publish* publish, int qos, int retained, Messages** m);
- Messages* MQTTProtocol_createMessage(Publish* publish, Messages** mm, int qos, int retained);
- Publications* MQTTProtocol_storePublication(Publish* publish, int* len);
- int messageIDCompare(void* a, void* b);
- int MQTTProtocol_assignMsgId(Clients* client);
- void MQTTProtocol_removePublication(Publications* p);
- void Protocol_processPublication(Publish* publish, Clients* client);
- int MQTTProtocol_handlePublishes(void* pack, int sock);
- int MQTTProtocol_handlePubacks(void* pack, int sock);
- int MQTTProtocol_handlePubrecs(void* pack, int sock);
- int MQTTProtocol_handlePubrels(void* pack, int sock);
- int MQTTProtocol_handlePubcomps(void* pack, int sock);
- void MQTTProtocol_closeSession(Clients* c, int sendwill);
- void MQTTProtocol_keepalive(time_t);
- void MQTTProtocol_retry(time_t, int, int);
- void MQTTProtocol_freeClient(Clients* client);
- void MQTTProtocol_emptyMessageList(List* msgList);
- void MQTTProtocol_freeMessageList(List* msgList);
- char* MQTTStrncpy(char *dest, const char* src, size_t num);
- char* MQTTStrdup(const char* src);
- //#define MQTTStrdup(src) MQTTStrncpy(malloc(strlen(src)+1), src, strlen(src)+1)
- #endif
|
