From 601d7a6ca95678613ca576258314f50a6e5e742c Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Fri, 6 Jan 2017 06:44:36 -0800 Subject: Start of PUB/SUB testing. Fixed a subscribe bug. --- src/protocol/pubsub/sub.c | 3 +++ 1 file changed, 3 insertions(+) (limited to 'src/protocol') diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c index 4908466f..6cd22712 100644 --- a/src/protocol/pubsub/sub.c +++ b/src/protocol/pubsub/sub.c @@ -173,6 +173,7 @@ nni_sub_subscribe(nni_sub_sock *sub, const void *buf, size_t sz) NNI_LIST_FOREACH (&sub->topics, topic) { int rv; + if (topic->len >= sz) { rv = memcmp(topic->buf, buf, sz); } else { @@ -201,6 +202,8 @@ nni_sub_subscribe(nni_sub_sock *sub, const void *buf, size_t sz) newtopic->len = sz; if (topic != NULL) { nni_list_insert_before(&sub->topics, newtopic, topic); + } else { + nni_list_append(&sub->topics, newtopic); } return (0); } -- cgit v1.2.3-70-g09d2