mvrxchange_client.h

Go to the documentation of this file.

//-----------------------------------------------------------------------------
//----- Copyright MVR Group 
//-----------------------------------------------------------------------------
 
#pragma once
 
#include "mvrxchange_prefix.h"
#include "mvrxchange_message.h"
 
namespace MVRxchangeNetwork
{
    struct TCPMessageInfo
    {
        uint16_t port;
        std::string ip;
    };
    struct TCPMessageInfo {…};
 
    class MVRxchangeClient
    {
    public:
    
    struct SendResult
    {
        bool success;
        boost::system::error_code error;
        TCPMessageInfo messageInfo;
        MVRxchangePacket message;
    };
    struct SendResult {…};
    
    MVRxchangeClient(const MVRxchangePacket& packet);
    ~MVRxchangeClient();
 
    SendResult      SendMessage(std::chrono::steady_clock::duration timeout);
    bool Connect(SendResult& res, const std::string& host, const std::string& service, std::chrono::steady_clock::duration timeout);
 
    private:
 
    bool ReadMessage(SendResult& res, std::chrono::steady_clock::duration timeout);
    bool WriteMessage(SendResult& res, std::chrono::steady_clock::duration timeout);
    void Run(std::chrono::steady_clock::duration timeout);
 
    boost::asio::io_context   fio_context;
    tcp::socket               fSocket{fio_context};
    const MVRxchangePacket&   fMsg_send;
};
    class MVRxchangeClient {…};
}
namespace MVRxchangeNetwork {…}