version 1.2.2.1, 2012/01/30 08:29:55
|
version 1.2.2.2, 2012/01/30 13:39:22
|
Line 85 cmdPINGREQ(void *srv, void *arg)
|
Line 85 cmdPINGREQ(void *srv, void *arg)
|
{ |
{ |
struct mqtthdr *hdr; |
struct mqtthdr *hdr; |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
|
int siz = 0; |
|
|
ioTRACE(2); |
ioTRACE(2); |
|
|
Line 92 cmdPINGREQ(void *srv, void *arg)
|
Line 93 cmdPINGREQ(void *srv, void *arg)
|
return -1; |
return -1; |
|
|
hdr = (struct mqtthdr*) sess->sess_buf->msg_base; |
hdr = (struct mqtthdr*) sess->sess_buf->msg_base; |
|
siz = mqtt_msgPINGRESP(sess->sess_buf); |
|
if (siz == -1) { |
|
ioDEBUG(5, "Error:: in msgPINGRESP #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
|
return 0; |
|
} |
|
if ((siz = send(sess->sess_sock, sess->sess_buf->msg_base, siz, 0)) == -1) { |
|
ioSYSERR(0); |
|
return 0; |
|
} else |
|
ioDEBUG(5, "Sended %d bytes.", siz); |
|
|
return 0; |
return 0; |
} |
} |
Line 114 cmdCONNECT(void *srv, void *arg)
|
Line 125 cmdCONNECT(void *srv, void *arg)
|
if (call.FiniSessPUB) |
if (call.FiniSessPUB) |
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%"); |
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%"); |
|
|
|
pthread_mutex_lock(&sess->sess_mtx); |
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) { |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node); |
|
|
Line 124 cmdCONNECT(void *srv, void *arg)
|
Line 136 cmdCONNECT(void *srv, void *arg)
|
|
|
free(store); |
free(store); |
} |
} |
|
pthread_mutex_unlock(&sess->sess_mtx); |
|
|
if (sess->sess_will.msg) |
if (sess->sess_will.msg) |
free(sess->sess_will.msg); |
free(sess->sess_will.msg); |