1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
#ifndef _3DS_PTHREAD_WRAP__
#define _3DS_PTHREAD_WRAP__
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include "3ds_utils.h"
#define CTR_PTHREAD_STACK_SIZE 0x10000
#define FALSE 0
typedef int32_t pthread_t;
typedef int pthread_attr_t;
typedef LightLock pthread_mutex_t;
typedef int pthread_mutexattr_t;
typedef struct {
uint32_t semaphore;
LightLock lock;
uint32_t waiting;
} pthread_cond_t;
typedef int pthread_condattr_t;
static inline int pthread_create(pthread_t *thread,
const pthread_attr_t *attr, void *(*start_routine)(void*), void *arg)
{
int procnum = -2; // use default cpu
bool isNew3DS;
APT_CheckNew3DS(&isNew3DS);
if (isNew3DS)
procnum = 2;
*thread = threadCreate(start_routine, arg, CTR_PTHREAD_STACK_SIZE, 0x25, procnum, FALSE);
return 0;
}
static inline int pthread_join(pthread_t thread, void **retval)
{
(void)retval;
if(threadJoin(thread, INT64_MAX))
return -1;
threadFree(thread);
return 0;
}
static inline void pthread_exit(void *retval)
{
(void)retval;
threadExit(0);
}
static inline int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr) {
LightLock_Init(mutex);
return 0;
}
static inline int pthread_mutex_lock(pthread_mutex_t *mutex) {
LightLock_Lock(mutex);
return 0;
}
static inline int pthread_mutex_unlock(pthread_mutex_t *mutex) {
LightLock_Unlock(mutex);
return 0;
}
static inline int pthread_mutex_destroy(pthread_mutex_t *mutex) {
return 0;
}
static inline int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr) {
if (svcCreateSemaphore(&cond->semaphore, 0, 1))
goto error;
LightLock_Init(&cond->lock);
cond->waiting = 0;
return 0;
error:
svcCloseHandle(cond->semaphore);
return -1;
}
static inline int pthread_cond_signal(pthread_cond_t *cond) {
int32_t count;
LightLock_Lock(&cond->lock);
if (cond->waiting) {
cond->waiting--;
svcReleaseSemaphore(&count, cond->semaphore, 1);
}
LightLock_Unlock(&cond->lock);
return 0;
}
static inline int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *lock) {
LightLock_Lock(&cond->lock);
cond->waiting++;
LightLock_Unlock(lock);
LightLock_Unlock(&cond->lock);
svcWaitSynchronization(cond->semaphore, INT64_MAX);
LightLock_Lock(lock);
return 0;
}
static inline int pthread_cond_destroy(pthread_cond_t *cond) {
svcCloseHandle(cond->semaphore);
return 0;
}
#endif //_3DS_PTHREAD_WRAP__
|
