#include <ProfilingMocks.hpp>
Definition at line 278 of file ProfilingMocks.hpp.
◆ MockStreamCounterBuffer()
◆ ~MockStreamCounterBuffer()
◆ Commit()
void Commit |
( |
IPacketBufferPtr & |
packetBuffer, |
|
|
unsigned int |
size, |
|
|
bool |
notifyConsumer = true |
|
) |
| |
|
inlineoverridevirtual |
Implements IBufferManager.
Definition at line 304 of file ProfilingMocks.hpp.
306 std::lock_guard<std::mutex> lock(m_Mutex);
308 packetBuffer->Commit(size);
309 m_BufferList.push_back(std::move(packetBuffer));
310 m_CommittedSize += size;
void FlushReadList() override
◆ FlushReadList()
Implements IBufferManager.
Definition at line 355 of file ProfilingMocks.hpp.
358 if (m_Consumer !=
nullptr)
virtual void SetReadyToRead()=0
Set a "ready to read" flag in the buffer to notify the reading thread to start reading it...
◆ GetCommittedSize()
unsigned int GetCommittedSize |
( |
| ) |
const |
|
inline |
◆ GetReadableBuffer()
Implements IBufferManager.
Definition at line 325 of file ProfilingMocks.hpp.
327 std::lock_guard<std::mutex> lock(m_Mutex);
329 if (m_BufferList.empty())
334 m_BufferList.pop_back();
335 m_ReadableSize += buffer->GetSize();
std::unique_ptr< IPacketBuffer > IPacketBufferPtr
◆ GetReadableSize()
unsigned int GetReadableSize |
( |
| ) |
const |
|
inline |
◆ GetReadSize()
unsigned int GetReadSize |
( |
| ) |
const |
|
inline |
◆ MarkRead()
Implements IBufferManager.
Definition at line 339 of file ProfilingMocks.hpp.
341 std::lock_guard<std::mutex> lock(m_Mutex);
343 m_ReadSize += packetBuffer->GetSize();
344 packetBuffer->MarkRead();
◆ Release()
◆ Reserve()
IPacketBufferPtr Reserve |
( |
unsigned int |
requestedSize, |
|
|
unsigned int & |
reservedSize |
|
) |
| |
|
inlineoverridevirtual |
Implements IBufferManager.
Definition at line 290 of file ProfilingMocks.hpp.
292 std::lock_guard<std::mutex> lock(m_Mutex);
295 if (requestedSize > m_MaxBufferSize)
298 std::to_string(m_MaxBufferSize) +
"] bytes");
300 reservedSize = requestedSize;
301 return std::make_unique<MockPacketBuffer>(requestedSize);
◆ SetConsumer()
The documentation for this class was generated from the following file: