version 1.2.2.8, 2012/04/27 16:41:56
|
version 1.2.2.9, 2012/05/05 13:39:27
|
Line 5
|
Line 5
|
|
|
|
|
int |
int |
cmdPUBLISH(void *srv, void *arg) | cmdPUBLISH(void *srv, int len, void *arg) |
{ |
{ |
struct mqtthdr *hdr; |
struct mqtthdr *hdr; |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
Line 33 cmdPUBLISH(void *srv, void *arg)
|
Line 33 cmdPUBLISH(void *srv, void *arg)
|
} |
} |
|
|
int |
int |
cmdPUBREL(void *srv, void *arg) | cmdPUBREL(void *srv, int len, void *arg) |
{ |
{ |
struct mqtthdr *hdr; |
struct mqtthdr *hdr; |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
Line 49 cmdPUBREL(void *srv, void *arg)
|
Line 49 cmdPUBREL(void *srv, void *arg)
|
} |
} |
|
|
int |
int |
cmdSUBSCRIBE(void *srv, void *arg) | cmdSUBSCRIBE(void *srv, int len, void *arg) |
{ |
{ |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
mqtt_subscr_t *subs = NULL; |
mqtt_subscr_t *subs = NULL; |
Line 111 end:
|
Line 111 end:
|
} |
} |
|
|
int |
int |
cmdUNSUBSCRIBE(void *srv, void *arg) | cmdUNSUBSCRIBE(void *srv, int len, void *arg) |
{ |
{ |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
|
|
Line 124 cmdUNSUBSCRIBE(void *srv, void *arg)
|
Line 124 cmdUNSUBSCRIBE(void *srv, void *arg)
|
} |
} |
|
|
int |
int |
cmdPINGREQ(void *srv, void *arg) | cmdPINGREQ(void *srv, int len, void *arg) |
{ |
{ |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
int siz = 0; |
int siz = 0; |
Line 152 cmdPINGREQ(void *srv, void *arg)
|
Line 152 cmdPINGREQ(void *srv, void *arg)
|
} |
} |
|
|
int |
int |
cmdCONNECT(void *srv, void *arg) | 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; |
Line 190 cmdCONNECT(void *srv, void *arg)
|
Line 190 cmdCONNECT(void *srv, void *arg)
|
|
|
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
sess->sess_addr, sess->sess_user); |
sess->sess_addr, sess->sess_user); |
|
|
|
// schedEvent(root, startSession, NULL, (u_long) sess->sess_sock, sess, ret); |
return 0; |
return 0; |
} |
} |
|
|
int |
int |
cmdDISCONNECT(void *srv, void *arg) | cmdDISCONNECT(void *srv, int len, void *arg) |
{ |
{ |
struct tagSession *sess = (struct tagSession*) arg; |
struct tagSession *sess = (struct tagSession*) arg; |
|
|
Line 210 cmdDISCONNECT(void *srv, void *arg)
|
Line 212 cmdDISCONNECT(void *srv, void *arg)
|
|
|
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
sess->sess_addr, sess->sess_user); |
sess->sess_addr, sess->sess_user); |
|
|
|
finiSession(sess); |
return 0; |
return 0; |
} |
} |