TransportTcpIO.h

Go to the documentation of this file.

//
// Copyright (c) 2002-2026 WEINZIERL ENGINEERING GmbH
// All rights reserved.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
// SHALL THE COPYRIGHT HOLDERS BE LIABLE FOR ANY DAMAGES OR OTHER LIABILITY,
// WHETHER IN CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE
//
 
#ifndef __BAOSLIB_TRANSPORT_TCP_IO_H__
#define __BAOSLIB_TRANSPORT_TCP_IO_H__
 
#include "baos/BaosLib_export.h"
#include "baos/config.h"
#include "baos/connection/IOEvent.h"
#include "baos/ip/TcpIO.h"
#include "wzcpp/features/concurrent/executor.h"
#include "baos/transport/TransportIO.h"
 
#include <array>
#include <atomic>
#include <memory>
#include <string>
 
 
namespace wz::baos::ip
{
class Ip4Driver;
}
 
namespace wz::baos::transport
{
 
 
/******************************************************************
 * TransportTcpIO
 ******************************************************************/
 
class BAOSLIB_EXPORT TransportTcpIO: public TransportIO
{
public:
    using UPtr       = std::unique_ptr<TransportTcpIO>;        
    using UniqueLock = std::unique_lock<std::mutex>;  
 
    TransportTcpIO(BaosMsgQueue& msgQueue, wzcpp::ExecutorBase& executor, wzcpp::TimerManager<Clock>& timerManager);
 
 
    TransportTcpIO(BaosMsgQueue& msgQueue, std::unique_ptr<ip::Ip4Driver>& driver, wzcpp::ExecutorBase& executor, wzcpp::TimerManager<Clock>& timerManager);
 
    ip::Ip4Driver& getDriver();
 
    ~TransportTcpIO();
 
    void stop() override;
 
    void send(const Buffer& buf) override;
 
    void open(const std::string& ip4Address, std::uint16_t port);
    void open(IOEvent::EventDataType arg);
 
    void close() override;
 
    void waitForFinished() override;
 
    bool isOpen() override;
 
private:
    void eventHandler() override;
 
    void sendToIo(const Buffer& frame) override;
 
protected:
    ip::TcpIO tcpIO_; 
};
 
}  // namespace wz::baos::transport
 
#endif  //__BAOSLIB_TRANSPORT_TCP_IO_H__