Equalizer
1.4.1
|
A proxy connection buffering outgoing data into a memory buffer. More...
#include <bufferConnection.h>
Public Member Functions | |
CO_API void | sendBuffer (ConnectionPtr connection) |
CO_API uint64_t | getSize () const |
Protected Member Functions | |
virtual void | readNB (void *, const uint64_t) |
Start a read operation on the connection. | |
virtual int64_t | readSync (void *, const uint64_t, const bool) |
Finish reading data from the connection. | |
virtual CO_API int64_t | write (const void *buffer, const uint64_t bytes) |
Write data to the connection. | |
virtual Notifier | getNotifier () const |
A proxy connection buffering outgoing data into a memory buffer.
Definition at line 29 of file bufferConnection.h.
virtual Notifier co::BufferConnection::getNotifier | ( | ) | const [inline, protected, virtual] |
Implements co::Connection.
Definition at line 44 of file bufferConnection.h.
virtual void co::BufferConnection::readNB | ( | void * | buffer, |
const uint64_t | bytes | ||
) | [inline, protected, virtual] |
Start a read operation on the connection.
This method is the low-level counterpart to recvNB().
This function returns immediately. The operation's Notifier will signal data availability, upon which readSync() should be used to finish the operation.
buffer | the buffer receiving the data. |
bytes | the number of bytes to read. |
Implements co::Connection.
Definition at line 39 of file bufferConnection.h.
virtual int64_t co::BufferConnection::readSync | ( | void * | buffer, |
const uint64_t | bytes, | ||
const bool | block | ||
) | [inline, protected, virtual] |
Finish reading data from the connection.
This method is the low-level counterpart to recvSync(). It may return with a partial read.
buffer | the buffer receiving the data. |
bytes | the number of bytes to read. |
block | internal WAR parameter, ignore it in the implementation unless you know exactly why not. |
Implements co::Connection.
Definition at line 40 of file bufferConnection.h.
virtual CO_API int64_t co::BufferConnection::write | ( | const void * | buffer, |
const uint64_t | bytes | ||
) | [protected, virtual] |
Write data to the connection.
buffer | the buffer containing the message. |
bytes | the number of bytes to write. |
Implements co::Connection.