summaryrefslogtreecommitdiffstats
blob: 6e3722a8e3174bb5162deeb2c6846b661b67ef97 (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
// Copyright (C) 2007 Anthony Williams
//
//  Distributed under the Boost Software License, Version 1.0. (See accompanying 
//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

#define __STDC_CONSTANT_MACROS
#include <boost/thread/once.hpp>
#include <boost/assert.hpp>
#include <pthread.h>
#include <stdlib.h>

namespace boost
{
    namespace detail
    {
        BOOST_THREAD_DECL boost::uintmax_t once_global_epoch=UINTMAX_C(~0);
        BOOST_THREAD_DECL pthread_mutex_t once_epoch_mutex=PTHREAD_MUTEX_INITIALIZER;
        BOOST_THREAD_DECL pthread_cond_t once_epoch_cv = PTHREAD_COND_INITIALIZER;

        namespace
        {
            pthread_key_t epoch_tss_key;
            pthread_once_t epoch_tss_key_flag=PTHREAD_ONCE_INIT;
            
            extern "C" void delete_epoch_tss_data(void* data)
            {
                free(data);
            }

            extern "C" void create_epoch_tss_key()
            {
                BOOST_VERIFY(!pthread_key_create(&epoch_tss_key,delete_epoch_tss_data));
            }
            
        }
        
        boost::uintmax_t& get_once_per_thread_epoch()
        {
            BOOST_VERIFY(!pthread_once(&epoch_tss_key_flag,create_epoch_tss_key));
            void* data=pthread_getspecific(epoch_tss_key);
            if(!data)
            {
                data=malloc(sizeof(boost::uintmax_t));
                BOOST_VERIFY(!pthread_setspecific(epoch_tss_key,data));
                *static_cast<boost::uintmax_t*>(data)=UINTMAX_C(~0);
            }
            return *static_cast<boost::uintmax_t*>(data);
        }
    }
    
}