block_simple.h

Go to the documentation of this file.

#pragma once

 
#include "dsp/block.h"
 
namespace satdump
{
    namespace ndsp
    {
        template <typename Ti, typename To>
        class BlockSimple : public Block
        {
        protected:
            float output_buffer_size_ratio = 1;
 
        private:
            bool work()
            {
                DSPBuffer iblk = inputs[0].fifo->wait_dequeue();
 
                if (iblk.isTerminator())
                {
                    if (iblk.terminatorShouldPropagate())
                        outputs[0].fifo->wait_enqueue(outputs[0].fifo->newBufferTerminator());
                    inputs[0].fifo->free(iblk);
                    return true;
                }
 
                DSPBuffer oblk = outputs[0].fifo->newBufferSamples(ceil(iblk.max_size * output_buffer_size_ratio), sizeof(To));
 
                oblk.size = process(iblk.getSamples<Ti>(), iblk.size, oblk.getSamples<To>());
 
                if (oblk.size > 0)
                    outputs[0].fifo->wait_enqueue(oblk);
                inputs[0].fifo->free(iblk);
 
                return false;
            }
 
        public:
            BlockSimple(std::string id, std::vector<BlockIO> in = {}, std::vector<BlockIO> out = {}) : Block(id, in, out) {}

            virtual uint32_t process(Ti *input, uint32_t nsamples, To *output) = 0;
        };
    } // namespace ndsp
} // namespace satdump