 |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
|
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, protected] |
| ActiveEndpointT(const std::string &name) (defined in Datacratic::ActiveEndpointT< SocketTransport >) | Datacratic::ActiveEndpointT< SocketTransport > | [inline, protected] |
| addFd(int fd, void *data=0) | Datacratic::Epoller | [protected] |
| addFdOneShot(int fd, void *data=0) | Datacratic::Epoller | [protected] |
| addr (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
| afterSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| alive | Datacratic::EndpointBase | [protected] |
| associateHandler(const std::shared_ptr< TransportBase > &transport) | Datacratic::EndpointBase | [inline, protected, virtual] |
| AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, protected] |
| barrier() | Datacratic::RemoteOutput | |
| beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| checkFinished() const | Datacratic::EndpointBase | [inline, protected] |
| clearStats() | Datacratic::LogOutput | [virtual] |
| close() | Datacratic::RemoteOutput | [virtual] |
| closePeer() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, protected, virtual] |
| connect(int port, const std::string &hostname, double timeout=10.0) | Datacratic::RemoteOutput | |
| connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, protected, 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 | [protected] |
| debug(bool debugOn) | Datacratic::AsyncEventSource | [inline, protected, virtual] |
| debug_ | Datacratic::AsyncEventSource | [protected] |
| disconnect() | Datacratic::AsyncEventSource | [protected] |
| 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, protected, virtual] |
| doNothingOnConnectionError(const std::string &error) | Datacratic::ActiveEndpoint | [protected, static] |
| dumpState() const | Datacratic::ActiveEndpoint | [protected, virtual] |
| EndpointBase(const std::string &name) (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| flush() | Datacratic::RemoteOutput | |
| getConnection(OnNewConnection onNewConnection, OnConnectionError onConnectionError, double timeout) | Datacratic::ActiveEndpoint | [protected, virtual] |
| Guard typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| HandleEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| handleEvent | Datacratic::Epoller | [protected] |
| handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent()) | Datacratic::Epoller | [protected] |
| ActiveEndpointT< SocketTransport >::hostname() const | Datacratic::ActiveEndpoint | [inline, protected, 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 | [protected] |
| init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| Lock typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| lock (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [mutable, protected] |
| logMessage(const std::string &channel, const std::string &message) | Datacratic::RemoteOutput | [virtual] |
| LogOutput() (defined in Datacratic::LogOutput) | Datacratic::LogOutput | [inline] |
| makeNewTransport() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, protected, virtual] |
| makeRealTime(int priority=1) | Datacratic::EndpointBase | [protected] |
| modifyIdle | Datacratic::EndpointBase | [mutable, protected] |
| name() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline, protected] |
| needsPoll | Datacratic::AsyncEventSource | [protected] |
| newConnection(OnNewConnection onNewConnection, OnConnectionError onConnectionError, double timeout=1.0) | Datacratic::ActiveEndpoint | [inline, protected, virtual] |
| notifyCloseTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::RemoteOutput | [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, protected] |
| numConnections() const | Datacratic::EndpointBase | [protected, virtual] |
| numConnectionsByHost() const | Datacratic::EndpointBase | [protected, virtual] |
| numInactiveConnections() const (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, protected] |
| onCheckFinished | Datacratic::EndpointBase | [protected] |
| OnConnectionError typedef (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
| onConnectionError | Datacratic::RemoteOutput | |
| OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| OnNewConnection typedef (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
| onTransportClose (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| OnTransportEvent typedef | Datacratic::EndpointBase | [protected] |
| onTransportOpen (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| parent_ | Datacratic::AsyncEventSource | [protected] |
| poll() const | Datacratic::Epoller | [protected, virtual] |
| ActiveEndpointT< SocketTransport >::port() const | Datacratic::ActiveEndpoint | [inline, protected, virtual] |
| port_ (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [protected] |
| processOne() | Datacratic::Epoller | [inline, protected, virtual] |
| RemoteOutput() (defined in Datacratic::RemoteOutput) | Datacratic::RemoteOutput | |
| removeFd(int fd) | Datacratic::Epoller | [protected] |
| restartFdOneShot(int fd, void *data=0) | Datacratic::Epoller | [protected] |
| restartPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| selectFd() const | Datacratic::Epoller | [inline, protected, virtual] |
| shutdown() | Datacratic::RemoteOutput | |
| singleThreaded() const | Datacratic::AsyncEventSource | [inline, protected, virtual] |
| sleepUntilIdle() const | Datacratic::EndpointBase | [protected] |
| spinup(int num_threads, bool synchronous) | Datacratic::EndpointBase | [protected, virtual] |
| startPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| stats() const | Datacratic::LogOutput | [virtual] |
| stopPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| sync() | Datacratic::RemoteOutput | |
| threadsActive() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline, protected] |
| throwExceptionOnConnectionError(const std::string &error) | Datacratic::ActiveEndpoint | [protected, static] |
| useThisThread() | Datacratic::EndpointBase | [protected] |
| ~ActiveEndpoint() (defined in Datacratic::ActiveEndpoint) | Datacratic::ActiveEndpoint | [inline, protected] |
| ~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, protected, virtual] |
| ~EndpointBase() (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected, virtual] |
| ~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | [protected] |
| ~LogOutput() (defined in Datacratic::LogOutput) | Datacratic::LogOutput | [inline, virtual] |
| ~RemoteOutput() (defined in Datacratic::RemoteOutput) | Datacratic::RemoteOutput | [virtual] |
1.7.6.1
