diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-11-21 07:53:55 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-11-21 07:53:55 +0100 |
| commit | 1f8f48caa194471fc5d7568dcd78b22377388629 (patch) | |
| tree | deb849d6f605186519801dc92112081ff29af82e /zmqtest | |
| parent | a3f491d43692e999270db5bac17717e8dfa60612 (diff) | |
| download | mmbtools-aux-1f8f48caa194471fc5d7568dcd78b22377388629.tar.gz mmbtools-aux-1f8f48caa194471fc5d7568dcd78b22377388629.tar.bz2 mmbtools-aux-1f8f48caa194471fc5d7568dcd78b22377388629.zip | |
minor stuff
Diffstat (limited to 'zmqtest')
| -rw-r--r-- | zmqtest/zmq-sub/zmq-sub.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/zmqtest/zmq-sub/zmq-sub.c b/zmqtest/zmq-sub/zmq-sub.c index ca3e468..22ba80a 100644 --- a/zmqtest/zmq-sub/zmq-sub.c +++ b/zmqtest/zmq-sub/zmq-sub.c @@ -56,12 +56,12 @@ void do_subscriber(const char* host, int port) memset(eti, 0x55, framelen); rc = zmq_recv(sock, &message, framelen, 0); - fprintf(stderr, "rc=%d \n", rc); - if (rc > 0 && message.version == 1) { uint8_t* buf = message.buf; for (int i = 0; i < NUM_FRAMES_PER_ZMQ_MESSAGE; i++) { + fprintf(stderr, "i=%d buflen=%d\n", i, message.buflen[i]); + memcpy(eti_p, buf, message.buflen[i]); eti_p += 6144; buf += message.buflen[i]; @@ -70,6 +70,8 @@ void do_subscriber(const char* host, int port) write(STDOUT_FILENO, eti, framelen); } else if (rc < 0) { + fprintf(stderr, "rc=%d \n", rc); + barf(); } } |