| /* |
| Simple DirectMedia Layer |
| Copyright (C) 1997-2022 Sam Lantinga <slouken@libsdl.org> |
| |
| This software is provided 'as-is', without any express or implied |
| warranty. In no event will the authors be held liable for any damages |
| arising from the use of this software. |
| |
| Permission is granted to anyone to use this software for any purpose, |
| including commercial applications, and to alter it and redistribute it |
| freely, subject to the following restrictions: |
| |
| 1. The origin of this software must not be misrepresented; you must not |
| claim that you wrote the original software. If you use this software |
| in a product, an acknowledgment in the product documentation would be |
| appreciated but is not required. |
| 2. Altered source versions must be plainly marked as such, and must not be |
| misrepresented as being the original software. |
| 3. This notice may not be removed or altered from any source distribution. |
| */ |
| #include "../../SDL_internal.h" |
| |
| /* An implementation of semaphores using the Symbian API. */ |
| |
| #include <e32std.h> |
| |
| #include "SDL_error.h" |
| #include "SDL_thread.h" |
| |
| #define SDL_MUTEX_TIMEOUT -2 |
| |
| struct SDL_semaphore |
| { |
| TInt handle; |
| TInt count; |
| }; |
| |
| struct TInfo |
| { |
| TInfo(TInt aTime, TInt aHandle) : |
| iTime(aTime), iHandle(aHandle), iVal(0) {} |
| TInt iTime; |
| TInt iHandle; |
| TInt iVal; |
| }; |
| |
| extern TInt CreateUnique(TInt (*aFunc)(const TDesC& aName, TAny*, TAny*), TAny*, TAny*); |
| |
| static TBool RunThread(TAny* aInfo) |
| { |
| TInfo* info = STATIC_CAST(TInfo*, aInfo); |
| User::After(info->iTime); |
| RSemaphore sema; |
| sema.SetHandle(info->iHandle); |
| sema.Signal(); |
| info->iVal = SDL_MUTEX_TIMEOUT; |
| return 0; |
| } |
| |
| static TInt |
| NewThread(const TDesC& aName, TAny* aPtr1, TAny* aPtr2) |
| { |
| return ((RThread*)(aPtr1))->Create |
| (aName, |
| RunThread, |
| KDefaultStackSize, |
| NULL, |
| aPtr2); |
| } |
| |
| static TInt NewSema(const TDesC& aName, TAny* aPtr1, TAny* aPtr2) |
| { |
| TInt value = *((TInt*) aPtr2); |
| return ((RSemaphore*)aPtr1)->CreateGlobal(aName, value); |
| } |
| |
| static void WaitAll(SDL_sem *sem) |
| { |
| RSemaphore sema; |
| sema.SetHandle(sem->handle); |
| sema.Wait(); |
| while(sem->count < 0) |
| { |
| sema.Wait(); |
| } |
| } |
| |
| SDL_sem * |
| SDL_CreateSemaphore(Uint32 initial_value) |
| { |
| RSemaphore s; |
| TInt status = CreateUnique(NewSema, &s, &initial_value); |
| if(status != KErrNone) |
| { |
| SDL_SetError("Couldn't create semaphore"); |
| } |
| SDL_semaphore* sem = new /*(ELeave)*/ SDL_semaphore; |
| sem->handle = s.Handle(); |
| sem->count = initial_value; |
| return(sem); |
| } |
| |
| void |
| SDL_DestroySemaphore(SDL_sem * sem) |
| { |
| if (sem) |
| { |
| RSemaphore sema; |
| sema.SetHandle(sem->handle); |
| sema.Signal(sema.Count()); |
| sema.Close(); |
| delete sem; |
| sem = NULL; |
| } |
| } |
| |
| int |
| SDL_SemWaitTimeout(SDL_sem * sem, Uint32 timeout) |
| { |
| if (! sem) |
| { |
| SDL_SetError("Passed a NULL sem"); |
| return -1; |
| } |
| |
| if (timeout == SDL_MUTEX_MAXWAIT) |
| { |
| WaitAll(sem); |
| return SDL_MUTEX_MAXWAIT; |
| } |
| |
| RThread thread; |
| TInfo* info = new (ELeave)TInfo(timeout, sem->handle); |
| TInt status = CreateUnique(NewThread, &thread, info); |
| |
| if(status != KErrNone) |
| { |
| return status; |
| } |
| |
| thread.Resume(); |
| WaitAll(sem); |
| |
| if(thread.ExitType() == EExitPending) |
| { |
| thread.Kill(SDL_MUTEX_TIMEOUT); |
| } |
| |
| thread.Close(); |
| return info->iVal; |
| } |
| |
| int |
| SDL_SemTryWait(SDL_sem *sem) |
| { |
| if(sem->count > 0) |
| { |
| sem->count--; |
| } |
| return SDL_MUTEX_TIMEOUT; |
| } |
| |
| int |
| SDL_SemWait(SDL_sem * sem) |
| { |
| return SDL_SemWaitTimeout(sem, SDL_MUTEX_MAXWAIT); |
| } |
| |
| Uint32 |
| SDL_SemValue(SDL_sem * sem) |
| { |
| if (! sem) |
| { |
| SDL_SetError("Passed a NULL sem."); |
| return 0; |
| } |
| return sem->count; |
| } |
| |
| int |
| SDL_SemPost(SDL_sem * sem) |
| { |
| if (! sem) |
| { |
| SDL_SetError("Passed a NULL sem."); |
| return -1; |
| } |
| sem->count++; |
| RSemaphore sema; |
| sema.SetHandle(sem->handle); |
| sema.Signal(); |
| return 0; |
| } |
| |
| /* vi: set ts=4 sw=4 expandtab: */ |