diff options
Diffstat (limited to 'src/odr-sourcecompanion.cpp')
| -rw-r--r-- | src/odr-sourcecompanion.cpp | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/src/odr-sourcecompanion.cpp b/src/odr-sourcecompanion.cpp index 02475eb..b8c5547 100644 --- a/src/odr-sourcecompanion.cpp +++ b/src/odr-sourcecompanion.cpp @@ -323,10 +323,6 @@ int main(int argc, char *argv[]) } } - if (not edi_output_uris.empty()) { - edi_output.set_tist(tist_enabled, tist_delay_ms); - } - if (padlen != 0) { int flags; if (mkfifo(pad_fifo, S_IWUSR | S_IRUSR | S_IRGRP | S_IROTH) != 0) { @@ -436,14 +432,21 @@ int main(int argc, char *argv[]) } } - numOutBytes = avtinput.getNextFrame(outbuf); - if (numOutBytes == 0) { + chrono::system_clock::time_point ts; + numOutBytes = avtinput.getNextFrame(outbuf, ts); + if (numOutBytes > 0) { + if (not edi_output_uris.empty()) { + edi_output.set_tist(tist_enabled, tist_delay_ms, ts); + } + } + else { const auto curTime = std::chrono::steady_clock::now(); const auto diff = curTime - timeout_start; if (diff > timeout_duration) { fprintf(stderr, "timeout reached\n"); timedout = true; - } else { + } + else { const int wait_ms = 1; usleep(wait_ms * 1000); } |