cOSPipe.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cOSPipe_H
#define _INC_cOSPipe_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "../GrayLibBase.h"
#include "GrayCore/include/cOSHandle.h"
 
#ifndef UNDER_CE
#include "GrayCore/include/cFilePath.h" // cStringF
#include "GrayCore/include/cStream.h"
 
namespace GrayLib
{
        UNITTEST2_PREDEF(cOSPipe);
 
        class GRAYLIB_LINK cOSPipe : public cOSHandle
        {
 
        protected:
                cOSPipe(void);
                virtual ~cOSPipe(void);
 
        public:
                static StrLen_t GRAYCALL MakePipePath(OUT FILECHAR_t* pszPipePath, StrLen_t nLenMax, const FILECHAR_t* pszPipeName);
                UNITTEST2_PREDEF(cOSPipe);
        };
 
        class GRAYLIB_LINK cOSPipeServer : public cOSPipe, public cStreamInput
        {
        public:
                static const size_t kSizeDef = 1024;
 
#ifdef _WIN32
        private:
                bool m_bConnected;              // i currently have a client connected.
        protected:
                HRESULT ConnectPipe();
#endif
        public:
                bool isConnected() const noexcept
                {
                        return m_bConnected;    // i currently have a client connected.
                }
                cOSPipeServer(void);
                virtual ~cOSPipeServer(void);
                HRESULT CreatePipe(const FILECHAR_t* pszPipeName, size_t nOutBufferSize = kSizeDef, TIMESYS_t waitForClient = cTimeSys::k_FREQ / 2);
                virtual HRESULT ReadX(void* pBuffer, size_t nDataSize) override;
        };
 
        class GRAYLIB_LINK cOSPipeClient : public cOSPipe, public cStreamOutput
        {
 
        public:
                cOSPipeClient();
                virtual ~cOSPipeClient(void);
 
                HRESULT OpenPipe(const FILECHAR_t* pszPipeName, TIMESYSD_t nTimeOutTotal = 0);
                virtual HRESULT WriteX(const void* pBuffer, size_t nDataSize) override;
 
                static HRESULT GRAYCALL OpenWritePipe(const FILECHAR_t* pszPipeName, TIMESYSD_t nTimeOutTotal, const void* pBuffer, size_t nDataSize);
        };
};
#endif // UNDER_CE
#endif