BlockingSslClientSocket.h

Go to the documentation of this file.

 
// BlockingSslClientSocket.h
 
// Declares the cBlockingSslClientSocket class representing a blocking TCP socket with client SSL encryption over it
 
 
 
 
 
#pragma once
 
#include "../OSSupport/Network.h"
#include "CallbackSslContext.h"
 
 
 
 
 
class cBlockingSslClientSocket :
    protected cCallbackSslContext::cDataCallbacks
{
public:
    cBlockingSslClientSocket(void);
 
    virtual ~cBlockingSslClientSocket(void) override
    {
        Disconnect();
    }
 
    bool Connect(const AString & a_ServerName, UInt16 a_Port);
 
    bool Send(const void * a_Data, size_t a_NumBytes);
 
    int Receive(void * a_Data, size_t a_MaxBytes);
 
    void Disconnect(void);
 
    void SetExpectedPeerName(AString a_ExpectedPeerName);
 
    void SetSslConfig(std::shared_ptr<const cSslConfig> a_Config);
 
    const AString & GetLastErrorText(void) const { return m_LastErrorText; }
 
protected:
    friend class cBlockingSslClientSocketConnectCallbacks;
    friend class cBlockingSslClientSocketLinkCallbacks;
 
    cCallbackSslContext m_Ssl;
 
    cTCPLinkPtr m_Socket;
 
    cEvent m_Event;
 
    std::shared_ptr<const cSslConfig> m_Config;
 
    AString m_ExpectedPeerName;
 
    AString m_ServerName;
 
    AString m_LastErrorText;
 
    std::atomic<bool> m_IsConnected;
 
    cCriticalSection m_CSIncomingData;
 
    AString m_IncomingData;
 
 
    void OnConnected(void);
 
    void OnConnectError(const AString & a_ErrorMsg);
 
    void OnReceivedData(const char * a_Data, size_t a_Size);
 
    void SetLink(cTCPLinkPtr a_Link);
 
    void OnDisconnected(void);
 
    // cCallbackSslContext::cDataCallbacks overrides:
    virtual int ReceiveEncrypted(unsigned char * a_Buffer, size_t a_NumBytes) override;
    virtual int SendEncrypted(const unsigned char * a_Buffer, size_t a_NumBytes) override;
} ;