diff options
Diffstat (limited to 'zmqoutput.c')
| -rw-r--r-- | zmqoutput.c | 28 |
1 files changed, 23 insertions, 5 deletions
diff --git a/zmqoutput.c b/zmqoutput.c index 1345bfd..03007cc 100644 --- a/zmqoutput.c +++ b/zmqoutput.c @@ -22,7 +22,7 @@ void zmqoutput_set_peaks(int left, int right) zmq_peak_right = right; } -int zmqoutput_open(Bit_stream_struc *bs, char* uri) +int zmqoutput_open(Bit_stream_struc *bs, const char* uri_list) { zmq_context = zmq_ctx_new(); bs->zmq_sock = zmq_socket(zmq_context, ZMQ_PUB); @@ -31,12 +31,30 @@ int zmqoutput_open(Bit_stream_struc *bs, char* uri) zmq_strerror(errno)); return -1; } - if (zmq_connect(bs->zmq_sock, uri) != 0) { - fprintf(stderr, "Error occurred during zmq_connect: %s\n", - zmq_strerror(errno)); - return -1; + + char* uris = strdup(uri_list); + char* saveptr = NULL; + + for (; ; uris = NULL) { + char* uri = strtok_r(uris, ";", &saveptr); + + + if (uri) { + fprintf(stderr, "Connecting ZMQ to %s\n", uri); + if (zmq_connect(bs->zmq_sock, uri) != 0) { + fprintf(stderr, "Error occurred during zmq_connect: %s\n", + zmq_strerror(errno)); + free(uris); + return -1; + } + } + else { + break; + } } + free(uris); + zmqbuf = (unsigned char*)malloc(bs->zmq_framesize); if (zmqbuf == NULL) { fprintf(stderr, "Unable to allocate ZMQ buffer\n"); |