1 files changed, 102 insertions, 0 deletions
diff --git a/source/modules/asura-utils/io/data_buffer.cpp b/source/modules/asura-utils/io/data_buffer.cpp
new file mode 100644
index 0000000..5049b38
--- /dev/null
+++ b/source/modules/asura-utils/io/data_buffer.cpp
@@ -0,0 +1,102 @@
+#include <cstdlib>
+#include <cstring>
+#include "data_buffer.h"
+
+using namespace AEThreading;
+
+namespace AsuraEngine
+{
+	namespace IO
+	{
+
+		DataBuffer::DataBuffer(DataBuffer& src)
+		{
+			Load(src);
+		}
+
+		DataBuffer::DataBuffer(std::size_t size)
+			: mSize(size)
+			, mBytes(nullptr)
+		{
+			lock(mMutex);
+			mBytes = new byte[size];
+			memset(mBytes, 0, size);
+		}
+
+		DataBuffer::DataBuffer(const void* data, std::size_t size)
+			: mSize(size)
+			, mBytes(nullptr)
+		{
+			Load(data, size);
+		}
+
+		DataBuffer::~DataBuffer()
+		{
+			delete[] mBytes;
+		}
+
+		void DataBuffer::Refactor(size_t size)
+		{
+			lock(mMutex);
+			if (!mBytes || mSize != size)
+			{
+				delete[] mBytes;
+				mBytes = new byte[size];
+				mSize = size;
+			}
+			memset(mBytes, 0, size * sizeof(byte));
+		}
+
+		size_t DataBuffer::Load(DataBuffer& db)
+		{
+			return Load(db.GetData(), db.GetSize());
+		}
+
+		size_t DataBuffer::Load(const void* data, std::size_t size)
+		{
+			lock(mMutex);
+			size_t len = mSize > size ? size : mSize;
+			memcpy(mBytes, data, len);
+			return len;
+		}
+
+		void DataBuffer::Move(void* bytes, std::size_t size)
+		{
+			lock(mMutex);
+			if (!mBytes)
+			{
+				delete[] mBytes;
+			}
+			mBytes = (byte*)bytes;
+			mSize = size;
+		}
+
+		byte* DataBuffer::GetData()
+		{
+			return mBytes;
+		}
+
+		void DataBuffer::Clear()
+		{
+			lock(mMutex);
+			if (mBytes)
+				memset(mBytes, 0, mSize);
+		}
+		
+		std::size_t DataBuffer::GetSize()
+		{
+			return mSize;
+		}
+
+		void DataBuffer::Lock()
+		{
+			mMutex.Lock();
+		}
+
+		void DataBuffer::Unlock()
+		{
+			mMutex.Unlock();
+		}
+
+	}
+}
+\ No newline at end of file