scottk/UltraGrid
1
0
Fork 0
mirror of https://github.com/outbackdingo/UltraGrid.git synced 2026-03-21 19:40:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Hd-rum-translator: allow create packet retransmitting port by control socket

Browse Source
This commit is contained in:
Martin Pulec
2015-02-04 18:28:35 +01:00
parent fce070a9a1
commit 00c8a4777c
1 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/hd-rum-translator/hd-rum-translator.cpp
View File

@@ -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);