From 0c391fdbce5a079cf03e483eb6174dd47806163d Mon Sep 17 00:00:00 2001
From: chai <chaifix@163.com>
Date: Wed, 7 Aug 2019 21:08:47 +0800
Subject: *misc

---
 Source/modules/asura-base/FileSystem/IOTask.cpp | 61 +++++++++++++++++++++++++
 1 file changed, 61 insertions(+)
 create mode 100644 Source/modules/asura-base/FileSystem/IOTask.cpp

(limited to 'Source/modules/asura-base/FileSystem/IOTask.cpp')

diff --git a/Source/modules/asura-base/FileSystem/IOTask.cpp b/Source/modules/asura-base/FileSystem/IOTask.cpp
new file mode 100644
index 0000000..9152a6e
--- /dev/null
+++ b/Source/modules/asura-base/FileSystem/IOTask.cpp
@@ -0,0 +1,61 @@
+#include "FileManager.h"
+#include "IOTask.h"
+
+#include <iostream>
+
+using namespace AEScripting;
+using namespace Luax;
+
+namespace AsuraEngine
+{
+	namespace FileSystem
+	{
+
+		IOTask::IOTask(const std::string& path, DataBuffer* buffer, IOTaskType type)
+			: m_Path(path)
+			, m_Buffer(buffer)
+		{
+			if (buffer)
+				buffer->Retain();
+		}
+
+		IOTask::~IOTask()
+		{
+			if (m_Buffer)
+			 m_Buffer->Release();
+		}
+
+		bool IOTask::Execute()
+		{
+			File file(m_Path);
+			if (m_Type == IOTASK_TYPE_WRITE)
+			{
+
+			}
+			// 从path读取内容保存在mBuffer中
+			else if (m_Type == IOTASK_TYPE_READ)
+			{
+				if (!m_Buffer)
+					return false; 
+				file.Open(File::FILE_MODE_READ);
+				file.ReadAll(m_Buffer);
+				file.Close();
+			}
+			return true;
+		}
+
+		void IOTask::Invoke(lua_State* invokeThreaad)
+		{
+			if (m_Callback)
+			{
+				LuaxScopedState state(invokeThreaad);
+				if (this->PushLuaxMemberRef(state, m_Callback))
+				{
+					this->PushLuaxMemberRef(state, m_BufferRef);
+					state.Call(1, 0);
+				}
+			}
+		}
+
+	}
+}
-- 
cgit v1.1-26-g67d0