hmbdc
simplify-high-performance-messaging-programming
|
Public Member Functions | |
AsyncSendServer (Config const &cfg, io_service &ios, size_t toSendQueueMaxSize) | |
void | queue (pair< char const *, char const * > const &t, ToSend &&toSend, size_t toSendByteSize, MonoLockFreeBuffer::iterator it) |
MonoLockFreeBuffer::iterator | run (MonoLockFreeBuffer::iterator begin, MonoLockFreeBuffer::iterator end) __restrict__ |
run the server's async send function and decide which items in buffer can be release More... | |
size_t | readySessionCount () const override |
void | killSlowestSession () |
![]() | |
SendServer (Config const &cfg, io_service &ios) | |
TopicSource const & | advertisingMessage () const |
Additional Inherited Members | |
![]() | |
Config | config_ |
tcp::acceptor | acceptor_ |
tcp::socket | socket_ |
TopicSource | advertisingMessage_ |
|
inline |
run the server's async send function and decide which items in buffer can be release
called all the time
begin | if nothing can be released in buffer return this |
end | if all can be releases return this |