| /third_party/boost/boost/interprocess/sync/spin/ |
| D | recursive_mutex.hpp | 52 namespace ipcdetail { namespace
71 volatile ipcdetail::OS_systemwide_thread_id_t m_nOwner;
76 : m_nLockCount(0), m_nOwner(ipcdetail::get_invalid_systemwide_thread_id()){} in spin_recursive_mutex()
82 typedef ipcdetail::OS_systemwide_thread_id_t handle_t; in lock()
83 const handle_t thr_id(ipcdetail::get_current_systemwide_thread_id()); in lock()
85 ipcdetail::systemwide_thread_id_copy(m_nOwner, old_id); in lock()
86 if(ipcdetail::equal_systemwide_thread_id(thr_id , old_id)){ in lock()
95 ipcdetail::systemwide_thread_id_copy(thr_id, m_nOwner); in lock()
102 typedef ipcdetail::OS_systemwide_thread_id_t handle_t; in try_lock()
103 handle_t thr_id(ipcdetail::get_current_systemwide_thread_id()); in try_lock()
[all …]
|
| D | wait.hpp | 52 namespace ipcdetail { namespace
61 return ipcdetail::get_num_cores(); in get()
73 unsigned int num_core_holder<Dummy>::num_cores = ipcdetail::get_num_cores();
91 << " system tick(us): " << ipcdetail::get_system_tick_us() << std::endl; in ~spin_wait()
122 ipcdetail::thread_yield(); in yield()
125 ipcdetail::thread_sleep_tick(); in yield()
140 unsigned int num_cores = ipcdetail::num_core_holder<0>::get(); in init_limits()
146 m_ul_yield_only_counts = ipcdetail::get_system_tick_in_highres_counts(); in init_tick_info()
147 m_count_start = ipcdetail::get_current_system_highres_count(); in init_tick_info()
157 const ipcdetail::OS_highres_count_t now = ipcdetail::get_current_system_highres_count(); in yield_or_sleep()
[all …]
|
| D | semaphore.hpp | 33 namespace ipcdetail { namespace
59 { ipcdetail::atomic_write32(&this->m_count, boost::uint32_t(initialCount)); } in spin_semaphore()
63 ipcdetail::atomic_inc32(&m_count); in post()
68 ipcdetail::lock_to_wait<spin_semaphore> lw(*this); in wait()
69 return ipcdetail::try_based_lock(lw); in wait()
74 return ipcdetail::atomic_add_unless32(&m_count, boost::uint32_t(-1), boost::uint32_t(0)); in try_wait()
79 ipcdetail::lock_to_wait<spin_semaphore> lw(*this); in timed_wait()
80 return ipcdetail::try_based_timed_lock(lw, abs_time); in timed_wait()
|
| /third_party/boost/libs/interprocess/test/ |
| D | sharable_mutex_test_template.hpp | 43 boost::interprocess::ipcdetail::thread_sleep((1000*3*BaseSeconds)); in plain_exclusive()
54 boost::interprocess::ipcdetail::thread_sleep((1000*pdata->m_secs*BaseSeconds)); in plain_shared()
65 boost::interprocess::ipcdetail::thread_sleep((1000*3*BaseSeconds)); in try_exclusive()
78 boost::interprocess::ipcdetail::thread_sleep((1000*pdata->m_secs*BaseSeconds)); in try_shared()
92 boost::interprocess::ipcdetail::thread_sleep((1000*3*BaseSeconds)); in timed_exclusive()
107 boost::interprocess::ipcdetail::thread_sleep((1000*pdata->m_secs*BaseSeconds)); in timed_shared()
125 boost::interprocess::ipcdetail::OS_thread_t tw1; in test_plain_sharable_mutex()
126 … boost::interprocess::ipcdetail::thread_launch(tw1, thread_adapter<SM>(plain_exclusive, &e1, mtx)); in test_plain_sharable_mutex()
130 boost::interprocess::ipcdetail::thread_sleep((1000*1*BaseSeconds)); in test_plain_sharable_mutex()
131 boost::interprocess::ipcdetail::OS_thread_t tw2; in test_plain_sharable_mutex()
[all …]
|
| D | mutex_test_template.hpp | 173 boost::interprocess::ipcdetail::thread_sleep((1000*pdata->m_secs)); in lock_and_sleep()
176 boost::interprocess::ipcdetail::thread_sleep((1000*2*BaseSeconds)); in lock_and_sleep()
191 boost::interprocess::ipcdetail::thread_sleep((1000*pdata->m_secs)); in lock_and_catch_errors()
194 boost::interprocess::ipcdetail::thread_sleep((1000*2*BaseSeconds)); in lock_and_catch_errors()
211 boost::interprocess::ipcdetail::thread_sleep((1000*2*BaseSeconds)); in try_lock_and_sleep()
225 boost::interprocess::ipcdetail::thread_sleep((1000*2*BaseSeconds)); in timed_lock_and_sleep()
242 boost::interprocess::ipcdetail::OS_thread_t tm1; in test_mutex_lock()
243 boost::interprocess::ipcdetail::thread_launch(tm1, thread_adapter<M>(&lock_and_sleep, &d1, mtx)); in test_mutex_lock()
246 boost::interprocess::ipcdetail::thread_sleep((1000*1*BaseSeconds)); in test_mutex_lock()
249 boost::interprocess::ipcdetail::OS_thread_t tm2; in test_mutex_lock()
[all …]
|
| D | condition_test_template.hpp | 142 boost::interprocess::ipcdetail::OS_thread_t thread; in do_test_condition_notify_one()
143 …boost::interprocess::ipcdetail::thread_launch(thread, bind_function(&condition_test_thread<Conditi… in do_test_condition_notify_one()
145 boost::interprocess::ipcdetail::thread_sleep(1000); in do_test_condition_notify_one()
154 boost::interprocess::ipcdetail::thread_join(thread); in do_test_condition_notify_one()
163 boost::interprocess::ipcdetail::OS_thread_t thgroup[NUMTHREADS]; in do_test_condition_notify_all()
167 …boost::interprocess::ipcdetail::thread_launch(thgroup[i], bind_function(&condition_test_thread<Con… in do_test_condition_notify_all()
171 boost::interprocess::ipcdetail::thread_sleep(1000); in do_test_condition_notify_all()
181 boost::interprocess::ipcdetail::thread_join(thgroup[i]); in do_test_condition_notify_all()
190 boost::interprocess::ipcdetail::OS_thread_t thread; in do_test_condition_waits()
191 …boost::interprocess::ipcdetail::thread_launch(thread, bind_function(&condition_test_waits<Conditio… in do_test_condition_waits()
[all …]
|
| D | windows_shared_dir_func.cpp | 24 namespace ipcdetail { namespace
30 shared_dir = boost::interprocess::ipcdetail::get_temporary_path(); in get_shared_dir()
34 ipcdetail::create_directory(shared_dir.c_str()); in get_shared_dir()
48 ipcdetail::get_shared_dir(shared_dir); in main()
61 … ret = ipcdetail::invalid_file() == ipcdetail::open_existing_file(shm_path.c_str(), read_only) ? in main()
69 ipcdetail::remove_directory(shared_dir.c_str()); in main()
|
| D | recursive_mutex_test.cpp | 25 test::test_all_lock<ipcdetail::windows_recursive_mutex>(); in main()
26 test::test_all_mutex<ipcdetail::windows_recursive_mutex>(); in main()
27 test::test_all_recursive_lock<ipcdetail::windows_recursive_mutex>(); in main()
29 test::test_all_lock<ipcdetail::spin_recursive_mutex>(); in main()
30 test::test_all_mutex<ipcdetail::spin_recursive_mutex>(); in main()
31 test::test_all_recursive_lock<ipcdetail::spin_recursive_mutex>(); in main()
|
| /third_party/boost/boost/interprocess/ |
| D | shared_memory_object.hpp | 72 { this->priv_open_or_create(ipcdetail::DoCreate, name, mode, perm); } in shared_memory_object()
78 { this->priv_open_or_create(ipcdetail::DoOpenOrCreate, name, mode, perm); } in shared_memory_object()
83 { this->priv_open_or_create(ipcdetail::DoOpen, name, mode, permissions()); } in shared_memory_object()
89 : m_handle(file_handle_t(ipcdetail::invalid_file())) in shared_memory_object()
142 …bool priv_open_or_create(ipcdetail::create_enum_t type, const char *filename, mode_t mode, const p…
153 : m_handle(file_handle_t(ipcdetail::invalid_file())) in shared_memory_object()
165 { return ipcdetail::get_file_size((file_handle_t)m_handle, size); } in get_size()
176 return ipcdetail::mapping_handle_from_file_handle(m_handle); in get_mapping_handle()
185 (ipcdetail::create_enum_t type, const char *filename, mode_t mode, const permissions &perm) in priv_open_or_create()
189 ipcdetail::create_shared_dir_cleaning_old_and_get_filepath(filename, shmfile); in priv_open_or_create()
[all …]
|
| D | segment_manager.hpp | 261 (size_type num, bool dothrow, ipcdetail::in_place_interface &table) in prot_anonymous_construct()
263 typedef ipcdetail::block_header<size_type> block_header_t; in prot_anonymous_construct()
284 ipcdetail::mem_algo_deallocator<MemoryAlgorithm> mem(ptr_struct, *this); in prot_anonymous_construct()
292 ipcdetail::array_construct(ptr, num, table); in prot_anonymous_construct()
300 void prot_anonymous_destroy(const void *object, ipcdetail::in_place_interface &table) in prot_anonymous_destroy()
304 typedef ipcdetail::block_header<size_type> block_header_t; in prot_anonymous_destroy()
368 typedef ipcdetail::block_header<size_type> block_header_t;
369 typedef ipcdetail::index_config<CharType, MemoryAlgorithm> index_config_named;
370 typedef ipcdetail::index_config<char, MemoryAlgorithm> index_config_unique;
372 typedef ipcdetail::bool_<is_intrusive_index<index_type>::value > is_intrusive_t;
[all …]
|
| D | managed_mapped_file.hpp | 39 namespace ipcdetail { namespace
44 typedef ipcdetail::managed_open_or_create_impl
61 : public ipcdetail::basic_managed_memory_impl
63 ,ipcdetail::mfile_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset>
68 typedef ipcdetail::basic_managed_memory_impl
70 …ipcdetail::mfile_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset> base_…
71 typedef ipcdetail::file_wrapper device_type;
75 typedef ipcdetail::create_open_func<base_t> create_open_func_t;
101 create_open_func_t(get_this_pointer(), ipcdetail::DoCreate), perm) in basic_managed_mapped_file()
113 ipcdetail::DoOpenOrCreate), perm) in basic_managed_mapped_file()
[all …]
|
| D | managed_shared_memory.hpp | 38 namespace ipcdetail { namespace
43 typedef ipcdetail::managed_open_or_create_impl
59 : public ipcdetail::basic_managed_memory_impl
61 ,ipcdetail::shmem_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset>
62 , private ipcdetail::shmem_open_or_create<AllocationAlgorithm>::type
65 typedef ipcdetail::basic_managed_memory_impl
67 …ipcdetail::shmem_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset> base_…
68 …typedef typename ipcdetail::shmem_open_or_create<AllocationAlgorithm>::type ba…
70 typedef ipcdetail::create_open_func<base_t> create_open_func_t;
106 create_open_func_t(get_this_pointer(), ipcdetail::DoCreate), perm) in basic_managed_shared_memory()
[all …]
|
| D | managed_windows_shared_memory.hpp | 39 namespace ipcdetail { namespace
44 typedef ipcdetail::managed_open_or_create_impl
68 : public ipcdetail::basic_managed_memory_impl
70 , ipcdetail::wshmem_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset>
74 typedef ipcdetail::basic_managed_memory_impl
76 …ipcdetail::wshmem_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset> base…
77 typedef ipcdetail::create_open_func<base_t> create_open_func_t;
101 create_open_func_t(get_this_pointer(), ipcdetail::DoCreate), perm) in basic_managed_windows_shared_memory()
115 ipcdetail::DoOpenOrCreate), perm) in basic_managed_windows_shared_memory()
124 ipcdetail::DoOpen)) in basic_managed_windows_shared_memory()
[all …]
|
| D | offset_ptr.hpp | 55 namespace ipcdetail { namespace
184 static const bool value = ipcdetail::is_cv_same<From, To>::value
185 || ipcdetail::is_cv_same<void, To>::value
186 || ipcdetail::is_cv_same<char, To>::value
240 typedef typename ipcdetail::
242 typedef typename ipcdetail::
243 remove_volatile<typename ipcdetail::
261 : internal(ipcdetail::offset_ptr_to_offset<OffsetType>(ptr, this)) in offset_ptr()
268 …, typename ipcdetail::enable_if< ::boost::is_convertible<T*, PointedType*> >::type * = 0) BOOST_NO… in offset_ptr()
269 : internal(ipcdetail::offset_ptr_to_offset<OffsetType>(static_cast<PointedType*>(ptr), this)) in offset_ptr()
[all …]
|
| D | managed_xsi_shared_memory.hpp | 43 namespace ipcdetail { namespace
48 typedef ipcdetail::managed_open_or_create_impl //!FileBased, StoreDevice
64 : public ipcdetail::basic_managed_memory_impl
66 ,ipcdetail::xsishmem_open_or_create<AllocationAlgorithm>::type::ManagedOpenOrCreateUserOffset>
67 , private ipcdetail::xsishmem_open_or_create<AllocationAlgorithm>::type
74 typedef typename ipcdetail::xsishmem_open_or_create<AllocationAlgorithm>::type base2_t;
75 typedef ipcdetail::basic_managed_memory_impl
79 typedef ipcdetail::create_open_func<base_t> create_open_func_t;
112 create_open_func_t(get_this_pointer(), ipcdetail::DoCreate), perm) in basic_managed_xsi_shared_memory()
125 ipcdetail::DoOpenOrCreate), perm) in basic_managed_xsi_shared_memory()
[all …]
|
| D | file_mapping.hpp | 67 : m_handle(file_handle_t(ipcdetail::invalid_file())) in file_mapping()
118 : m_handle(file_handle_t(ipcdetail::invalid_file())) in file_mapping()
136 { return ipcdetail::mapping_handle_from_file_handle(m_handle); } in get_mapping_handle()
152 m_handle = ipcdetail::open_existing_file(filename, mode); in file_mapping()
155 if(m_handle == ipcdetail::invalid_file()){ in file_mapping()
164 { return ipcdetail::delete_file(filename); } in remove()
170 if(m_handle != ipcdetail::invalid_file()){ in priv_close()
171 ipcdetail::close_file(m_handle); in priv_close()
172 m_handle = ipcdetail::invalid_file(); in priv_close()
189 { ipcdetail::delete_file(m_name); } in ~remove_file_on_destroy()
|
| D | xsi_shared_memory.hpp | 83 { this->priv_open_or_create(ipcdetail::DoCreate, key, perm, size); } in xsi_shared_memory()
88 { this->priv_open_or_create(ipcdetail::DoOpenOrCreate, key, perm, size); } in xsi_shared_memory()
93 { this->priv_open_or_create(ipcdetail::DoOpen, key, permissions(), 0); } in xsi_shared_memory()
136 bool priv_open_or_create( ipcdetail::create_enum_t type
165 …(ipcdetail::create_enum_t type, const xsi_key &key, const permissions& permissions, std::size_t si… in priv_open_or_create()
172 case ipcdetail::DoOpen: in priv_open_or_create()
175 case ipcdetail::DoCreate: in priv_open_or_create()
178 case ipcdetail::DoOpenOrCreate: in priv_open_or_create()
190 if((type == ipcdetail::DoOpen) && (-1 != ret)){ in priv_open_or_create()
|
| /third_party/boost/boost/interprocess/sync/ |
| D | file_lock.hpp | 55 : m_file_hnd(file_handle_t(ipcdetail::invalid_file())) in file_lock()
66 : m_file_hnd(file_handle_t(ipcdetail::invalid_file())) in file_lock()
155 m_file_hnd = ipcdetail::open_existing_file(name, read_write); in file_lock()
157 if(m_file_hnd == ipcdetail::invalid_file()){ in file_lock()
165 if(m_file_hnd != ipcdetail::invalid_file()){ in ~file_lock()
166 ipcdetail::close_file(m_file_hnd); in ~file_lock()
167 m_file_hnd = ipcdetail::invalid_file(); in ~file_lock()
173 if(!ipcdetail::acquire_file_lock(m_file_hnd)){ in lock()
182 if(!ipcdetail::try_acquire_file_lock(m_file_hnd, result)){ in try_lock()
190 { return ipcdetail::try_based_timed_lock(*this, abs_time); } in timed_lock()
[all …]
|
| D | named_condition.hpp | 44 namespace ipcdetail{ class interprocess_tester; } namespace
124 typedef ipcdetail::windows_named_condition condition_type;
126 typedef ipcdetail::shm_named_condition condition_type;
130 friend class ipcdetail::interprocess_tester;
132 { ipcdetail::interprocess_tester::dont_close_on_destruction(m_cond); } in dont_close_on_destruction()
162 ipcdetail::internal_mutex_lock<L> internal_lock(lock); in wait()
169 ipcdetail::internal_mutex_lock<L> internal_lock(lock); in wait()
177 ipcdetail::internal_mutex_lock<L> internal_lock(lock); in timed_wait()
185 ipcdetail::internal_mutex_lock<L> internal_lock(lock); in timed_wait()
|
| /third_party/boost/boost/interprocess/smart_ptr/ |
| D | shared_ptr.hpp | 54 namespace ipcdetail{ namespace
109 typedef typename ipcdetail::add_reference
111 typedef typename ipcdetail::add_reference
141 BOOST_STATIC_ASSERT((ipcdetail::is_same<pointer, ParameterPointer>::value) || in shared_ptr()
142 (ipcdetail::is_pointer<pointer>::value)); in shared_ptr()
143 …ipcdetail::sp_enable_shared_from_this<T, VoidAllocator, Deleter>( m_pn, ipcdetail::to_raw_pointer(… in shared_ptr()
182 shared_ptr(shared_ptr<Y, VoidAllocator, Deleter> const & r, ipcdetail::static_cast_tag) in shared_ptr()
183 : m_pn( pointer(static_cast<T*>(ipcdetail::to_raw_pointer(r.m_pn.to_raw_pointer()))) in shared_ptr()
188 shared_ptr(shared_ptr<Y, VoidAllocator, Deleter> const & r, ipcdetail::const_cast_tag) in shared_ptr()
189 : m_pn( pointer(const_cast<T*>(ipcdetail::to_raw_pointer(r.m_pn.to_raw_pointer()))) in shared_ptr()
[all …]
|
| /third_party/boost/boost/interprocess/detail/ |
| D | file_wrapper.hpp | 32 namespace ipcdetail{ namespace
48 { this->priv_open_or_create(ipcdetail::DoCreate, name, mode, perm); } in file_wrapper()
54 { this->priv_open_or_create(ipcdetail::DoOpenOrCreate, name, mode, perm); } in file_wrapper()
59 { this->priv_open_or_create(ipcdetail::DoOpen, name, mode, permissions()); } in file_wrapper()
65 : m_handle(file_handle_t(ipcdetail::invalid_file())) in file_wrapper()
113 …bool priv_open_or_create(ipcdetail::create_enum_t type, const char *filename, mode_t mode, const p…
121 : m_handle(file_handle_t(ipcdetail::invalid_file())) in file_wrapper()
148 (ipcdetail::create_enum_t type, in priv_open_or_create()
162 case ipcdetail::DoOpen: in priv_open_or_create()
165 case ipcdetail::DoCreate: in priv_open_or_create()
[all …]
|
| /third_party/boost/boost/interprocess/allocators/ |
| D | node_allocator.hpp | 48 namespace ipcdetail{ namespace
75 typedef ipcdetail::shared_node_pool
94 typedef typename ipcdetail::add_reference
96 typedef typename ipcdetail::add_reference
129 … : mp_node_pool(ipcdetail::get_or_create_node_pool<typename node_pool<0>::type>(segment_mngr)) { } in node_allocator_base()
136 node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_pool))->inc_ref_count(); in node_allocator_base()
145 …: mp_node_pool(ipcdetail::get_or_create_node_pool<typename node_pool<0>::type>(other.get_segment_m… in node_allocator_base()
158 …{ ipcdetail::destroy_node_pool_if_last_link(node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_p… in ~node_allocator_base()
163 { return ipcdetail::to_raw_pointer(mp_node_pool); } in get_node_pool()
168 { return node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_pool))->get_segment_manager(); } in get_segment_manager()
[all …]
|
| D | cached_node_allocator.hpp | 43 namespace ipcdetail { namespace
50 : public ipcdetail::cached_allocator_impl
52 , ipcdetail::shared_node_pool
60 typedef ipcdetail::cached_allocator_impl
62 , ipcdetail::shared_node_pool
101 : public ipcdetail::cached_allocator_impl
103 , ipcdetail::shared_node_pool
114 typedef ipcdetail::cached_allocator_impl
116 , ipcdetail::shared_node_pool
151 typedef typename ipcdetail::add_reference
[all …]
|
| D | adaptive_pool.hpp | 49 namespace ipcdetail{ namespace
78 typedef ipcdetail::shared_adaptive_node_pool
97 typedef typename ipcdetail::add_reference
99 typedef typename ipcdetail::add_reference
130 … : mp_node_pool(ipcdetail::get_or_create_node_pool<typename node_pool<0>::type>(segment_mngr)) { } in adaptive_pool_base()
137 node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_pool))->inc_ref_count(); in adaptive_pool_base()
154 …: mp_node_pool(ipcdetail::get_or_create_node_pool<typename node_pool<0>::type>(other.get_segment_m… in adaptive_pool_base()
159 …{ ipcdetail::destroy_node_pool_if_last_link(node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_p… in ~adaptive_pool_base()
164 { return ipcdetail::to_raw_pointer(mp_node_pool); } in get_node_pool()
169 { return node_pool<0>::get(ipcdetail::to_raw_pointer(mp_node_pool))->get_segment_manager(); } in get_segment_manager()
[all …]
|
| /third_party/boost/boost/interprocess/sync/shm/ |
| D | named_mutex.hpp | 40 namespace ipcdetail { namespace
112 friend class ipcdetail::interprocess_tester;
114 …typedef ipcdetail::managed_open_or_create_impl<shared_memory_object, 0, true, false> open_create_i…
116 typedef ipcdetail::named_creation_functor<interprocess_mutex> construct_func_t;
123 { ipcdetail::interprocess_tester::dont_close_on_destruction(m_shmem); } in dont_close_on_destruction()
135 ,construct_func_t(ipcdetail::DoCreate) in shm_named_mutex()
146 ,construct_func_t(ipcdetail::DoOpenOrCreate) in shm_named_mutex()
155 ,construct_func_t(ipcdetail::DoOpen)) in shm_named_mutex()
|