version 1.2.2.19, 2012/06/01 10:39:48
|
version 1.2.2.21, 2012/06/01 13:13:40
|
Line 30 mkPkt(void * __restrict data, int dlen)
|
Line 30 mkPkt(void * __restrict data, int dlen)
|
} |
} |
|
|
static inline void |
static inline void |
freePkt(struct tagPkt ** __restrict p) | freePkt(struct tagPkt * __restrict p) |
{ |
{ |
if (!p || !*p) | if (!p) |
return; |
return; |
|
|
io_freeVar(&(*p)->pkt_data); | io_freeVar(&p->pkt_data); |
io_free(*p); | io_free(p); |
*p = NULL; | |
} |
} |
|
|
static void * |
static void * |
Line 61 sendPacket(sched_task_t *task)
|
Line 60 sendPacket(sched_task_t *task)
|
} |
} |
} |
} |
|
|
|
freePkt(p); |
return NULL; |
return NULL; |
} |
} |
|
|
Line 194 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
Line 194 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
struct tagStore *store; |
struct tagStore *store; |
char buf[BUFSIZ]; |
char buf[BUFSIZ]; |
void *ptr; |
void *ptr; |
|
struct tagPkt *p = NULL; |
|
|
ioTRACE(2); |
ioTRACE(2); |
|
|
Line 259 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
Line 260 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
if (siz == -1) { |
if (siz == -1) { |
ioDEBUG(5, "Error:: in msgSUBACK #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
ioDEBUG(5, "Error:: in msgSUBACK #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
goto end; |
goto end; |
} | } else { |
if ((siz = send(sess->sess_sock, sess->sess_buf->msg_base, siz, MSG_NOSIGNAL)) == -1) | p = mkPkt(sess->sess_buf->msg_base, siz); |
ioSYSERR(0); | |
else { | |
ioDEBUG(5, "Sended %d bytes.", siz); | |
memset(sess->sess_buf->msg_base, 0, sess->sess_buf->msg_len); |
memset(sess->sess_buf->msg_base, 0, sess->sess_buf->msg_len); |
} |
} |
|
|
|
schedWrite(root, sendPacket, p, sess->sess_sock, NULL, 0); |
end: |
end: |
mqtt_subFree(&subs); |
mqtt_subFree(&subs); |
return 0; |
return 0; |
Line 280 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
Line 280 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
u_short mid = 0; |
u_short mid = 0; |
register int i; |
register int i; |
struct tagStore *store, *tmp; |
struct tagStore *store, *tmp; |
|
struct tagPkt *p = NULL; |
|
|
ioTRACE(2); |
ioTRACE(2); |
|
|
Line 319 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
Line 320 cmdUNSUBSCRIBE(void *srv, int len, void *arg)
|
if (siz == -1) { |
if (siz == -1) { |
ioDEBUG(5, "Error:: in msgUNSUBACK #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
ioDEBUG(5, "Error:: in msgUNSUBACK #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
goto end; |
goto end; |
} | } else { |
if ((siz = send(sess->sess_sock, sess->sess_buf->msg_base, siz, MSG_NOSIGNAL)) == -1) | p = mkPkt(sess->sess_buf->msg_base, siz); |
ioSYSERR(0); | |
else { | |
ioDEBUG(5, "Sended %d bytes.", siz); | |
memset(sess->sess_buf->msg_base, 0, sess->sess_buf->msg_len); |
memset(sess->sess_buf->msg_base, 0, sess->sess_buf->msg_len); |
} |
} |
|
|
|
schedWrite(root, sendPacket, p, sess->sess_sock, NULL, 0); |
end: |
end: |
mqtt_subFree(&subs); |
mqtt_subFree(&subs); |
return 0; |
return 0; |