#include <ClientBufferedReaderHandler.h>
| ClientBufferedReaderHandler::ClientBufferedReaderHandler |
( |
Client * |
client, |
|
|
uint32_t |
fd, |
|
|
uint32_t |
buf_size, |
|
|
uint32_t |
outstanding, |
|
|
uint64_t |
start_offset, |
|
|
uint64_t |
end_offset |
|
) |
| |
| ClientBufferedReaderHandler::~ClientBufferedReaderHandler |
( |
| ) |
|
|
virtual |
| void ClientBufferedReaderHandler::handle |
( |
EventPtr & |
event_ptr | ) |
|
|
virtual |
Callback method.
When the Comm layer needs to deliver an event to the application, this method is called to do so. The set of event types include, CONNECTION_ESTABLISHED, DISCONNECT, MESSAGE, ERROR, and TIMER.
- Parameters
-
| event_ptr | smart pointer to Event object |
Implements Hypertable::DispatchHandler.
Definition at line 99 of file ClientBufferedReaderHandler.cc.
| size_t ClientBufferedReaderHandler::read |
( |
void * |
buf, |
|
|
size_t |
len |
|
) |
| |
| void ClientBufferedReaderHandler::read_ahead |
( |
| ) |
|
|
private |
| uint64_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_actual_offset |
|
private |
| Client* Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_client |
|
private |
| std::condition_variable Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_cond |
|
private |
| uint64_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_end_offset |
|
private |
| const uint8_t* Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_end_ptr |
|
private |
| bool Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_eof |
|
private |
| int Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_error |
|
private |
| std::string Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_error_msg |
|
private |
| uint32_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_fd |
|
private |
| uint32_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_max_outstanding |
|
private |
| std::mutex Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_mutex |
|
private |
| uint32_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_outstanding |
|
private |
| uint64_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_outstanding_offset |
|
private |
| const uint8_t* Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_ptr |
|
private |
| std::queue<EventPtr> Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_queue |
|
private |
| uint32_t Hypertable::FsBroker::Lib::ClientBufferedReaderHandler::m_read_size |
|
private |
The documentation for this class was generated from the following files:
0.9.8.10
Public Member Functions inherited from Hypertable::DispatchHandler
1.8.8