JHUAPL/kvspool
1
0
Fork 0
mirror of https://github.com/JHUAPL/kvspool.git synced 2026-01-09 07:27:55 -05:00
Code Issues Packages Projects Releases Wiki Activity

str8

Browse Source
This commit is contained in:
Troy D. Hanson
2016-07-12 22:11:13 -04:00
parent eb7da29652
commit 235b0872a7
5 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
utils/kvsp-bcat.c
View File

@@ -55,6 +55,10 @@ int set_to_binary(void *set, UT_string *tmp) {
case i8: g=atoi(kv->val); utstring_bincpy(tmp,&g,sizeof(g)); break;
case i16: s=atoi(kv->val); utstring_bincpy(tmp,&s,sizeof(s)); break;
case i32: u=atoi(kv->val); utstring_bincpy(tmp,&u,sizeof(u)); break;
case str8:
g=kv->vlen; utstring_bincpy(tmp,&g,sizeof(g)); /* length prefix */
utstring_bincpy(tmp,kv->val,g); /* string itself */
break;
case str:
l=kv->vlen; utstring_bincpy(tmp,&l,sizeof(l)); /* length prefix */
utstring_bincpy(tmp,kv->val,kv->vlen); /* string itself */

2
utils/kvsp-bconfig.h
View File

@@ -11,7 +11,7 @@ int parse_config(char *);
extern char *supported_types_str[];
#define TYPES x(i16) x(i32) x(ipv4) x(str) x(i8) x(d64) x(mac)
#define TYPES x(i16) x(i32) x(ipv4) x(str) x(str8) x(i8) x(d64) x(mac)
#define x(t) t,
enum supported_types { TYPES };
#undef x

4
utils/kvsp-bpub.c
View File

@@ -69,6 +69,10 @@ int set_to_binary(void *set, zmq_msg_t *part) {
case i8: g=atoi(kv->val); utstring_bincpy(tmp,&g,sizeof(g)); break;
case i16: s=atoi(kv->val); utstring_bincpy(tmp,&s,sizeof(s)); break;
case i32: u=atoi(kv->val); utstring_bincpy(tmp,&u,sizeof(u)); break;
case str8:
g=kv->vlen; utstring_bincpy(tmp,&g,sizeof(g)); /* length prefix */
utstring_bincpy(tmp,kv->val,g); /* string itself */
break;
case str:
l=kv->vlen; utstring_bincpy(tmp,&l,sizeof(l)); /* length prefix */
utstring_bincpy(tmp,kv->val,kv->vlen); /* string itself */

4
utils/kvsp-npub.c
View File

@@ -60,6 +60,10 @@ int set_to_binary(void *set) {
case i8: g=atoi(kv->val); utstring_bincpy(tmp,&g,sizeof(g)); break;
case i16: s=atoi(kv->val); utstring_bincpy(tmp,&s,sizeof(s)); break;
case i32: u=atoi(kv->val); utstring_bincpy(tmp,&u,sizeof(u)); break;
case str8:
g=kv->vlen; utstring_bincpy(tmp,&g,sizeof(g)); /* length prefix */
utstring_bincpy(tmp,kv->val,g); /* string itself */
break;
case str:
l=kv->vlen; utstring_bincpy(tmp,&l,sizeof(l)); /* length prefix */
utstring_bincpy(tmp,kv->val,kv->vlen); /* string itself */

4
utils/kvsp-tpub.c
View File

@@ -139,6 +139,10 @@ int set_to_binary(void *set, UT_string *bin) {
case i8: g=atoi(kv->val); utstring_bincpy(bin,&g,sizeof(g)); break;
case i16: s=atoi(kv->val); utstring_bincpy(bin,&s,sizeof(s)); break;
case i32: u=atoi(kv->val); utstring_bincpy(bin,&u,sizeof(u)); break;
case str8:
g=kv->vlen; utstring_bincpy(bin,&g,sizeof(g)); /* length prefix */
utstring_bincpy(bin,kv->val,g); /* string itself */
break;
case str:
l=kv->vlen; utstring_bincpy(bin,&l,sizeof(l)); /* length prefix */
utstring_bincpy(bin,kv->val,kv->vlen); /* string itself */