version 1.2.2.34, 2012/07/03 07:48:49
|
version 1.2.2.36, 2012/07/03 08:07:15
|
Line 42 sendPacket(sched_task_t *task)
|
Line 42 sendPacket(sched_task_t *task)
|
return NULL; |
return NULL; |
} |
} |
|
|
ioDEBUG(7, "Send packet length %d for socket %d\n", AIT_LEN(p), TASK_FD(task)); | ioDEBUG(7, "Send packet length %d for socket %d\n", AIT_LEN(p), (u_int) TASK_FD(task)); |
|
|
for (slen = AIT_LEN(p), pos = AIT_GET_BUF(p); slen > 0; slen -= n, pos += n) { |
for (slen = AIT_LEN(p), pos = AIT_GET_BUF(p); slen > 0; slen -= n, pos += n) { |
n = send(TASK_FD(task), pos, slen, MSG_NOSIGNAL); |
n = send(TASK_FD(task), pos, slen, MSG_NOSIGNAL); |
Line 128 sendRetain(sched_task_t *task)
|
Line 128 sendRetain(sched_task_t *task)
|
search4send(sess, s->sub_topic.msg_base, siz, s->sub_ret); |
search4send(sess, s->sub_topic.msg_base, siz, s->sub_ret); |
} |
} |
|
|
|
mqtt_subFree(&subs); |
return NULL; |
return NULL; |
} |
} |
|
|