#include <NetworkMessageStream.hpp>
Public Member Functions | |
NetworkMessageStream (NetworkStream *stream) | |
void | read (MessageStreamHandler &handler) |
void | request (indri::xml::XMLNode *messageNode) |
void | reply (indri::xml::XMLNode *replyNode) |
void | reply (const std::string &name, const void *buffer, unsigned int size) |
void | replyDone () |
void | error (const std::string &errorMessage) |
bool | alive () |
indri::thread::Lockable & | mutex () |
Private Member Functions | |
int | _findEOL () |
void | _cleanBuffer () |
int | _bufferLength () |
Private Attributes | |
indri::thread::Mutex | _lock |
indri::utility::Buffer | _buffer |
NetworkStream * | _stream |
int | _readPosition |
int | _writePosition |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|