fix realignment

2026-05-30 23:10:35 +03:00
parent 003279669e
commit c2e823beda
1 changed files with 8 additions and 4 deletions
@@ -239,13 +239,17 @@ void DeckLinkOutNode::process() {
        if (status == MXL_ERR_OUT_OF_RANGE_TOO_LATE || status == MXL_ERR_OUT_OF_RANGE_TOO_EARLY) {
            auto now = mxlGetTime();
            auto current_index = mxlTimestampToIndex(&flow_rate_, now);
-            read_index_ = current_index - 2;
-            if (grains_read_ == 0) {
-                spdlog::warn("DeckLink-out: realigned to source index {}", read_index_);
-            }
-        }
+            spdlog::warn("DeckLink-out: realigned from {} to {}", source_index, current_index - 2);
+            source_index = current_index - 2;
+
+            status = mxlFlowReaderGetGrain(*reader_, source_index, 5000000ULL, &grain_info, &payload);
+            if (status != MXL_STATUS_OK) {
                return;
            }
+        } else {
+            return;
+        }
+    }

    mxlFlowConfigInfo config{};
    mxlFlowReaderGetConfigInfo(*reader_, &config);