boost/interprocess/detail/os_thread_functions.hpp

   1 //////////////////////////////////////////////////////////////////////////////
   2 //
   3 // (C) Copyright Ion Gaztanaga 2005-2008. Distributed under the Boost
   4 // Software License, Version 1.0. (See accompanying file
   5 // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
   6 //
   7 // See http://www.boost.org/libs/interprocess for documentation.
   8 //
   9 //////////////////////////////////////////////////////////////////////////////
  10
  11 #ifndef BOOST_INTERPROCESS_DETAIL_OS_THREAD_FUNCTIONS_HPP
  12 #define BOOST_INTERPROCESS_DETAIL_OS_THREAD_FUNCTIONS_HPP
  13
  14 #include <boost/interprocess/detail/config_begin.hpp>
  15 #include <boost/interprocess/detail/workaround.hpp>
  16
  17 #if (defined BOOST_INTERPROCESS_WINDOWS)
  18 #  include <boost/interprocess/detail/win32_api.hpp>
  19 #else
  20 #  ifdef BOOST_HAS_UNISTD_H
  21 #     include <pthread.h>
  22 #     include <unistd.h>
  23 #     include <sched.h>
  24 #  else
  25 #     error Unknown platform
  26 #  endif
  27 #endif
  28
  29 namespace boost {
  30 namespace interprocess {
  31 namespace detail{
  32
  33 #if (defined BOOST_INTERPROCESS_WINDOWS)
  34
  35 typedef unsigned long OS_process_id_t;
  36 typedef unsigned long OS_thread_id_t;
  37 typedef OS_thread_id_t OS_systemwide_thread_id_t;
  38
  39 //process
  40 inline OS_process_id_t get_current_process_id()
  41 {  return winapi::get_current_process_id();  }
  42
  43 inline OS_process_id_t get_invalid_process_id()
  44 {  return OS_process_id_t(0);  }
  45
  46 //thread
  47 inline OS_thread_id_t get_current_thread_id()
  48 {  return winapi::get_current_thread_id();  }
  49
  50 inline OS_thread_id_t get_invalid_thread_id()
  51 {  return OS_thread_id_t(0xffffffff);  }
  52
  53 inline bool equal_thread_id(OS_thread_id_t id1, OS_thread_id_t id2)
  54 {  return id1 == id2;  }
  55
  56 inline void thread_yield()
  57 {  winapi::sched_yield();  }
  58
  59 //systemwide thread
  60 inline OS_systemwide_thread_id_t get_current_systemwide_thread_id()
  61 {
  62    return get_current_thread_id();
  63 }
  64
  65 inline void systemwide_thread_id_copy
  66    (const volatile OS_systemwide_thread_id_t &from, volatile OS_systemwide_thread_id_t &to)
  67 {
  68    to = from;
  69 }
  70
  71 inline bool equal_systemwide_thread_id(const OS_systemwide_thread_id_t &id1, const OS_systemwide_thread_id_t &id2)
  72 {
  73    return equal_thread_id(id1, id2);
  74 }
  75
  76 inline OS_systemwide_thread_id_t get_invalid_systemwide_thread_id()
  77 {
  78    return get_invalid_thread_id();
  79 }
  80
  81 #else    //#if (defined BOOST_INTERPROCESS_WINDOWS)
  82
  83 typedef pthread_t OS_thread_id_t;
  84 typedef pid_t     OS_process_id_t;
  85
  86 struct OS_systemwide_thread_id_t
  87 {
  88    OS_systemwide_thread_id_t()
  89       :  pid(), tid()
  90    {}
  91
  92    OS_systemwide_thread_id_t(pid_t p, pthread_t t)
  93       :  pid(p), tid(t)
  94    {}
  95
  96    OS_systemwide_thread_id_t(const OS_systemwide_thread_id_t &x)
  97       :  pid(x.pid), tid(x.tid)
  98    {}
  99
 100    OS_systemwide_thread_id_t(const volatile OS_systemwide_thread_id_t &x)
 101       :  pid(x.pid), tid(x.tid)
 102    {}
 103
 104    OS_systemwide_thread_id_t & operator=(const OS_systemwide_thread_id_t &x)
 105    {  pid = x.pid;   tid = x.tid;   return *this;   }
 106
 107    OS_systemwide_thread_id_t & operator=(const volatile OS_systemwide_thread_id_t &x)
 108    {  pid = x.pid;   tid = x.tid;   return *this;  }
 109
 110    void operator=(const OS_systemwide_thread_id_t &x) volatile
 111    {  pid = x.pid;   tid = x.tid;   }
 112
 113    pid_t       pid;
 114    pthread_t   tid;
 115 };
 116
 117 inline void systemwide_thread_id_copy
 118    (const volatile OS_systemwide_thread_id_t &from, volatile OS_systemwide_thread_id_t &to)
 119 {
 120    to.pid = from.pid;
 121    to.tid = from.tid;
 122 }
 123
 124 //process
 125 inline OS_process_id_t get_current_process_id()
 126 {  return ::getpid();  }
 127
 128 inline OS_process_id_t get_invalid_process_id()
 129 {  return pid_t(0);  }
 130
 131 //thread
 132 inline OS_thread_id_t get_current_thread_id()
 133 {  return ::pthread_self();  }
 134
 135 inline OS_thread_id_t get_invalid_thread_id()
 136 {
 137    static pthread_t invalid_id;
 138    return invalid_id;
 139 }
 140
 141 inline bool equal_thread_id(OS_thread_id_t id1, OS_thread_id_t id2)
 142 {  return 0 != ::pthread_equal(id1, id2);  }
 143
 144 inline void thread_yield()
 145 {  ::sched_yield();  }
 146
 147 //systemwide thread
 148 inline OS_systemwide_thread_id_t get_current_systemwide_thread_id()
 149 {
 150    return OS_systemwide_thread_id_t(::getpid(), ::pthread_self());
 151 }
 152
 153 inline bool equal_systemwide_thread_id(const OS_systemwide_thread_id_t &id1, const OS_systemwide_thread_id_t &id2)
 154 {
 155    return (0 != ::pthread_equal(id1.tid, id2.tid)) && (id1.pid == id2.pid);
 156 }
 157
 158 inline OS_systemwide_thread_id_t get_invalid_systemwide_thread_id()
 159 {
 160    return OS_systemwide_thread_id_t(get_invalid_process_id(), get_invalid_thread_id());
 161 }
 162
 163 #endif   //#if (defined BOOST_INTERPROCESS_WINDOWS)
 164
 165 }  //namespace detail{
 166 }  //namespace interprocess {
 167 }  //namespace boost {
 168
 169 #include <boost/interprocess/detail/config_end.hpp>
 170
 171 #endif   //BOOST_INTERPROCESS_DETAIL_OS_THREAD_FUNCTIONS_HPP