--- mqtt/inc/defs.h 2011/11/22 14:19:48 1.1.1.1.2.5 +++ mqtt/inc/defs.h 2011/12/12 09:24:24 1.1.1.1.2.19 @@ -3,39 +3,47 @@ #define STRSIZ 256 +#define MAX_CONNID 24 +#define MAX_CRED 13 #define MQTTMSG_MAX 65529 #define WILDCARDS "/#+" +#define MQTT_CONNFLGS_INIT { 1, 1, 1, 3, 1, 1, 1 } #define MQTT_DATA_MAX 268435455 #define MQTT_CONN_STR "MQIsdp" #define MQTT_PROTO_VER 3 #define MQTT_KEEPALIVE 10 -#define MQTT_TYPE_UNKNOWN 0 /* reserved */ -#define MQTT_TYPE_CONNECT 1 /* client request to connect to server */ -#define MQTT_TYPE_CONNACK 2 /* connect acknowledgment */ -#define MQTT_TYPE_PUBLISH 3 /* publish message */ -#define MQTT_TYPE_PUBACK 4 /* publish acknowledgment */ -#define MQTT_TYPE_PUBREC 5 /* publish received (assured delivery part 1) */ -#define MQTT_TYPE_PUBREL 6 /* publish release (assured delivery part 2) */ -#define MQTT_TYPE_PUBCOMP 7 /* publish complete (assured delivery part 3) */ -#define MQTT_TYPE_SUBSCRIBE 8 /* client subscribe request */ -#define MQTT_TYPE_SUBACK 9 /* subscribe acknowledgment */ -#define MQTT_TYPE_UNSUBSCRIBE 10 /* client unsubscribe request */ -#define MQTT_TYPE_UNSUBACK 11 /* unsubscribe acknowledgment */ -#define MQTT_TYPE_PINGREQ 12 /* PING request */ -#define MQTT_TYPE_PINGRESP 13 /* PING response */ -#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */ -#define MQTT_TYPE_RESERVED 15 /* reserved */ +#define DEFAULT_RETRY 1 +#define DEFAULT_CONFIG "/etc/mqtt.conf" +#define MQTT_PORT "1883" +#define MQTT_HOST "localhost" +#define MQTT_USER "mqtt" -#define LOGERR { \ - mqtt_Errno = errno; \ - strlcpy(mqtt_Error, strerror(errno), sizeof mqtt_Error); \ - } +#define VERB(x) if ((x) <= Verbose) +#define FTRACE(x) VERB((x)) syslog(LOG_DEBUG, "I'm in %s(%d)", __func__, __LINE__); +#define LOGERR { \ + mqtt_Errno = errno; \ + strlcpy(mqtt_Error, strerror(errno), sizeof mqtt_Error); \ + } + +extern int mqtt_Errno; +extern char mqtt_Error[STRSIZ]; +extern struct tagCallbacks call; + +extern char cliCmd[], *cliStr[]; + inline void mqtt_SetErr(int eno, char *estr, ...); +inline struct mqtthdr *_mqtt_readHEADER(mqtt_msg_t * __restrict, u_char, int *, int *); + +extern int Verbose, Kill; + +extern struct tagCallbacks call; +extern sqlite3 *acc, *pub; +extern FILE *logg; #endif