From 00c8a4777c123c39d682dcc98cd9953c169f8407 Mon Sep 17 00:00:00 2001 From: Martin Pulec Date: Wed, 4 Feb 2015 18:28:35 +0100 Subject: [PATCH] Hd-rum-translator: allow create packet retransmitting port by control socket --- src/hd-rum-translator/hd-rum-translator.cpp | 25 +++++++++++++++------ 1 file changed, 18 insertions(+), 7 deletions(-) diff --git a/src/hd-rum-translator/hd-rum-translator.cpp b/src/hd-rum-translator/hd-rum-translator.cpp index 5fcd5bcc7..8de4a246a 100644 --- a/src/hd-rum-translator/hd-rum-translator.cpp +++ b/src/hd-rum-translator/hd-rum-translator.cpp @@ -289,13 +289,24 @@ static void *writer(void *arg) int tx_port = atoi(strtok_r(NULL, " ", &save_ptr)); char *compress = strtok_r(NULL, " ", &save_ptr); replica_init(rep, host, tx_port, 100*1000, &s->mod); - - rep->type = replica::type_t::RECOMPRESS; - char *fec = NULL; - rep->recompress = recompress_init(&rep->mod, - host, compress, - 0, tx_port, 1500, fec, RATE_UNLIMITED); - hd_rum_decompress_append_port(s->decompress, rep->recompress); + if (compress) { + rep->type = replica::type_t::RECOMPRESS; + char *fec = NULL; + rep->recompress = recompress_init(&rep->mod, + host, compress, + 0, tx_port, 1500, fec, RATE_UNLIMITED); + hd_rum_decompress_append_port(s->decompress, rep->recompress); + hd_rum_decompress_set_active(s->decompress, rep->recompress, true); + } else{ + rep->type = replica::type_t::USE_SOCK; + char compress[] = "none"; + char *fec = NULL; + rep->recompress = recompress_init(&rep->mod, + host, compress, + 0, tx_port, 1500, fec, RATE_UNLIMITED); + hd_rum_decompress_append_port(s->decompress, rep->recompress); + hd_rum_decompress_set_active(s->decompress, rep->recompress, false); + } } free_message((struct message *) msg);