![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
Public Types | |
typedef std::function< void(const std::string &)> | MessageHandler |
Public Member Functions | |
void | init (std::shared_ptr< ConfigurationService > config, const std::string &endpointName) |
void | shutdown () |
void | onConnect (int newFd) |
void | bindTcp (int port) |
void | onDisconnect (int fd) |
void | handleEvent (epoll_event &event) |
void | flushMessages () |
Public Attributes | |
int | socket_ |
MessageHandler | onMessage_ |
CharMessageRingBuffer | recvBuffer |
CharMessageRingBuffer | sendBuffer |
Definition at line 90 of file tcpsockets.h.
void TcpNamedEndpoint::init | ( | std::shared_ptr< ConfigurationService > | config, |
const std::string & | endpointName | ||
) |
The endpoint exists. Publish that to anyone who may care.
Reimplemented from Datacratic::NamedEndpoint.
Definition at line 287 of file tcpsockets.cc.