version 1.1.1.1.2.5, 2012/01/27 15:16:40
|
version 1.1.1.1.2.8, 2012/04/26 11:49:12
|
Line 12 terms:
|
Line 12 terms:
|
All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
|
|
Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011 | Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
|
|
Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
Line 234 inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg
|
Line 234 inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg
|
*/ |
*/ |
int mqtt_expandTopic(const char *csInput, char * __restrict psRegEx, int regexLen, |
int mqtt_expandTopic(const char *csInput, char * __restrict psRegEx, int regexLen, |
unsigned char BOL, unsigned char EOL); |
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 |
* mqtt_encodeLen() Encode number to MQTT length field |
Line 535 unsigned short mqtt_readPUBCOMP(mqtt_msg_t * __restric
|
Line 544 unsigned short mqtt_readPUBCOMP(mqtt_msg_t * __restric
|
* @buf = Message buffer |
* @buf = Message buffer |
* @msgID = MessageID |
* @msgID = MessageID |
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
* return: NULL error or !=NULL MQTT fixed header | * return: -1 error or >-1 elements into subscr |
*/ |
*/ |
struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, | int mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
mqtt_subscr_t **subscr); |
mqtt_subscr_t **subscr); |
/* |
/* |
* mqtt_readSUBACK() Read SUBACK message |
* mqtt_readSUBACK() Read SUBACK message |
Line 554 int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsig
|
Line 563 int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsig
|
* @buf = Message buffer |
* @buf = Message buffer |
* @msgID = MessageID |
* @msgID = MessageID |
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
* return: NULL error or !=NULL MQTT fixed header | * return: -1 error or >-1 elements into subscr |
*/ |
*/ |
struct mqtthdr *mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, | int mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
mqtt_subscr_t **subscr); |
mqtt_subscr_t **subscr); |
/* |
/* |
* mqtt_readUNSUBACK() Read UNSUBACK message |
* mqtt_readUNSUBACK() Read UNSUBACK message |