RemotingReader.hpp

 
//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Rsc/Services/Rsc.h"
 
// forwards
namespace CommonRemoting
{
class BinaryReader2;
}
 
namespace Arp { namespace System { namespace Rsc { namespace Services
{
 
using namespace CommonRemoting;
 
// forwards
class RscReader;
class RscClientContext;
 
class RemotingReader
{
    friend class RscStream;
 
public: // construction
    RemotingReader(BinaryReader2& binaryReader, RscReader& rscReader, RscClientContext* pRscClientContext = nullptr);
 
public: // getter
    RscReader& GetRscReader(void);
    bool       HasDataTagging(void)const;
 
public: // operations
    size_t              ReadArrayLength(void);
    RscType             ReadEnumeratorTag(bool& isEndTag);
    void                ReadDataInternal(byte* pBuffer, size_t count);
    RscStringEncoding   ReadStringEncoding(void);
    void                ReadStringInternal(char* pBuffer, size_t count, RscStringEncoding encoding, bool readTag = true);
    RscType             ReadObjectType(void);
    size_t              TryReadDataInternal(byte* pBuffer, size_t count);
    void                BeginReadStream(int& maxPackageSize, int& count, int& remaining);
    bool                ReadStream(byte* pBuffer, int bufferSize, int maxPackageSize, int& count, int& remaining);
    DateTime            ReadDateTime(void);
    RscType             ReadTag(void);
    void                ReadTag(RscType expectedType);
    void                ReadArrayTag(RscType elementType, size_t& arrayLength);
    void                ReadBeginStruct(size_t fieldCount);
    size_t              ReadFieldCount(void);
    void                ReadSecurityToken(SecurityToken& value, bool readTag = true);
    RscArrayInformation ReadArrayInformation(void);
 
private: // fields
    BinaryReader2&      binaryReader;
    RscReader&          rscReader;
    RscClientContext*   pRscClientContext = nullptr;
};
 
// inline methods of class RemotingReader
inline RscReader& RemotingReader::GetRscReader(void)
{
    return this->rscReader;
}
 
 
 
}}}} // end of namespace Arp::System::Rsc::Services