summaryrefslogtreecommitdiff
path: root/Source/modules/asura-base/FileSystem/IOTask.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Source/modules/asura-base/FileSystem/IOTask.cpp')
-rw-r--r--Source/modules/asura-base/FileSystem/IOTask.cpp61
1 files changed, 61 insertions, 0 deletions
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);
+ }
+ }
+ }
+
+ }
+}