diff options
Diffstat (limited to 'xfa/src/fwl/src/core/fwl_threadimp.cpp')
| -rw-r--r-- | xfa/src/fwl/src/core/fwl_threadimp.cpp | 158 |
1 files changed, 158 insertions, 0 deletions
diff --git a/xfa/src/fwl/src/core/fwl_threadimp.cpp b/xfa/src/fwl/src/core/fwl_threadimp.cpp new file mode 100644 index 0000000000..66f4144c71 --- /dev/null +++ b/xfa/src/fwl/src/core/fwl_threadimp.cpp @@ -0,0 +1,158 @@ +// Copyright 2014 PDFium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+// Original code copyright 2014 Foxit Software Inc. http://www.foxitsoftware.com
+
+#include "../../../foxitlib.h"
+#include "include/fwl_targetimp.h"
+#include "include/fwl_noteimp.h"
+#include "include/fwl_threadimp.h"
+#include "include/fwl_appimp.h"
+CFWL_ControlThread::~CFWL_ControlThread()
+{
+}
+FWL_ERR CFWL_ControlThread::Run(FWL_HTHREAD hThread)
+{
+ static int count = 0;
+ while (TRUE) {
+ }
+ return FWL_ERR_Succeeded;
+}
+IFWL_Thread * IFWL_Thread::Create()
+{
+ return (IFWL_Thread *) FX_NEW CFWL_Thread;
+}
+CFWL_Thread::CFWL_Thread()
+{
+}
+CFWL_Thread::~CFWL_Thread()
+{
+}
+FWL_ERR CFWL_Thread::Run(FWL_HTHREAD hThread)
+{
+ return FWL_ERR_Succeeded;
+}
+CFWL_ControlThread * CFWL_NoteThread::_assistantThreadHandler = NULL;
+FWL_HTHREAD CFWL_NoteThread::_assistantThread = NULL;
+FX_INT32 CFWL_NoteThread::_refCount = 0;
+IFWL_NoteThread* IFWL_NoteThread::Create()
+{
+ return (IFWL_NoteThread*) FX_NEW CFWL_NoteThread;
+}
+CFWL_NoteThread::CFWL_NoteThread()
+ : m_hThread(NULL)
+{
+ m_pNoteDriver = FX_NEW CFWL_NoteDriver;
+}
+CFWL_NoteThread::~CFWL_NoteThread()
+{
+ if (m_hThread) {
+ FWL_StopThread(m_hThread, 0);
+ }
+ if (m_pNoteDriver) {
+ delete m_pNoteDriver;
+ m_pNoteDriver = NULL;
+ }
+}
+FWL_ERR CFWL_NoteThread::Run(FWL_HTHREAD hThread)
+{
+ _FWL_RETURN_VALUE_IF_FAIL(m_pNoteDriver, FWL_ERR_Indefinite);
+ FWL_ERR result = m_pNoteDriver->Run();
+ return result;
+}
+IFWL_NoteDriver* CFWL_NoteThread::GetNoteDriver()
+{
+ return (IFWL_NoteDriver*)m_pNoteDriver;
+}
+extern IFWL_AdapterNative* FWL_GetAdapterNative();
+FWL_HTHREAD FWL_StartThread(IFWL_Thread *pThread, FX_BOOL bSuspended )
+{
+ IFWL_AdapterNative *pNative = FWL_GetAdapterNative();
+ _FWL_RETURN_VALUE_IF_FAIL(pNative, NULL);
+ IFWL_AdapterThreadMgr *pThreadMgr = pNative->GetThreadMgr();
+ _FWL_RETURN_VALUE_IF_FAIL(pThreadMgr, NULL);
+ FWL_HTHREAD hThread = NULL;
+ pThreadMgr->Start(pThread, hThread, bSuspended);
+ return hThread;
+}
+FWL_ERR FWL_ResumeThread(FWL_HTHREAD hThread)
+{
+ IFWL_AdapterNative * Native = FWL_GetAdapterNative();
+ _FWL_RETURN_VALUE_IF_FAIL(Native, FWL_ERR_Indefinite);
+ IFWL_AdapterThreadMgr * ThreadMgr = Native->GetThreadMgr();
+ _FWL_RETURN_VALUE_IF_FAIL(ThreadMgr, FWL_ERR_Indefinite);
+ return ThreadMgr->Resume(hThread);
+}
+FWL_ERR FWL_SuspendThread(FWL_HTHREAD hThread)
+{
+ IFWL_AdapterNative * Native = FWL_GetAdapterNative();
+ _FWL_RETURN_VALUE_IF_FAIL(Native, FWL_ERR_Indefinite);
+ IFWL_AdapterThreadMgr * ThreadMgr = Native->GetThreadMgr();
+ _FWL_RETURN_VALUE_IF_FAIL(ThreadMgr, FWL_ERR_Indefinite);
+ return ThreadMgr->Suspend(hThread);
+}
+FWL_ERR FWL_KillThread(FWL_HTHREAD hThread, FX_INT32 iExitCode)
+{
+ IFWL_AdapterNative * Native = FWL_GetAdapterNative();
+ _FWL_RETURN_VALUE_IF_FAIL(Native, FWL_ERR_Indefinite);
+ IFWL_AdapterThreadMgr * ThreadMgr = Native->GetThreadMgr();
+ _FWL_RETURN_VALUE_IF_FAIL(ThreadMgr, FWL_ERR_Indefinite);
+ return ThreadMgr->Kill(hThread, iExitCode);
+}
+FWL_ERR FWL_StopThread(FWL_HTHREAD hThread, FX_INT32 iExitCode)
+{
+ IFWL_AdapterNative * Native = FWL_GetAdapterNative();
+ _FWL_RETURN_VALUE_IF_FAIL(Native, FWL_ERR_Indefinite);
+ IFWL_AdapterThreadMgr * ThreadMgr = Native->GetThreadMgr();
+ _FWL_RETURN_VALUE_IF_FAIL(ThreadMgr, FWL_ERR_Indefinite);
+ return ThreadMgr->Stop(hThread, iExitCode);
+}
+FWL_HMUTEX FWL_CreateMutex()
+{
+ return NULL;
+}
+FWL_ERR FWL_DestroyMutex(FWL_HMUTEX hMutex)
+{
+ return FWL_ERR_Succeeded;
+}
+FWL_ERR FWL_LockMutex(FWL_HMUTEX hMutex)
+{
+ return FWL_ERR_Succeeded;
+}
+FWL_ERR FWL_TryLockMutex(FWL_HMUTEX hMutex)
+{
+ return FWL_ERR_Succeeded;
+}
+FWL_ERR FWL_UnlockMutex(FWL_HMUTEX hMutex)
+{
+ return FWL_ERR_Succeeded;
+}
+FWL_ERR FWL_IsLockedMutex(FWL_HMUTEX hMutex, FX_BOOL &bLocked)
+{
+ return FWL_ERR_Succeeded;
+}
+FWL_HSEMAPHORE FWL_CreateSemaphore()
+{
+ return (FWL_HSEMAPHORE) IFWL_AdapterSemaphore::Create();
+}
+FWL_ERR FWL_DestroySemaphore(FWL_HSEMAPHORE hSemaphore)
+{
+ return ((IFWL_AdapterSemaphore*)hSemaphore)->Destroy();
+}
+FWL_ERR FWL_WaitSemaphore(FWL_HSEMAPHORE hSemaphore)
+{
+ return ((IFWL_AdapterSemaphore*)hSemaphore)->Wait();
+}
+FWL_ERR FWL_PostSemaphore(FWL_HSEMAPHORE hSemaphore, FX_INT32 down )
+{
+ return ((IFWL_AdapterSemaphore*)hSemaphore)->Post();
+}
+FWL_ERR FWL_GetSemaphoreValue(FWL_HSEMAPHORE hSemaphore, FX_INT32 &value)
+{
+ return ((IFWL_AdapterSemaphore*)hSemaphore)->Value((FX_DWORD &)value);
+}
+FWL_ERR FWL_ResetSemaphore(FWL_HSEMAPHORE hSemaphore, FX_INT32 init)
+{
+ return ((IFWL_AdapterSemaphore*)hSemaphore)->Reset(init);
+}
|