diff options
Diffstat (limited to 'src/zmq2edi/zmq2edi.cpp')
| -rw-r--r-- | src/zmq2edi/zmq2edi.cpp | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/zmq2edi/zmq2edi.cpp b/src/zmq2edi/zmq2edi.cpp index b2c20f4..3364faa 100644 --- a/src/zmq2edi/zmq2edi.cpp +++ b/src/zmq2edi/zmq2edi.cpp @@ -55,6 +55,7 @@ void usage(void) cerr << "The following options can be given only once:" << endl; cerr << " <source> is a ZMQ URL that points to a ODR-DabMux ZMQ output." << endl; cerr << " -w <delay> Keep every ETI frame until TIST is <delay> milliseconds after current system time." << endl; + cerr << " -x Drop frames where for which the wait time would be negative, i.e. frames that arrived too late." << endl; cerr << " -p <destination port> sets the destination port." << endl; cerr << " -P Disable PFT and send AFPackets." << endl; cerr << " -f <fec> sets the FEC." << endl; @@ -223,10 +224,11 @@ int start(int argc, char **argv) } int delay_ms = 500; + bool drop_late_packets = false; int ch = 0; while (ch != -1) { - ch = getopt(argc, argv, "d:p:s:S:t:Pf:i:Dva:w:"); + ch = getopt(argc, argv, "d:p:s:S:t:Pf:i:Dva:w:x"); switch (ch) { case -1: break; @@ -274,6 +276,9 @@ int start(int argc, char **argv) case 'w': delay_ms = std::stoi(optarg); break; + case 'x': + drop_late_packets = true; + break; case 'h': default: usage(); @@ -298,8 +303,9 @@ int start(int argc, char **argv) return 1; } - etiLog.level(info) << "Setting up EDI Sender with delay " << delay_ms << " ms"; - edisender.start(edi_conf, delay_ms); + etiLog.level(info) << "Setting up EDI Sender with delay " << delay_ms << " ms. " << + (drop_late_packets ? "Will" : "Will not") << " drop late packets"; + edisender.start(edi_conf, delay_ms, drop_late_packets); edisender.print_configuration(); const char* source_url = argv[optind]; |