--- libaitmqtt/inc/aitmqtt.h 2012/01/27 15:15:32 1.1.1.1.2.4 +++ libaitmqtt/inc/aitmqtt.h 2012/02/04 10:40:01 1.1.1.1.2.6 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitmqtt.h,v 1.1.1.1.2.4 2012/01/27 15:15:32 misho Exp $ +* $Id: aitmqtt.h,v 1.1.1.1.2.6 2012/02/04 10:40:01 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -50,9 +50,11 @@ SUCH DAMAGE. #define MAX_CONNID 24 #define MAX_CRED 13 #define MQTTMSG_MAX 65529 +#define MQTT_DATA_MAX 268435455 #define MQTT_PROTO_VER 3 #define MQTT_KEEPALIVE 10 +#define MQTT_DEFAULT_MSGID 0xDEBA /* FIXED HEADER */ @@ -232,6 +234,15 @@ inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg */ int mqtt_expandTopic(const char *csInput, char * __restrict psRegEx, int regexLen, unsigned char BOL, unsigned char EOL); +/* + * mqtt_sqlTopic() - Expanding topic to SQL search string + * + * @csInput = Input topic + * @psSQL = Output to SQL search string + * @sqlLen = Length of psSQL + * return: -1 error, 0 changed bytes + */ +int mqtt_sqlTopic(const char *csInput, char * __restrict psSQL, int sqlLen); /* * mqtt_encodeLen() Encode number to MQTT length field