|
|
| version 1.2.2.41, 2012/06/29 13:46:37 | version 1.2.2.42, 2012/06/29 15:43:13 |
|---|---|
| Line 1 | Line 1 |
| #include "global.h" | #include "global.h" |
| #include "rtlm.h" | #include "rtlm.h" |
| #include "utils.h" | |
| #include "mqttd.h" | #include "mqttd.h" |
| #include "mqttd_calls.h" | #include "mqttd_calls.h" |
| #include "utils.h" | |
| static inline struct tagSession * | static inline struct tagSession * |
| Line 90 finiSession(struct tagSession *sess) | Line 90 finiSession(struct tagSession *sess) |
| io_free(store); | io_free(store); |
| } | } |
| if (sess->sess_will.msg) | if (sess->sess_will.flag) |
| free(sess->sess_will.msg); | srv_Will(sess); |
| if (sess->sess_will.topic) | if (sess->sess_will.topic) |
| free(sess->sess_will.topic); | free(sess->sess_will.topic); |
| if (sess->sess_will.msg) | |
| free(sess->sess_will.msg); | |
| if (sess->sess_sock > STDERR_FILENO) | if (sess->sess_sock > STDERR_FILENO) |
| srv_Close(sess->sess_sock); | srv_Close(sess->sess_sock); |