diff options
| author | Per Larsson <[email protected]> | 2022-02-21 14:22:38 +0100 |
|---|---|---|
| committer | Per Larsson <[email protected]> | 2022-02-21 14:22:38 +0100 |
| commit | fd9f9086b3ddd0c38fa87d7e49f6341dacdcc125 (patch) | |
| tree | 50be00e62f1e0d3a0521d08d5c7f00fe7787e014 /zencore/stream.cpp | |
| parent | Basic websocket service and test. (diff) | |
| download | zen-fd9f9086b3ddd0c38fa87d7e49f6341dacdcc125.tar.xz zen-fd9f9086b3ddd0c38fa87d7e49f6341dacdcc125.zip | |
Refactored websocket message.
Diffstat (limited to 'zencore/stream.cpp')
| -rw-r--r-- | zencore/stream.cpp | 19 |
1 files changed, 2 insertions, 17 deletions
diff --git a/zencore/stream.cpp b/zencore/stream.cpp index 36953363f..8faf90af2 100644 --- a/zencore/stream.cpp +++ b/zencore/stream.cpp @@ -26,25 +26,10 @@ BinaryWriter::Write(const void* data, size_t ByteCount, uint64_t Offset) } void -SimpleBinaryWriter::Write(MemoryView Memory) +BinaryWriter::Reset() { - const uint64_t NeededSize = m_Offset + Memory.GetSize(); - - if (NeededSize > m_Buffer.size()) - { - const size_t NewCapacity = RoundUp(NeededSize, m_BlockSize); - - m_Buffer.resize(NewCapacity); - } - - memcpy(m_Buffer.data() + m_Offset, Memory.GetData(), Memory.GetSize()); - - m_Offset += Memory.GetSize(); -} + RwLock::ExclusiveLockScope _(m_Lock); -void -SimpleBinaryWriter::Clear() -{ m_Buffer.clear(); m_Offset = 0; } |