diff options
| -rw-r--r-- | src/zmq2edi/EDISender.cpp | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/zmq2edi/EDISender.cpp b/src/zmq2edi/EDISender.cpp index 126131b..ec76e02 100644 --- a/src/zmq2edi/EDISender.cpp +++ b/src/zmq2edi/EDISender.cpp @@ -325,11 +325,18 @@ void EDISender::process() frame_t frame; frames.wait_and_pop(frame); - if (not running.load()) { + if (not running.load() or frame.first.empty()) { break; } - send_eti_frame(frame.first.data(), frame.second); + if (frame.first.size() == 6144) { + send_eti_frame(frame.first.data(), frame.second); + } + else { + etiLog.level(warn) << "Ignoring short ETI frame, " + "DFLC=" << frame.second.dlfc << ", len=" << + frame.first.size(); + } if (wait_times.size() == 250) { // every six seconds const double n = wait_times.size(); |