cStreamStack.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cStreamStack_H
#define _INC_cStreamStack_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cStreamQueue.h"
 
namespace Gray
{
        class GRAYCORE_LINK cStreamStackInp : public cStreamQueue // cStreamInput, protected cStreamStack
        {
        protected:
                cStreamInput* m_pStreamInp;     
 
        protected:
                HRESULT ReadFill();
                HRESULT ReadFillAligned(size_t nSizeBlockAlign = 1);
 
        public:
                cStreamStackInp(cStreamInput* pStreamInp = nullptr, size_t nSizeMaxBuffer = cStream::k_FILE_BLOCK_SIZE) noexcept
                        : cStreamQueue(MIN(nSizeMaxBuffer / 2, 8 * 1024), nSizeMaxBuffer)       // chunk size, max size.
                        , m_pStreamInp(pStreamInp)
                {
                        ASSERT(get_AutoReadCommit() > 0);
                }
 
                virtual HRESULT ReadX(void* pData, size_t nDataSize) override = 0;      // MUST be overridden. and call ReadFill() at some point.
        };
 
        class GRAYCORE_LINK cStreamStackOut : public cStreamQueue // cStreamOutput, protected cStreamStack
        {
        protected:
                cStreamOutput* m_pStreamOut;    
 
        protected:
                HRESULT WriteFlush();
 
        public:
                cStreamStackOut(cStreamOutput* pStreamOut = nullptr, size_t nSizeBuffer = cStream::k_FILE_BLOCK_SIZE)
                        : cStreamQueue(8 * 1024, nSizeBuffer)
                        , m_pStreamOut(pStreamOut)
                {
                }
 
                virtual HRESULT WriteX(const void* pData, size_t nDataSize) override = 0; // cStreamOutput override calls WriteFlush() // MUST be overridden
        };
 
        class GRAYCORE_LINK cStreamStackPackets : public cStreamStackOut
        {
 
        public:
                cStreamStackPackets(cStreamOutput* pStreamOut = nullptr, size_t nSizeBuffer = cStream::k_FILE_BLOCK_SIZE)
                        : cStreamStackOut(pStreamOut, nSizeBuffer)
                {
                }
                virtual HRESULT WriteX(const void* pData, size_t nDataSize) override;
        };
};
 
#endif