![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
Classes | |
struct | WriteEntry |
Public Types | |
enum | NextAction { NEXT_CLOSE, NEXT_RECYCLE, NEXT_CONTINUE } |
typedef boost::function< void()> | OnWriteFinished |
Public Member Functions | |
void | send (const std::string &str, NextAction action=NEXT_CONTINUE, OnWriteFinished onWriteFinished=OnWriteFinished()) |
virtual void | handleData (const std::string &data)=0 |
virtual void | handleError (const std::string &message)=0 |
virtual void | doError (const std::string &error) |
virtual void | handleInput () |
virtual void | handleOutput () |
virtual void | handleTimeout (Date time, size_t cookie) |
Public Attributes | |
std::string | error |
int | done |
bool | inSend |
std::list< WriteEntry > | toWrite |
Friends | |
class | TransportBase |
Definition at line 235 of file connection_handler.h.
Action to perform once we've finished sending.
Definition at line 248 of file connection_handler.h.
void Datacratic::PassiveConnectionHandler::doError | ( | const std::string & | error | ) | [virtual] |
Thing to call when we have an error internally. This may be called from within another handler.
Implements Datacratic::ConnectionHandler.
Definition at line 157 of file connection_handler.cc.
virtual void Datacratic::PassiveConnectionHandler::handleData | ( | const std::string & | data | ) | [pure virtual] |
Function called out to when we got some data
Implemented in FakeCarbon::CarbonConnection, Datacratic::HttpConnectionHandler, Datacratic::RemoteInputConnection, and Datacratic::RemoteOutputConnection.
virtual void Datacratic::PassiveConnectionHandler::handleError | ( | const std::string & | message | ) | [pure virtual] |
Function called out to when we got an error from the socket.
Reimplemented from Datacratic::ConnectionHandler.
Implemented in FakeCarbon::CarbonConnection, Datacratic::HttpConnectionHandler, Datacratic::RemoteInputConnection, Datacratic::RemoteOutputConnection, and Datacratic::ChunkedHttpHandler.
void Datacratic::PassiveConnectionHandler::send | ( | const std::string & | str, |
NextAction | action = NEXT_CONTINUE , |
||
OnWriteFinished | onWriteFinished = OnWriteFinished() |
||
) |
Send some data, with the given set of actions to be done once it's finished.
Definition at line 318 of file connection_handler.cc.