StreamingRingBuffer
fReceiveBuffer = new(std::nothrow) StreamingRingBuffer(16 * 1024);
fSendBuffer = new(std::nothrow) StreamingRingBuffer(16 * 1024);
class StreamingRingBuffer;
StreamingRingBuffer * fReceiveBuffer;
StreamingRingBuffer * fSendBuffer;
NetReceiver::NetReceiver(BNetEndpoint *listener, StreamingRingBuffer *target,
class StreamingRingBuffer;
StreamingRingBuffer *target,
StreamingRingBuffer * fTarget;
NetSender::NetSender(BNetEndpoint *endpoint, StreamingRingBuffer *source)
class StreamingRingBuffer;
StreamingRingBuffer *source);
StreamingRingBuffer * fSource;
fSendBuffer.SetTo(new(std::nothrow) StreamingRingBuffer(16 * 1024));
fReceiveBuffer.SetTo(new(std::nothrow) StreamingRingBuffer(16 * 1024));
ObjectDeleter<StreamingRingBuffer>
ObjectDeleter<StreamingRingBuffer>
class StreamingRingBuffer;
StreamingRingBuffer* ReceiveBuffer()
StreamingRingBuffer* SendBuffer() { return fSendBuffer.Get(); }
RemoteMessage(StreamingRingBuffer* source,
StreamingRingBuffer *target);
StreamingRingBuffer* fSource;
StreamingRingBuffer* fTarget;
RemoteMessage::RemoteMessage(StreamingRingBuffer* source,
StreamingRingBuffer* target)
StreamingRingBuffer::Write(const void *buffer, size_t length)
StreamingRingBuffer::MakeEmpty()
StreamingRingBuffer::StreamingRingBuffer(size_t bufferSize)
StreamingRingBuffer::~StreamingRingBuffer()
StreamingRingBuffer::InitCheck()
StreamingRingBuffer::Read(void *buffer, size_t length, bool onlyBlockOnNoData)
class StreamingRingBuffer {
StreamingRingBuffer(size_t bufferSize);
~StreamingRingBuffer();