![]() |
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.
1.7.6.1