DataIOSocketRelay.h

Go to the documentation of this file.

/******************************************************************************
* Copyright (c) ATTX INC 2025. All Rights Reserved.
*
* This software and associated documentation (the "Software") are the 
* proprietary and confidential information of ATTX INC. The Software is 
* furnished under a license agreement between ATTX and the user organization 
* and may be used or copied only in accordance with the terms of the agreement.
* Refer to 'license/attx_license.adoc' for standard license terms.
*
* EXPORT CONTROL NOTICE: THIS SOFTWARE MAY INCLUDE CONTENT CONTROLLED UNDER THE
* INTERNATIONAL TRAFFIC IN ARMS REGULATIONS (ITAR) OR THE EXPORT ADMINISTRATION 
* REGULATIONS (EAR99). No part of the Software may be used, reproduced, or 
* transmitted in any form or by any means, for any purpose, without the express 
* written permission of ATTX INC.
******************************************************************************/
#ifndef UTILS_DATA_IO_SOCKET_RELAY_H
#define UTILS_DATA_IO_SOCKET_RELAY_H
 
#include <netinet/in.h>
 
#include "architecture/DataIO.hpp"
 
namespace warptwin {
 
const int DATASOCK_IO_BUFFER_SIZE = 1000;

class DataIOSocketRelay : public clockwerk::DataIOBase {
public:
    DataIOSocketRelay(DataIOBase& map_target, const char* ip, int port, bool is_read = true); 
    ~DataIOSocketRelay() {};

    int16 syncExternal() override;
protected:
    int16 _syncWriteSocket();
    int16 _syncReadSocket();
 
    // All of our socket information in ONE convenient place!
    std::string _ip;                
    int _port = 0;                  
    int _sock_fd = -1;              
    sockaddr_in _addr;              
    bool _is_read;                  
    DataIOBase& _tgt;               
 
    // Buffer for string io
    char _buffer[DATASOCK_IO_BUFFER_SIZE];
};
 
}
 
#endif