chunks have shorts

git-svn-id: svn://elaine/murooma/trunk@64 d8a302eb-03bc-478d-80e4-98257eca68ef
This commit is contained in:
(no author) 2014-07-03 21:03:38 +00:00
parent 614b7c941e
commit a379d5903f
2 changed files with 4 additions and 4 deletions

View file

@ -314,8 +314,8 @@ int main (int argc, char *argv[])
bufferMs = atoi(argv[1]); bufferMs = atoi(argv[1]);
zmq::context_t context (1); zmq::context_t context (1);
zmq::socket_t subscriber (context, ZMQ_SUB); zmq::socket_t subscriber (context, ZMQ_SUB);
subscriber.connect("tcp://127.0.0.1:123458"); // subscriber.connect("tcp://127.0.0.1:123458");
// subscriber.connect("tcp://192.168.0.2:123458"); subscriber.connect("tcp://192.168.0.2:123458");
const char* filter = ""; const char* filter = "";
subscriber.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter)); subscriber.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));

View file

@ -42,7 +42,7 @@ int main () {
{ {
c[0] = cin.get(); c[0] = cin.get();
c[1] = cin.get(); c[1] = cin.get();
chunk->payload[idx++] = 0;//(int)c[0] + ((int)c[1] * 256); chunk->payload[idx++] = (int)c[0] + ((int)c[1] * 256);
if (idx == WIRE_CHUNK_SIZE) if (idx == WIRE_CHUNK_SIZE)
{ {
timeval now; timeval now;
@ -63,7 +63,7 @@ int main () {
// snprintf ((char *) message.data(), size, "%05d %d", zipcode, c); // snprintf ((char *) message.data(), size, "%05d %d", zipcode, c);
// message.data()[0] = c; // message.data()[0] = c;
publisher.send(message); publisher.send(message);
/// addMs(ts, WIRE_CHUNK_MS); addMs(ts, WIRE_CHUNK_MS);
idx = 0; idx = 0;
// msg[0] = '0'; // msg[0] = '0';
} }