hmbdc
simplify-high-performance-messaging-programming
Public Types | Public Member Functions | Protected Attributes | List of all members
hmbdc::app::tcpcast::SendTransport Struct Reference

capture the transportation mechanism More...

#include <SendTransportEngine.hpp>

Inheritance diagram for hmbdc::app::tcpcast::SendTransport:
hmbdc::app::tcpcast::Transport hmbdc::app::tcpcast::SendTransportEngine

Public Types

using ptr = std::shared_ptr< SendTransport >
 
- Public Types inherited from hmbdc::app::tcpcast::Transport
using ptr = std::shared_ptr< Transport >
 

Public Member Functions

 SendTransport (Config const &cfg, size_t maxMessageSize, size_t minRecvToStart)
 ctor More...
 
template<typename... Messages>
void queue (Topic const &t, Messages &&...msgs)
 
template<typename... Messages>
bool tryQueue (Topic const &t, Messages &&...msgs)
 
template<typename Message , typename... Args>
void queueInPlace (Topic const &t, Args &&...args)
 
void queueBytes (Topic const &t, uint16_t tag, void const *bytes, size_t len)
 
void stop ()
 
void initInThread ()
 
bool match (Topic const &t) const
 
- Public Member Functions inherited from hmbdc::app::tcpcast::Transport
 Transport (Config const &cfg)
 
void initInThread ()
 
bool operator== (Transport const &other) const
 
bool operator< (Transport const &other) const
 

Protected Attributes

size_t maxMessageSize_
 
size_t minRecvToStart_
 
hmbdc::pattern::MonoLockFreeBuffer buffer_
 
unique_ptr< mcast::SendTransportmcSendTransport_
 
Rater rater_
 
Config mcConfig_
 
- Protected Attributes inherited from hmbdc::app::tcpcast::Transport
Config const config_
 
string hmbdcName_
 
string schedPolicy_
 
int schedPriority_
 
ip::udp::endpoint endpoint_
 
std::shared_ptr< io_service > pIos_
 
Topic const tcpcastAdTopic_
 

Detailed Description

capture the transportation mechanism

Constructor & Destructor Documentation

hmbdc::app::tcpcast::SendTransport::SendTransport ( Config const &  cfg,
size_t  maxMessageSize,
size_t  minRecvToStart 
)
inline

ctor

Parameters
cfgjason specifing the transport - see example, perf-tcpcast.cpp
maxMessageSizemax messafe size in bytes to be sent
minRecvToStartstart send when there are that many recipient online, otherwise hold the message in buffer

The documentation for this struct was generated from the following file: