IOEvent.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_EVENT_H__
#define __BAOSLIB_EVENT_H__
 
#include "baos/BaosLib_export.h"
#include "baos/config.h"
#include "baos/ip/IpGeneral.h"
#include "baos/protocol/Response.h"
#include "wzcpp/features/concurrent/concurrent_queue.h"
 
#include <array>
#include <future>
#include <memory>
#include <optional>
#include <variant>
 
namespace wz::baos
{
 
class BAOSLIB_EXPORT IOEvent
{
public:
    using TimerIdList       = std::vector<std::uint64_t>;   
    using UPtr          = std::unique_ptr<IOEvent>;  
    using EventDataType = std::variant<std::monostate, ip::Ip4SocketAddress, 
        std::unique_ptr<Buffer>, TimerIdList>;  
 
    enum class Type
    {
        UNKNOWN,          
        OPEN,             
        CLOSE,            
        SOCKETERROR,      
        RESPONSETIMEOUT,  
        HEARTBEAT,        
        RX_PACKET,        
        TX_PACKET,        
        STACK_CONNECT_RESULT, 
        STACK_DISCONNECT_RESULT, 
        TIMER_ELAPSED,       
 
    };
    IOEvent() = default;  
 
    IOEvent(Type eventT, EventDataType&& pkt, protocol::ResponsePromise&& prom, std::uint64_t mID = 0);
 
public:
    Type eventType{Type::UNKNOWN};              
    std::uint64_t msgID{0};                     
    protocol::ResponsePromise responsePromise;  
    bool promiseMoved{false};  
    EventDataType data_;       
};
 
BAOSLIB_EXPORT std::string toString(IOEvent::Type typ);
 
using BaosMsgQueue = wzcpp::ConcurrentDeque<IOEvent>;  
using TransportMsgQueue = wzcpp::ConcurrentDeque<IOEvent>;  
}  // namespace wz::baos
 
#endif  //__BAOSLIB_TCP_IO_H__