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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
#include <pthread.h>
#include <assert.h>
#include <errno.h>
#include <alloca.h>
#include <string.h>
#include <sys/mman.h>
#include <signal.h>
static void test_detachstate() {
pthread_attr_t attr;
assert(!pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED));
int detachstate;
assert(!pthread_attr_getdetachstate(&attr, &detachstate));
assert(detachstate == PTHREAD_CREATE_DETACHED);
assert(pthread_attr_setdetachstate(&attr, 2* (PTHREAD_CREATE_DETACHED +
PTHREAD_CREATE_JOINABLE)) == EINVAL);
}
static void *stacksize_worker(void *arg) {
size_t default_stacksize = (*(size_t*)arg);
size_t alloc_size = default_stacksize + default_stacksize/2;
void *area = alloca(alloc_size);
// If the allocated stack was not enough this will crash.
*(volatile int*)(area + alloc_size) = 1;
return NULL;
}
static void test_stacksize() {
pthread_attr_t attr;
assert(!pthread_attr_init(&attr));
size_t stacksize;
assert(!pthread_attr_getstacksize(&attr, &stacksize));
assert(!pthread_attr_setstacksize(&attr, stacksize * 2));
pthread_t thread;
assert(!pthread_create(&thread, &attr, stacksize_worker, &stacksize));
assert(!pthread_join(thread, NULL));
}
static void test_guardsize() {
pthread_attr_t attr;
assert(!pthread_attr_init(&attr));
assert(!pthread_attr_setguardsize(&attr, 0));
size_t guardsize;
assert(!pthread_attr_getguardsize(&attr, &guardsize));
assert(!guardsize);
}
static void test_scope() {
pthread_attr_t attr;
assert(!pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM));
int scope;
assert(!pthread_attr_getscope(&attr, &scope));
assert(scope == PTHREAD_SCOPE_SYSTEM);
assert(pthread_attr_setscope(&attr, 2* (PTHREAD_SCOPE_SYSTEM +
PTHREAD_SCOPE_PROCESS)) == EINVAL);
}
static void test_inheritsched() {
pthread_attr_t attr;
assert(!pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED));
int inheritsched;
assert(!pthread_attr_getinheritsched(&attr, &inheritsched));
assert(inheritsched == PTHREAD_INHERIT_SCHED);
assert(pthread_attr_setinheritsched(&attr, 2* (PTHREAD_INHERIT_SCHED +
PTHREAD_EXPLICIT_SCHED)) == EINVAL);
}
static void test_schedparam() {
pthread_attr_t attr;
struct sched_param init_param = {0};
assert(!pthread_attr_setschedparam(&attr, &init_param));
struct sched_param param = {1};
assert(!pthread_attr_getschedparam(&attr, ¶m));
assert(param.sched_priority == init_param.sched_priority);
}
static void test_schedpolicy() {
pthread_attr_t attr;
assert(!pthread_attr_setschedpolicy(&attr, SCHED_FIFO));
int policy;
assert(!pthread_attr_getschedpolicy(&attr, &policy));
assert(policy == SCHED_FIFO);
assert(pthread_attr_setinheritsched(&attr, 2* (SCHED_FIFO + SCHED_RR +
SCHED_OTHER)) == EINVAL);
}
static void *stackaddr_worker(void *arg) {
void *addr = *(void**)arg;
void *sp;
#if defined(__x86_64__)
asm volatile ("mov %%rsp, %0" : "=r"(sp));
#elif defined(__i386__)
asm volatile ("mov %%esp, %0" : "=r"(sp));
#elif defined(__aarch64__)
asm volatile ("mov %0, sp" : "=r"(sp));
#elif defined (__riscv)
asm volatile ("mv %0, sp" : "=r"(sp));
#else
# error Unknown architecture
#endif
// Check if our stack pointer is in a sane range.
assert(sp > addr);
return NULL;
}
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wdeprecated-declarations"
static void test_stackaddr() {
pthread_attr_t attr;
assert(!pthread_attr_init(&attr));
size_t size;
assert(!pthread_attr_getstacksize(&attr, &size));
void *addr = mmap(NULL, size, PROT_READ | PROT_WRITE,
MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);
assert(!pthread_attr_setstack(&attr, addr, size));
assert(!pthread_attr_setguardsize(&attr, 0));
void *new_addr;
size_t new_size;
assert(!pthread_attr_getstack(&attr, &new_addr, &new_size));
assert(new_addr == addr);
assert(new_size == size);
pthread_t thread;
assert(!pthread_create(&thread, &attr, stackaddr_worker, &addr));
assert(!pthread_join(thread, NULL));
}
#pragma GCC diagnostic pop
#if !defined(USE_HOST_LIBC) || (__GLIBC__ == 2 && __GLIBC_MINOR__ >= 32)
static void test_stack() {
pthread_attr_t attr;
void *stackaddr = (void*)1;
size_t stacksize = PTHREAD_STACK_MIN;
assert(!pthread_attr_setstack(&attr, stackaddr, stacksize));
void *new_addr;
size_t new_size;
assert(!pthread_attr_getstack(&attr, &new_addr, &new_size));
assert(new_addr == stackaddr);
assert(new_size == stacksize);
}
#endif
int main() {
test_detachstate();
test_stacksize();
test_guardsize();
test_scope();
test_inheritsched();
test_schedparam();
test_schedpolicy();
test_stackaddr();
#if !defined(USE_HOST_LIBC) || (__GLIBC__ == 2 && __GLIBC_MINOR__ >= 32)
test_stack();
#endif
}
|