diff --git a/src/bin/msgq/cc.h b/src/bin/msgq/cc.h index 6271835afb..773e62abb3 100644 --- a/src/bin/msgq/cc.h +++ b/src/bin/msgq/cc.h @@ -27,10 +27,11 @@ * Item types and data lengths. */ #define ITEM_UNDEFINED 0x00 -#define ITEM_DATA 0x01 +#define ITEM_BLOB 0x01 #define ITEM_HASH 0x02 #define ITEM_LIST 0x03 #define ITEM_NULL 0x04 +#define ITEM_UTF8 0x08 #define ITEM_MASK 0x0f #define LENGTH_32 0x00 diff --git a/src/bin/msgq/msgq.c b/src/bin/msgq/msgq.c index 2205b075d4..8213cf193b 100644 --- a/src/bin/msgq/msgq.c +++ b/src/bin/msgq/msgq.c @@ -392,9 +392,9 @@ handle_subscribe(connection_t *con, msgbuf_t *msgb, ccsearch_t *c) return; } - if (group->type != ITEM_DATA - || instance->type != ITEM_DATA - || subtype->type != ITEM_DATA) { + if (group->type != ITEM_UTF8 + || instance->type != ITEM_UTF8 + || subtype->type != ITEM_UTF8) { con_log(con, LOG_NOTICE, "Bad subscribe, incorrect data types"); return; @@ -421,8 +421,8 @@ handle_unsubscribe(connection_t *con, msgbuf_t *msgb, ccsearch_t *c) return; } - if (group->type != ITEM_DATA - || instance->type != ITEM_DATA) { + if (group->type != ITEM_UTF8 + || instance->type != ITEM_UTF8) { con_log(con, LOG_NOTICE, "Bad subscribe, incorrect data types"); return; @@ -450,13 +450,13 @@ handle_send(connection_t *con, msgbuf_t *msgb, ccsearch_t *c) return; } - if (group->type != ITEM_DATA - || instance->type != ITEM_DATA) { + if (group->type != ITEM_UTF8 + || instance->type != ITEM_UTF8) { con_log(con, LOG_NOTICE, "Bad send, incorrect data types"); return; } - if (to->type != ITEM_DATA) { + if (to->type != ITEM_UTF8) { con_log(con, LOG_NOTICE, "Bad send, incorrect data types"); return; } @@ -566,8 +566,8 @@ handle_lname(connection_t *con, msgbuf_t *msgb, ccsearch_t *c) isc_buffer_t b; ccmsg_init(&msg, buf, sizeof(buf)); - ccmsg_add(&msg, ITEM_DATA, "lname", 5, con->lname, con->lnamelen); - ccmsg_add(&msg, ITEM_DATA, "type", 4, "getlname", 8); + ccmsg_add(&msg, ITEM_UTF8, "lname", 5, con->lname, con->lnamelen); + ccmsg_add(&msg, ITEM_UTF8, "type", 4, "getlname", 8); len = ccmsg_render(&msg); mb = msgbuf_create(mctx, len + 4); @@ -625,13 +625,13 @@ process_packet(connection_t *con) c = cc_findtag(cc, "type", 4); - if (cc_matchdata(c, ITEM_DATA, "send", 4)) { + if (cc_matchdata(c, ITEM_UTF8, "send", 4)) { handle_send(con, mb, cc); - } else if (cc_matchdata(c, ITEM_DATA, "getlname", 8)) { + } else if (cc_matchdata(c, ITEM_UTF8, "getlname", 8)) { handle_lname(con, mb, cc); - } else if (cc_matchdata(c, ITEM_DATA, "subscribe", 9)) { + } else if (cc_matchdata(c, ITEM_UTF8, "subscribe", 9)) { handle_subscribe(con, mb, cc); - } else if (cc_matchdata(c, ITEM_DATA, "unsubscribe", 9)) { + } else if (cc_matchdata(c, ITEM_UTF8, "unsubscribe", 9)) { handle_unsubscribe(con, mb, cc); } }