hstreamprocessor.h

#ifndef __HSTREAMPROCESSOR_H
#define __HSTREAMPROCESSOR_H
 
#include "hreader.h"
#include "hwriter.h"
 
template <class T>
class HStreamProcessor : public HProcessor<T>
{
    public:
 
        HStreamProcessor(HWriter<T>* writer, HReader<T>* reader, int blocksize, bool* terminationToken);
 
        HStreamProcessor(HReader<T>* reader, int blocksize, bool* terminationToken);
 
        void Run(long unsigned int blocks = 0);
 
        bool Command(H_COMMAND_CLASS commandClass, H_COMMAND_OPCODE commandOpcode, int16_t length, HCommandData data)
        {
            HLog("Creating command with class %d and opcode %d with length %d", commandClass, commandOpcode, length);
            HCommand cmd = {static_cast<int16_t>(commandClass), static_cast<int16_t>(commandOpcode), length, data};
 
            if( HProcessor<T>::_reader != nullptr )
            {
                HLog("Sending command to reader chain");
                if( !HProcessor<T>::_reader->Command(&cmd) )
                {
                    HError("Error when sending command to reader chain");
                    return false;
                }
            }
            if( HProcessor<T>::_writer != nullptr )
            {
                HLog("Sending command to writer chain");
                if( !HProcessor<T>::_writer->Command(&cmd) )
                {
                    HError("Error when sending command to writer chain");
                    return false;
                }
            }
 
            HLog("Command sent successfully");
            return true;
        }
};
 
#endif