RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
active (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
ActiveEndpoint(const std::string &name) (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline] |
addFd(int fd, void *data=0) | Datacratic::Epoller | |
addFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
addr (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
afterSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
alive | Datacratic::EndpointBase | [protected] |
associateHandler(const std::shared_ptr< TransportBase > &transport) | Datacratic::EndpointBase | [inline, protected, virtual] |
AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
checkFinished() const | Datacratic::EndpointBase | [inline, protected] |
close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
closePeer() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, virtual] |
connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
Connections typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
connector (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
createConnections(int num_connections, bool synchronous, bool throwIfAnyConnectionError, OnConnectionError onEachConnectionError, double timeout=1.0) | Datacratic::ActiveEndpoint | |
debug(bool debugOn) | Datacratic::AsyncEventSource | [inline, virtual] |
debug_ | Datacratic::AsyncEventSource | |
disconnect() | Datacratic::AsyncEventSource | |
doAsync(const std::shared_ptr< TransportBase > &transport, const boost::function< void()> &callback, const char *nameOfCallback) | Datacratic::EndpointBase | [protected] |
doConnect(const std::shared_ptr< TransportBase > &transport, const ACE_INET_Addr &addr, double timeout, bool block) | Datacratic::ActiveEndpoint | [inline, virtual] |
doNothingOnConnectionError(const std::string &error) | Datacratic::ActiveEndpoint | [static] |
dumpState() const | Datacratic::ActiveEndpoint | [virtual] |
EndpointBase(const std::string &name) (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
getConnection(OnNewConnection onNewConnection, OnConnectionError onConnectionError, double timeout) | Datacratic::ActiveEndpoint | [virtual] |
Guard typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
HandleEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
handleEvent | Datacratic::Epoller | |
handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent()) | Datacratic::Epoller | |
hostname() const | Datacratic::ActiveEndpoint | [inline, virtual] |
hostname_ (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
idle | Datacratic::EndpointBase | [mutable, protected] |
inactive (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
init(int port, const std::string &hostname, int connections=0, int threads=1, bool synchronous=true, bool throwIfAnyConnectionError=true, OnConnectionError onEachConnectionError=doNothingOnConnectionError, double timeout=1.0) | Datacratic::ActiveEndpoint | |
init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | |
lock (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [mutable, protected] |
Lock typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
makeNewTransport() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, virtual] |
makeRealTime(int priority=1) | Datacratic::EndpointBase | |
modifyIdle | Datacratic::EndpointBase | [mutable, protected] |
name() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline] |
needsPoll | Datacratic::AsyncEventSource | |
newConnection(OnNewConnection onNewConnection, OnConnectionError onConnectionError, double timeout=1.0) | Datacratic::ActiveEndpoint | [inline, virtual] |
notifyCloseTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::ActiveEndpoint | [protected, virtual] |
notifyNewTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::ActiveEndpoint | [protected, virtual] |
notifyRecycleTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::ActiveEndpoint | [protected, virtual] |
notifyTransportOpen(const std::shared_ptr< TransportBase > &transport) | Datacratic::ActiveEndpoint | [protected, virtual] |
numActiveConnections() const (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline] |
numConnections() const | Datacratic::EndpointBase | [virtual] |
numConnectionsByHost() const | Datacratic::EndpointBase | [virtual] |
numInactiveConnections() const (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline] |
onCheckFinished | Datacratic::EndpointBase | |
OnConnectionError typedef (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | |
OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
OnNewConnection typedef (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | |
onTransportClose (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
OnTransportEvent typedef | Datacratic::EndpointBase | |
onTransportOpen (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
parent_ | Datacratic::AsyncEventSource | |
poll() const | Datacratic::Epoller | [virtual] |
port() const | Datacratic::ActiveEndpoint | [inline, virtual] |
port_ (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
processOne() | Datacratic::Epoller | [inline, virtual] |
removeFd(int fd) | Datacratic::Epoller | |
restartFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
restartPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
selectFd() const | Datacratic::Epoller | [inline, virtual] |
shutdown() | Datacratic::ActiveEndpoint | |
singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
sleepUntilIdle() const | Datacratic::EndpointBase | |
spinup(int num_threads, bool synchronous) | Datacratic::EndpointBase | [virtual] |
startPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
stopPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
threadsActive() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline] |
throwExceptionOnConnectionError(const std::string &error) | Datacratic::ActiveEndpoint | [static] |
useThisThread() | Datacratic::EndpointBase | |
~ActiveEndpoint() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline] |
~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
~EndpointBase() (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [virtual] |
~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller |