small fixes

This commit is contained in:
Vladislav Mikhalin 2024-12-27 21:24:36 +03:00
parent 17323ba10f
commit f7a34b3bc6

View File

@ -271,14 +271,14 @@ AjmJob AjmJobFromBatchBuffer(u32 instance_id, AjmBatchBuffer batch_buffer) {
} }
const auto control_flags = job_flags.value().control_flags; const auto control_flags = job_flags.value().control_flags;
if (True(control_flags & AjmJobControlFlags::Resample)) {
job.input.resample_parameters = input_batch.Consume<AjmSidebandResampleParameters>();
}
if (True(control_flags & AjmJobControlFlags::Initialize)) { if (True(control_flags & AjmJobControlFlags::Initialize)) {
job.input.init_params = AjmDecAt9InitializeParameters{}; job.input.init_params = AjmDecAt9InitializeParameters{};
std::memcpy(&job.input.init_params.value(), input_batch.GetCurrent(), std::memcpy(&job.input.init_params.value(), input_batch.GetCurrent(),
input_batch.BytesRemaining()); input_batch.BytesRemaining());
} }
if (True(control_flags & AjmJobControlFlags::Resample)) {
job.input.resample_parameters = input_batch.Consume<AjmSidebandResampleParameters>();
}
} }
// Initialize sideband output parameters // Initialize sideband output parameters
@ -321,7 +321,7 @@ std::shared_ptr<AjmBatch> AjmBatch::FromBatchBuffer(std::span<u8> data) {
while (!buffer.IsEmpty()) { while (!buffer.IsEmpty()) {
auto& job_chunk = buffer.Consume<AjmChunkJob>(); auto& job_chunk = buffer.Consume<AjmChunkJob>();
if (job_chunk.header.ident == AjmIdentInlineBuf) { if (job_chunk.header.ident == AjmIdentInlineBuf) {
// Inline buffers are used to pass data to sideband, input or output buffers. // Inline buffers are used to store sideband input data.
// We should just skip them as they do not require any special handling. // We should just skip them as they do not require any special handling.
buffer.Advance(job_chunk.size); buffer.Advance(job_chunk.size);
continue; continue;