blob: 159a8e8e17af1f45006a6964fa605da6164f3678 (
plain)
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
|
#include <mbgl/util/thread_local.hpp>
#include <mbgl/util/logging.hpp>
#include <cassert>
#include <cstdlib>
#include <pthread.h>
#ifdef MB_COMPILER_CXX_THREAD_LOCAL
#include <unordered_map>
#endif
namespace mbgl {
namespace util {
namespace impl {
#ifdef MB_COMPILER_CXX_THREAD_LOCAL
namespace {
thread_local std::unordered_map<void*, void*> mapOfPointers;
}
#endif
ThreadLocalBase::ThreadLocalBase() {
#ifndef MB_COMPILER_CXX_THREAD_LOCAL
static_assert(sizeof(storage) >= sizeof(pthread_key_t), "storage is too small");
static_assert(alignof(decltype(storage)) % alignof(pthread_key_t) == 0, "storage is incorrectly aligned");
if (pthread_key_create(&reinterpret_cast<pthread_key_t&>(storage), nullptr) != 0) {
Log::Error(Event::General, "Failed to initialize thread-specific storage key");
abort();
}
#endif
}
ThreadLocalBase::~ThreadLocalBase() {
#ifndef MB_COMPILER_CXX_THREAD_LOCAL
// ThreadLocal will not take ownership of the pointer it is managing. The pointer
// needs to be explicitly cleared before we destroy this object.
assert(!get());
if (pthread_key_delete(reinterpret_cast<pthread_key_t&>(storage)) != 0) {
Log::Error(Event::General, "Failed to delete thread-specific storage key");
abort();
}
#endif
}
void* ThreadLocalBase::get() {
#ifdef MB_COMPILER_CXX_THREAD_LOCAL
return mapOfPointers[this];
#else
return pthread_getspecific(reinterpret_cast<pthread_key_t&>(storage));
#endif
}
void ThreadLocalBase::set(void* ptr) {
#ifdef MB_COMPILER_CXX_THREAD_LOCAL
mapOfPointers[this] = ptr;
#else
if (pthread_setspecific(reinterpret_cast<pthread_key_t&>(storage), ptr) != 0) {
Log::Error(Event::General, "Failed to set thread-specific storage");
abort();
}
#endif
}
} // namespace impl
} // namespace util
} // namespace mbgl
|
