9 zsock_t* o = zsock_new(ZMQ_PAIR);
10 zsock_bind(o,
"inproc://teststr");
11 zsock_t* i = zsock_new(ZMQ_PAIR);
12 zsock_connect(i,
"inproc://teststr");
15 zmsg_t* msg = zmsg_new();
16 zmsg_addstrf(msg,
"ZIO%d%s%s", 4,
"TEXT",
17 "Live long int and be unsigned");
18 uint64_t coords[2] = {0xf12edeadbeaf, (uint64_t)zclock_time()};
19 zmsg_addmem(msg, coords, 2*
sizeof(uint64_t));
20 zmsg_addmem(msg, NULL, 0);
25 char* got = zmsg_popstr(msg);
26 std::string gots = got;
28 cerr <<
"Size: " << gots.size() <<
" " << strlen(got)
29 <<
": " << gots << endl;
32 std::string
format = gots.substr(4,4);
33 std::string label = gots.substr(8);
34 cerr <<
"h1: L" << lvl <<
" " << format <<
" \"" << label <<
"\"\n";
36 zframe_t* ogf = zmsg_pop(msg);
37 uint64_t* og = (uint64_t*)zframe_data(ogf);
38 uint64_t origin=og[0], granule=og[1];
42 << std::hex << std::uppercase <<
" o=0X" << origin
43 <<
" (" << std::dec << origin <<
" )" 44 << std::hex << std::uppercase <<
" g=0X" << granule
45 <<
" (" << std::dec << granule <<
" )" 48 int nleft = zmsg_size(msg);
49 cerr <<
"pay: " << nleft <<
" frames" << endl;
52 zframe_t* frame = zmsg_pop(msg);
53 cerr <<
"\tframe size: " << zframe_size(frame) << endl;
54 zframe_destroy(&frame);