| Line |
Branch |
Exec |
Source |
| 1 |
|
|
#pragma once |
| 2 |
|
|
|
| 3 |
|
|
#include <stdint.h> |
| 4 |
|
|
#include <pthread.h> |
| 5 |
|
|
|
| 6 |
|
|
struct function_pointer_wrapper /*have this struct at global level*/ |
| 7 |
|
|
{ |
| 8 |
|
|
static void* (*thread_callback)(void*); |
| 9 |
|
400 |
static void* execute_thread(void* parameter) { return thread_callback(parameter); } |
| 10 |
|
|
}; |
| 11 |
|
|
|
| 12 |
|
|
void* (*function_pointer_wrapper::thread_callback)(void*) = nullptr; |
| 13 |
|
|
|
| 14 |
|
|
template <typename functor> |
| 15 |
|
400 |
bool run_as_thread(functor&& callback) { |
| 16 |
|
|
struct thread_wrapper { |
| 17 |
|
|
functor& callback; |
| 18 |
|
|
bool result; |
| 19 |
|
|
|
| 20 |
|
400 |
void* execute() { |
| 21 |
|
400 |
result = callback(); |
| 22 |
2/2
✓ Branch 0 taken 326 times.
✓ Branch 1 taken 74 times.
|
400 |
if (result) |
| 23 |
|
326 |
pthread_exit(NULL); |
| 24 |
|
|
else |
| 25 |
|
74 |
pthread_exit(reinterpret_cast<void*>((uintptr_t)-1)); |
| 26 |
|
|
} |
| 27 |
|
|
|
| 28 |
|
400 |
} wrapper{ callback, false }; |
| 29 |
|
|
|
| 30 |
|
400 |
function_pointer_wrapper::thread_callback = [](void* parameter) { |
| 31 |
|
400 |
return reinterpret_cast<thread_wrapper*>(parameter)->execute(); |
| 32 |
|
|
}; |
| 33 |
|
|
|
| 34 |
|
|
pthread_attr_t settings; |
| 35 |
|
|
pthread_t thread_id; |
| 36 |
|
|
int ret; |
| 37 |
|
|
|
| 38 |
|
400 |
ret = pthread_attr_init(&settings); |
| 39 |
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 400 times.
|
400 |
if (ret == -1){ |
| 40 |
|
✗ |
return callback(); |
| 41 |
|
|
} |
| 42 |
|
|
|
| 43 |
|
400 |
ret = pthread_attr_setstacksize(&settings, 16 * 1024 * 1024); |
| 44 |
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 400 times.
|
400 |
if (ret == -1){ |
| 45 |
|
✗ |
return callback(); |
| 46 |
|
|
} |
| 47 |
|
|
|
| 48 |
|
400 |
ret = pthread_create(&thread_id, &settings, &function_pointer_wrapper::execute_thread, &wrapper); |
| 49 |
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 400 times.
|
400 |
if (ret == -1){ |
| 50 |
|
✗ |
return callback(); |
| 51 |
|
|
} |
| 52 |
|
|
|
| 53 |
|
|
void* thread_ret; |
| 54 |
1/2
✓ Branch 0 taken 400 times.
✗ Branch 1 not taken.
|
400 |
pthread_join(thread_id, &thread_ret); |
| 55 |
|
|
|
| 56 |
|
400 |
return wrapper.result; |
| 57 |
|
|
} |
| 58 |
|
|
|
| 59 |
|
|
#ifndef NO_USE_THREADS |
| 60 |
|
|
void* stack_bottom = nullptr; |
| 61 |
|
1170 |
void init_stack_use_check() { |
| 62 |
|
1170 |
pthread_t self = pthread_self(); |
| 63 |
|
|
#ifdef __APPLE__ |
| 64 |
|
|
stack_bottom = (char*)pthread_get_stackaddr_np(self) - pthread_get_stacksize_np(self); |
| 65 |
|
|
#else |
| 66 |
|
|
pthread_attr_t attrs; |
| 67 |
|
1170 |
size_t stack_size = 0; |
| 68 |
|
1170 |
pthread_getattr_np(self, &attrs); |
| 69 |
|
1170 |
pthread_attr_getstack(&attrs, &stack_bottom, &stack_size); |
| 70 |
|
1170 |
pthread_attr_destroy(&attrs); |
| 71 |
|
|
#endif |
| 72 |
|
1170 |
} |
| 73 |
|
1155 |
void deinit_stack_use_check() { |
| 74 |
|
1155 |
stack_bottom = nullptr; |
| 75 |
|
1155 |
} |
| 76 |
|
196320 |
bool have_enough_stack_left() { |
| 77 |
|
|
#if defined(__clang__) || defined(__GNUC__) |
| 78 |
|
|
// this is a GCC extension, but it's necessary for this function to work in ASan |
| 79 |
|
|
// (regular local variables are banished to the shadow realm or some shit, |
| 80 |
|
|
// so their addresses don't tell us anything about "real" stack usage) |
| 81 |
|
196320 |
void* stack_top = __builtin_frame_address(0); |
| 82 |
|
|
#else |
| 83 |
|
|
// using a random local as a rough estimate for current top-of-stack |
| 84 |
|
|
char stackvar; |
| 85 |
|
|
void* stack_top = &stackvar; |
| 86 |
|
|
#endif |
| 87 |
|
196320 |
ssize_t stack_left = (char*)stack_top - (char*)stack_bottom; |
| 88 |
4/4
✓ Branch 0 taken 196124 times.
✓ Branch 1 taken 196 times.
✓ Branch 2 taken 196121 times.
✓ Branch 3 taken 3 times.
|
196320 |
return stack_bottom == nullptr || stack_left >= 32768; |
| 89 |
|
|
} |
| 90 |
|
|
#endif |
| 91 |
|
|
|