mirror of
https://github.com/kevinbentley/Descent3.git
synced 2025-01-23 12:08:56 +00:00
a4ab78192c
Join the license header with historical comments using a separator so IDEs can correctly parse the initial header. Also use .gitattributes to ensure all files are LF.
152 lines
3.6 KiB
C++
152 lines
3.6 KiB
C++
/*
|
|
* Descent 3
|
|
* Copyright (C) 2024 Parallax Software
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
--- HISTORICAL COMMENTS FOLLOW ---
|
|
|
|
* $Logfile: /DescentIII/Main/win32/wintask.cpp $
|
|
* $Revision: 5 $
|
|
* $Date: 9/14/98 4:02p $
|
|
* $Author: Samir $
|
|
*
|
|
* Task manager
|
|
*
|
|
* $Log: /DescentIII/Main/win32/wintask.cpp $
|
|
*
|
|
* 5 9/14/98 4:02p Samir
|
|
* allow variable lengths of blocking for tasks.
|
|
*
|
|
* 4 8/10/98 5:54p Samir
|
|
* added mutexes.
|
|
*
|
|
* 3 10/22/97 10:57a Samir
|
|
* Made highest priority time critical again.
|
|
*
|
|
* 2 10/17/97 11:37a Samir
|
|
* Changed highest task priority from TIME_CRITICAL to HIGHEST.
|
|
*
|
|
* 2 6/09/97 4:17p Samir
|
|
* RCS check in.
|
|
*
|
|
* $NoKeywords: $
|
|
*/
|
|
|
|
// Allow Full DD system access.
|
|
#include "DDAccess.h"
|
|
|
|
// Library includes
|
|
#include "TaskSystem.h"
|
|
#include "pserror.h"
|
|
|
|
// Standard includes
|
|
#include <windows.h>
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// osTask implementation
|
|
// ---------------------------------------------------------------------------
|
|
|
|
osTask::osTask(unsigned (*func)(void *), tTaskPriority priority, void *parm) {
|
|
int pri;
|
|
|
|
task_os_handle = 0;
|
|
task_os_id = 0;
|
|
|
|
task_os_handle = (unsigned)CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)func, (LPVOID)parm, 0, (LPDWORD)&task_os_id);
|
|
if (task_os_handle == 0) {
|
|
Int3(); // Get Samir.
|
|
}
|
|
|
|
if (priority == TASKPRIORITY_HIGHEST)
|
|
pri = THREAD_PRIORITY_TIME_CRITICAL;
|
|
else if (priority == TASKPRIORITY_NORMAL)
|
|
pri = THREAD_PRIORITY_NORMAL;
|
|
else if (priority == TASKPRIORITY_LOWEST)
|
|
pri = THREAD_PRIORITY_LOWEST;
|
|
|
|
SetThreadPriority((HANDLE)task_os_handle, pri);
|
|
}
|
|
|
|
osTask::~osTask() {
|
|
if (task_os_handle) {
|
|
CloseHandle((HANDLE)task_os_handle);
|
|
}
|
|
}
|
|
|
|
bool osTask::error() const {
|
|
if (!task_os_handle)
|
|
return 1;
|
|
else
|
|
return 0;
|
|
}
|
|
|
|
void osTask::suspend() // suspends task
|
|
{
|
|
if (task_os_handle) {
|
|
SuspendThread((HANDLE)task_os_handle);
|
|
}
|
|
}
|
|
|
|
void osTask::resume() // resumes task
|
|
{
|
|
if (task_os_handle) {
|
|
ResumeThread((HANDLE)task_os_handle);
|
|
}
|
|
}
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// osEvent implementation
|
|
// ---------------------------------------------------------------------------
|
|
osEvent::osEvent(char *name) { event_os_handle = (unsigned)CreateEvent(NULL, TRUE, FALSE, name); }
|
|
|
|
osEvent::~osEvent() {
|
|
if (event_os_handle)
|
|
CloseHandle((HANDLE)event_os_handle);
|
|
}
|
|
|
|
// signal the event so blocking can stop
|
|
void osEvent::signal() {
|
|
if (event_os_handle)
|
|
SetEvent((HANDLE)event_os_handle);
|
|
}
|
|
|
|
// clear the event so blocking can continue
|
|
void osEvent::clear() {
|
|
if (event_os_handle)
|
|
ResetEvent((HANDLE)event_os_handle);
|
|
}
|
|
|
|
// block until signaled
|
|
bool osEvent::block(int timeout) {
|
|
DWORD res;
|
|
|
|
if (event_os_handle) {
|
|
res = WaitForSingleObject((HANDLE)event_os_handle, (timeout == -1) ? INFINITE : timeout);
|
|
if (res == WAIT_OBJECT_0)
|
|
return 1;
|
|
else if (res == WAIT_ABANDONED)
|
|
return 0;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
bool osEvent::error() const {
|
|
if (!event_os_handle)
|
|
return 1;
|
|
else
|
|
return 0;
|
|
}
|