aboutsummaryrefslogtreecommitdiff
path: root/zencore/stream.cpp
diff options
context:
space:
mode:
authorPer Larsson <[email protected]>2022-02-21 14:22:38 +0100
committerPer Larsson <[email protected]>2022-02-21 14:22:38 +0100
commitfd9f9086b3ddd0c38fa87d7e49f6341dacdcc125 (patch)
tree50be00e62f1e0d3a0521d08d5c7f00fe7787e014 /zencore/stream.cpp
parentBasic websocket service and test. (diff)
downloadzen-fd9f9086b3ddd0c38fa87d7e49f6341dacdcc125.tar.xz
zen-fd9f9086b3ddd0c38fa87d7e49f6341dacdcc125.zip
Refactored websocket message.
Diffstat (limited to 'zencore/stream.cpp')
-rw-r--r--zencore/stream.cpp19
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;
}