version 1.2.2.23, 2012/06/20 09:23:28
|
version 1.2.2.24, 2012/06/20 14:51:38
|
Line 257 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
Line 257 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
SLIST_INSERT_HEAD(&sess->sess_subscr, store, st_node); |
SLIST_INSERT_HEAD(&sess->sess_subscr, store, st_node); |
|
|
/* convert topic to regexp */ |
/* convert topic to regexp */ |
if (mqtt_expandTopic(subs[i].sub_topic.msg_base, buf, sizeof buf, 1, 0) == -1) { | if (mqtt_expandTopic(subs[i].sub_topic.msg_base, buf, sizeof buf, 1, 1) == -1) { |
ioDEBUG(5, "Error:: in regexp #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
ioDEBUG(5, "Error:: in regexp #%d - %s", mqtt_GetErrno(), mqtt_GetError()); |
goto end; | |
| subs[i].sub_ret = MQTT_QOS_DENY; |
} else { |
} else { |
ptr = realloc(store->st_subscr.sub_topic.msg_base, strlen(buf) + 1); |
ptr = realloc(store->st_subscr.sub_topic.msg_base, strlen(buf) + 1); |
if (!ptr) { |
if (!ptr) { |
ioSYSERR(0); |
ioSYSERR(0); |
goto end; | |
| subs[i].sub_ret = MQTT_QOS_DENY; |
} else { |
} else { |
store->st_subscr.sub_topic.msg_base = ptr; |
store->st_subscr.sub_topic.msg_base = ptr; |
store->st_subscr.sub_topic.msg_len = strlen(buf) + 1; |
store->st_subscr.sub_topic.msg_len = strlen(buf) + 1; |
memcpy(store->st_subscr.sub_topic.msg_base, buf, |
memcpy(store->st_subscr.sub_topic.msg_base, buf, |
store->st_subscr.sub_topic.msg_len); |
store->st_subscr.sub_topic.msg_len); |
} |
} |
} |
|
|
|
call.LOG(logg, "Added [%s] SUBSCRIBE '%s'(%d) from %s\n", sess->sess_cid, | call.LOG(logg, "Added [%s] SUBSCRIBE '%s'(%d) from %s\n", sess->sess_cid, |
store->st_subscr.sub_topic.msg_base, | store->st_subscr.sub_topic.msg_base, |
store->st_subscr.sub_topic.msg_len, sess->sess_addr); | store->st_subscr.sub_topic.msg_len, sess->sess_addr); |
|
|
subs[i].sub_ret = MQTT_QOS_PASS; | subs[i].sub_ret = MQTT_QOS_PASS; |
| } |
} else |
} else |
subs[i].sub_ret = MQTT_QOS_DENY; |
subs[i].sub_ret = MQTT_QOS_DENY; |
} |
} |