![]() ![]() | ![]() |
patch libaitmqtt readCONNECT() for return undefined string with size allocate if needed will strings
1: #ifndef __MQTTD_H 2: #define __MQTTD_H 3: 4: 5: struct tagSession { 6: pthread_t sess_tid; 7: mqtt_msg_t *sess_buf; 8: 9: int sess_sock; 10: io_sockaddr_t sess_addr; 11: struct timeval sess_ka; 12: 13: char sess_cid[MAX_CONNID]; 14: char sess_user[MAX_CRED]; 15: char sess_pass[MAX_CRED]; 16: 17: char clear; 18: struct { 19: char flag; 20: char qos; 21: char retain; 22: char *topic; 23: char *msg; 24: } sess_will; 25: 26: TAILQ_ENTRY(tagSession) sess_node; 27: }; 28: 29: typedef TAILQ_HEAD(, tagSession) sessions_t; 30: 31: 32: extern sessions_t Sessions; 33: 34: 35: #endif