diff --git a/client.cpp b/client.cpp index c6d527f0..c08180cd 100644 --- a/client.cpp +++ b/client.cpp @@ -314,8 +314,8 @@ int main (int argc, char *argv[]) bufferMs = atoi(argv[1]); zmq::context_t context (1); zmq::socket_t subscriber (context, ZMQ_SUB); - subscriber.connect("tcp://127.0.0.1:123458"); -// subscriber.connect("tcp://192.168.0.2:123458"); +// subscriber.connect("tcp://127.0.0.1:123458"); + subscriber.connect("tcp://192.168.0.2:123458"); const char* filter = ""; subscriber.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter)); diff --git a/server.cpp b/server.cpp index b14d4ccf..c3fb6e6f 100644 --- a/server.cpp +++ b/server.cpp @@ -42,7 +42,7 @@ int main () { { c[0] = 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) { timeval now; @@ -63,7 +63,7 @@ int main () { // snprintf ((char *) message.data(), size, "%05d %d", zipcode, c); // message.data()[0] = c; publisher.send(message); -/// addMs(ts, WIRE_CHUNK_MS); + addMs(ts, WIRE_CHUNK_MS); idx = 0; // msg[0] = '0'; }