--- mqtt/src/daemon.c 2011/12/09 14:01:37 1.1.2.15 +++ mqtt/src/daemon.c 2011/12/12 09:24:25 1.1.2.16 @@ -1,10 +1,8 @@ #include "global.h" +#include "rtlm.h" #include "mqttd.h" -extern char cliCmd[], *cliStr[]; - - static inline struct tagSession * initSession(int sock, char * __restrict addr) { @@ -124,6 +122,12 @@ startSession(sched_task_t *task) } /* check online table for user */ + if (call.LoginACC(&cfg, acc, sess->sess_user, sess->sess_pass)) { + VERB(1) syslog(LOG_WARNING, "Login:: DENIED for username %s and password %s", + sess->sess_user, sess->sess_pass); + goto end; + } else + VERB(1) syslog(LOG_WARNING, "Login:: ALLOWED for username %s ...", sess->sess_user); /* Start session thread OK ... */ TAILQ_INSERT_TAIL(&Sessions, sess, sess_node);