version 1.4.4.1, 2013/01/18 10:17:22
|
version 1.5, 2017/10/08 22:49:25
|
Line 148 sendRetain(sched_task_t *task)
|
Line 148 sendRetain(sched_task_t *task)
|
struct tagSession *sess; |
struct tagSession *sess; |
int siz; |
int siz; |
|
|
ETRACE(2); | ETRACE(); |
|
|
assert(task); |
assert(task); |
|
|
Line 183 pubWill(struct tagSession * __restrict sess)
|
Line 183 pubWill(struct tagSession * __restrict sess)
|
{ |
{ |
int datlen; |
int datlen; |
|
|
ETRACE(2); | ETRACE(); |
|
|
/* prepare will packet */ |
/* prepare will packet */ |
datlen = mqtt_msgPUBLISH(sess->sess_buf, sess->sess_will.topic, 0xDEAD, 0, 1, 0, |
datlen = mqtt_msgPUBLISH(sess->sess_buf, sess->sess_will.topic, 0xDEAD, 0, 1, 0, |
Line 246 cmdPUBLISH(void *srv, int len, void *arg)
|
Line 246 cmdPUBLISH(void *srv, int len, void *arg)
|
u_short mid = 0; |
u_short mid = 0; |
ait_val_t *p = NULL; |
ait_val_t *p = NULL; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 300 cmdPUBREL(void *srv, int len, void *arg)
|
Line 300 cmdPUBREL(void *srv, int len, void *arg)
|
u_short mid = 0; |
u_short mid = 0; |
ait_val_t *p = NULL; |
ait_val_t *p = NULL; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 341 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
Line 341 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
void *ptr; |
void *ptr; |
ait_val_t *p = NULL; |
ait_val_t *p = NULL; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 423 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
Line 423 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
struct tagStore *store, *tmp; |
struct tagStore *store, *tmp; |
ait_val_t *p = NULL; |
ait_val_t *p = NULL; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 479 cmdPINGREQ(void *srv, int len, void *arg)
|
Line 479 cmdPINGREQ(void *srv, int len, void *arg)
|
int siz = 0; |
int siz = 0; |
ait_val_t *p = NULL; |
ait_val_t *p = NULL; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 504 cmdCONNECT(void *srv, int len, void *arg)
|
Line 504 cmdCONNECT(void *srv, int len, void *arg)
|
struct tagStore *store; |
struct tagStore *store; |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |
Line 553 cmdDISCONNECT(void *srv, int len, void *arg)
|
Line 553 cmdDISCONNECT(void *srv, int len, void *arg)
|
{ |
{ |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
|
|
ETRACE(2); | ETRACE(); |
|
|
if (!sess) |
if (!sess) |
return -1; |
return -1; |