hprocessor.h

#ifndef __HPROCESSOR_H
#define __HPROCESSOR_H
 
#include "hwriter.h"
#include "hreader.h"
 
template <class T>
class HProcessor : public HWriterConsumer<T>
{
    private:
 
        T* _buffer;
        int _blocksize;
        bool* _terminated;
        HMetrics _metrics;
 
    private:
 
        bool Start();
 
        bool Stop();
 
        void Init();
 
    protected:
 
        HWriter<T>* _writer;
 
        HReader<T>* _reader;
 
        HProcessor(HWriter<T>* writer, HReader<T>* reader, size_t blocksize, bool* terminationToken);
 
        HProcessor(HReader<T>* reader, size_t blocksize, bool* terminationToken);
 
        ~HProcessor();
 
        void SetWriter(HWriter<T>* writer)
        {
            _writer = writer;
        }
 
    public:
 
        int Read(T* dest, int blocksize);
 
        int Write(T* src, int blocksize);
 
        HReader<T>* GetReader();
 
        HWriter<T>* GetWriter();
 
        virtual void Run(long unsigned int blocks = 0);
 
        virtual void Halt();
 
        bool Command(H_COMMAND_CLASS commandClass, H_COMMAND_OPCODE commandOpcode, int32_t value) {
            HCommandData data;
            data.Value = value;
            return Command(commandClass,commandOpcode, 0, data);
        }
 
        bool Command(H_COMMAND_CLASS commandClass, H_COMMAND_OPCODE commandOpcode, int16_t length, void* content) {
            HCommandData data;
            data.Content = content;
            return Command(commandClass,commandOpcode, length, data);
        }
 
        bool Command(H_COMMAND_CLASS commandClass, H_COMMAND_OPCODE commandOpcode, bool state) {
            HCommandData data;
            data.State = state;
            return Command(commandClass,commandOpcode, 0, data);
        }
 
        virtual bool Command(H_COMMAND_CLASS commandClass, H_COMMAND_OPCODE commandOpcode, int16_t length, HCommandData data) = 0;
 
        HMetrics* GetMetrics() {
            return &_metrics;
        }
};
 
#endif