version 1.2.2.22, 2012/06/19 08:32:17
|
version 1.2.2.23, 2012/06/20 09:23:28
|
Line 87 pubOnce(struct tagSession *sess, char * __restrict psT
|
Line 87 pubOnce(struct tagSession *sess, char * __restrict psT
|
} |
} |
if (!regexec(&re, psTopic, 1, &match, 0)) { |
if (!regexec(&re, psTopic, 1, &match, 0)) { |
/* MATCH */ |
/* MATCH */ |
|
ioDEBUG(1, "+++ dlen=%d\n", datlen); |
p = mkPkt(sess->sess_buf->msg_base, datlen); |
p = mkPkt(sess->sess_buf->msg_base, datlen); |
schedWrite(root, sendPacket, p, sess->sess_sock, NULL, 0); | schedWrite(root, sendPacket, p, s->sess_sock, NULL, 0); |
} |
} |
|
|
regfree(&re); |
regfree(&re); |
Line 145 cmdPUBLISH(void *srv, int len, void *arg)
|
Line 146 cmdPUBLISH(void *srv, int len, void *arg)
|
hdr = (struct mqtthdr*) sess->sess_buf->msg_base; |
hdr = (struct mqtthdr*) sess->sess_buf->msg_base; |
switch (hdr->mqtt_msg.qos) { |
switch (hdr->mqtt_msg.qos) { |
case MQTT_QOS_ACK: |
case MQTT_QOS_ACK: |
pubAck(sess, szTopic, siz); | pubAck(sess, szTopic, mqtt_pktLen(hdr)); |
siz = mqtt_msgPUBACK(sess->sess_buf, mid); |
siz = mqtt_msgPUBACK(sess->sess_buf, mid); |
if (siz == -1) { |
if (siz == -1) { |
ioDEBUG(5, "Error:: in msgPUBACK #%d - %s", |
ioDEBUG(5, "Error:: in msgPUBACK #%d - %s", |
Line 154 cmdPUBLISH(void *srv, int len, void *arg)
|
Line 155 cmdPUBLISH(void *srv, int len, void *arg)
|
} |
} |
break; |
break; |
case MQTT_QOS_EXACTLY: |
case MQTT_QOS_EXACTLY: |
pubExactly(sess, szTopic, siz); | pubExactly(sess, szTopic, mqtt_pktLen(hdr)); |
siz = mqtt_msgPUBREC(sess->sess_buf, mid); |
siz = mqtt_msgPUBREC(sess->sess_buf, mid); |
if (siz == -1) { |
if (siz == -1) { |
ioDEBUG(5, "Error:: in msgPUBREC #%d - %s", |
ioDEBUG(5, "Error:: in msgPUBREC #%d - %s", |
Line 163 cmdPUBLISH(void *srv, int len, void *arg)
|
Line 164 cmdPUBLISH(void *srv, int len, void *arg)
|
} |
} |
break; |
break; |
case MQTT_QOS_ONCE: |
case MQTT_QOS_ONCE: |
pubOnce(sess, szTopic, siz); | pubOnce(sess, szTopic, mqtt_pktLen(hdr)); |
default: |
default: |
return 0; |
return 0; |
} |
} |