summaryrefslogtreecommitdiff
path: root/platform/default/thread_local.cpp
blob: 7abbaa01465a85fdc2eb3fb944612e472312ac64 (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
#include <mbgl/util/thread_local.hpp>

#include <mbgl/renderer/backend_scope.hpp>
#include <mbgl/util/logging.hpp>
#include <mbgl/util/run_loop.hpp>

#include <stdexcept>
#include <cassert>

#include <pthread.h>

namespace mbgl {
namespace util {

template <class T>
class ThreadLocal<T>::Impl {
public:
    pthread_key_t key;
};

template <class T>
ThreadLocal<T>::ThreadLocal() : impl(std::make_unique<Impl>()) {
    int ret = pthread_key_create(&impl->key, [](void *) {});

    if (ret) {
        throw std::runtime_error("Failed to init local storage key.");
    }
}

template <class T>
ThreadLocal<T>::~ThreadLocal() {
    // 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(impl->key)) {
        Log::Error(Event::General, "Failed to delete local storage key.");
        assert(false);
    }
}

template <class T>
T* ThreadLocal<T>::get() {
    auto* ret = reinterpret_cast<T*>(pthread_getspecific(impl->key));
    if (!ret) {
        return nullptr;
    }

    return ret;
}

template <class T>
void ThreadLocal<T>::set(T* ptr) {
    if (pthread_setspecific(impl->key, ptr)) {
        throw std::runtime_error("Failed to set local storage.");
    }
}

template class ThreadLocal<RunLoop>;
template class ThreadLocal<BackendScope>;
template class ThreadLocal<int>; // For unit tests

} // namespace util
} // namespace mbgl