mirror of
https://github.com/PCSX2/pcsx2.git
synced 2026-09-21 12:05:47 +02:00
wxgui branch: Maintenance merge against trunk, plus many cleanups and project-level changes.
* Moved the x86 emitter to /common, so that plugins can link against it if they wish. * Created a new "utility" class in /common which houses string utils, fast memcpy, common exception classes, and other handy dandies. * Removed old-style linux automake files from the pcsx2 dir since they were hopelessly out of date (and their multi-file-per-line format makes svn merging impossible >_<) git-svn-id: http://pcsx2.googlecode.com/svn/branches/wxgui@1454 96395faa-99c1-11dd-bbfe-3dabce05a288
This commit is contained in:
@@ -0,0 +1,207 @@
|
||||
/* Pcsx2 - Pc Ps2 Emulator
|
||||
* Copyright (C) 2002-2009 Pcsx2 Team
|
||||
*
|
||||
* 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 2 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, write to the Free Software
|
||||
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA
|
||||
*/
|
||||
|
||||
#include "PrecompiledHeader.h"
|
||||
#include "Threading.h"
|
||||
|
||||
using namespace Threading;
|
||||
|
||||
namespace Threading
|
||||
{
|
||||
Thread::Thread() :
|
||||
m_thread()
|
||||
, m_returncode( 0 )
|
||||
, m_terminated( false )
|
||||
, m_post_event()
|
||||
{
|
||||
}
|
||||
|
||||
Thread::~Thread()
|
||||
{
|
||||
Close();
|
||||
}
|
||||
|
||||
void Thread::Start()
|
||||
{
|
||||
if( pthread_create( &m_thread, NULL, _internal_callback, this ) != 0 )
|
||||
throw Exception::ThreadCreationError();
|
||||
}
|
||||
|
||||
void Thread::Close()
|
||||
{
|
||||
if( m_terminated ) return;
|
||||
pthread_cancel( m_thread );
|
||||
pthread_join( m_thread, NULL );
|
||||
}
|
||||
|
||||
int Thread::GetReturnCode() const
|
||||
{
|
||||
if( !m_terminated )
|
||||
throw std::logic_error( "Thread is still running. No return code is available." );
|
||||
|
||||
return m_returncode;
|
||||
}
|
||||
|
||||
// pthread Cond is an evil api that is not suited for Pcsx2 needs.
|
||||
// Let's not use it. (Air)
|
||||
#if 0
|
||||
WaitEvent::WaitEvent()
|
||||
{
|
||||
int err = 0;
|
||||
|
||||
err = pthread_cond_init(&cond, NULL);
|
||||
err = pthread_mutex_init(&mutex, NULL);
|
||||
}
|
||||
|
||||
WaitEvent::~WaitEvent()
|
||||
{
|
||||
pthread_cond_destroy( &cond );
|
||||
pthread_mutex_destroy( &mutex );
|
||||
}
|
||||
|
||||
void WaitEvent::Set()
|
||||
{
|
||||
pthread_mutex_lock( &mutex );
|
||||
pthread_cond_signal( &cond );
|
||||
pthread_mutex_unlock( &mutex );
|
||||
}
|
||||
|
||||
void WaitEvent::Wait()
|
||||
{
|
||||
pthread_mutex_lock( &mutex );
|
||||
pthread_cond_wait( &cond, &mutex );
|
||||
pthread_mutex_unlock( &mutex );
|
||||
}
|
||||
#endif
|
||||
|
||||
Semaphore::Semaphore()
|
||||
{
|
||||
sem_init( &sema, false, 0 );
|
||||
}
|
||||
|
||||
Semaphore::~Semaphore()
|
||||
{
|
||||
sem_destroy( &sema );
|
||||
}
|
||||
|
||||
void Semaphore::Reset()
|
||||
{
|
||||
sem_destroy( &sema );
|
||||
sem_init( &sema, false, 0 );
|
||||
}
|
||||
|
||||
void Semaphore::Post()
|
||||
{
|
||||
sem_post( &sema );
|
||||
}
|
||||
|
||||
void Semaphore::Post( int multiple )
|
||||
{
|
||||
#if defined(_MSC_VER)
|
||||
sem_post_multiple( &sema, multiple );
|
||||
#endif
|
||||
}
|
||||
|
||||
void Semaphore::Wait()
|
||||
{
|
||||
sem_wait( &sema );
|
||||
}
|
||||
|
||||
int Semaphore::Count()
|
||||
{
|
||||
int retval;
|
||||
sem_getvalue( &sema, &retval );
|
||||
return retval;
|
||||
}
|
||||
|
||||
MutexLock::MutexLock()
|
||||
{
|
||||
int err = 0;
|
||||
err = pthread_mutex_init( &mutex, NULL );
|
||||
}
|
||||
|
||||
MutexLock::~MutexLock()
|
||||
{
|
||||
pthread_mutex_destroy( &mutex );
|
||||
}
|
||||
|
||||
void MutexLock::Lock()
|
||||
{
|
||||
pthread_mutex_lock( &mutex );
|
||||
}
|
||||
|
||||
void MutexLock::Unlock()
|
||||
{
|
||||
pthread_mutex_unlock( &mutex );
|
||||
}
|
||||
|
||||
//////////////////////////////////////////////////////////////////////
|
||||
// define some overloads for InterlockedExchanges
|
||||
// for commonly used types, like u32 and s32.
|
||||
|
||||
__forceinline void AtomicExchange( volatile u32& Target, u32 value )
|
||||
{
|
||||
pcsx2_InterlockedExchange( (volatile long*)&Target, value );
|
||||
}
|
||||
|
||||
__forceinline void AtomicExchangeAdd( volatile u32& Target, u32 value )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, value );
|
||||
}
|
||||
|
||||
__forceinline void AtomicIncrement( volatile u32& Target )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, 1 );
|
||||
}
|
||||
|
||||
__forceinline void AtomicDecrement( volatile u32& Target )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, -1 );
|
||||
}
|
||||
|
||||
__forceinline void AtomicExchange( volatile s32& Target, s32 value )
|
||||
{
|
||||
pcsx2_InterlockedExchange( (volatile long*)&Target, value );
|
||||
}
|
||||
|
||||
__forceinline void AtomicExchangeAdd( s32& Target, u32 value )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, value );
|
||||
}
|
||||
|
||||
__forceinline void AtomicIncrement( volatile s32& Target )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, 1 );
|
||||
}
|
||||
|
||||
__forceinline void AtomicDecrement( volatile s32& Target )
|
||||
{
|
||||
pcsx2_InterlockedExchangeAdd( (volatile long*)&Target, -1 );
|
||||
}
|
||||
|
||||
__forceinline void _AtomicExchangePointer( const void ** target, const void* value )
|
||||
{
|
||||
pcsx2_InterlockedExchange( (volatile long*)target, (long)value );
|
||||
}
|
||||
|
||||
__forceinline void _AtomicCompareExchangePointer( const void ** target, const void* value, const void* comparand )
|
||||
{
|
||||
pcsx2_InterlockedCompareExchange( (volatile long*)target, (long)value, (long)comparand );
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user