| /dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/src/tbb/ |
| H A D | recursive_mutex.cpp | 49 my_mutex = &m; in internal_acquire()
53 __TBB_ASSERT( my_mutex, "recursive_mutex::scoped_lock: not holding a mutex" ); in internal_release()
55 switch( my_mutex->state ) { in internal_release()
57 LeaveCriticalSection( &my_mutex->impl ); in internal_release()
67 int error_code = pthread_mutex_unlock(&my_mutex->impl); in internal_release()
70 my_mutex = NULL; in internal_release()
93 my_mutex = &m; in internal_try_acquire()
|
| /dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/ |
| H A D | recursive_mutex.cpp | 49 my_mutex = &m; in internal_acquire()
53 __TBB_ASSERT( my_mutex, "recursive_mutex::scoped_lock: not holding a mutex" ); in internal_release()
55 switch( my_mutex->state ) { in internal_release()
57 LeaveCriticalSection( &my_mutex->impl ); in internal_release()
67 int error_code = pthread_mutex_unlock(&my_mutex->impl); in internal_release()
70 my_mutex = NULL; in internal_release()
93 my_mutex = &m; in internal_try_acquire()
|
| H A D | task_stream.h | 44 mutex_t my_mutex; member
46 queue_and_mutex () : my_queue(), my_mutex() {} in queue_and_mutex()
105 if( lock.try_acquire(lanes[idx].my_mutex) ) { in push()
122 if( lock.try_acquire(lane.my_mutex) && !lane.my_queue.empty() ) { in pop()
147 spin_mutex::scoped_lock lock(lane.my_mutex); in drain()
|
| /dports/devel/tbb/oneTBB-2020.3/src/tbb/ |
| H A D | recursive_mutex.cpp | 45 my_mutex = &m; in internal_acquire()
49 __TBB_ASSERT( my_mutex, "recursive_mutex::scoped_lock: not holding a mutex" ); in internal_release()
51 switch( my_mutex->state ) { in internal_release()
53 LeaveCriticalSection( &my_mutex->impl ); in internal_release()
63 int error_code = pthread_mutex_unlock(&my_mutex->impl); in internal_release()
66 my_mutex = NULL; in internal_release()
89 my_mutex = &m; in internal_try_acquire()
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/tbb/ |
| H A D | recursive_mutex.cpp | 45 my_mutex = &m; in internal_acquire()
49 __TBB_ASSERT( my_mutex, "recursive_mutex::scoped_lock: not holding a mutex" ); in internal_release()
51 switch( my_mutex->state ) { in internal_release()
53 LeaveCriticalSection( &my_mutex->impl ); in internal_release()
63 int error_code = pthread_mutex_unlock(&my_mutex->impl); in internal_release()
66 my_mutex = NULL; in internal_release()
89 my_mutex = &m; in internal_try_acquire()
|
| /dports/devel/allegro/allegro-4.4.3.1/src/unix/ |
| H A D | uthreads.c | 307 struct my_mutex { struct
320 struct my_mutex *mx; in _unix_create_mutex() argument
322 mx = _AL_MALLOC(sizeof(struct my_mutex)); in _unix_create_mutex()
343 struct my_mutex *mx = (struct my_mutex *)handle; in _unix_destroy_mutex()
357 struct my_mutex *mx = (struct my_mutex *)handle; in _unix_lock_mutex()
374 struct my_mutex *mx = (struct my_mutex *)handle; in _unix_unlock_mutex()
|
| /dports/devel/onetbb/oneTBB-2021.4.0/doc/main/reference/ |
| H A D | custom_mutex_chmap.rst | 91 my_mutex_ptr->my_mutex.lock();
93 my_mutex_ptr->my_mutex.lock_shared();
108 my_mutex_ptr->my_mutex.lock();
110 my_mutex_ptr->my_mutex.lock_shared();
116 my_mutex_ptr->my_mutex.unlock();
118 my_mutex_ptr->my_mutex.unlock_shared();
126 my_mutex_ptr->my_mutex.unlock_shared();
127 my_mutex_ptr->my_mutex.lock();
134 my_mutex_ptr->my_mutex.unlock();
135 my_mutex_ptr->my_mutex.lock_shared();
[all …]
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/ |
| H A D | test_mutex.cpp | 96 mutex_type* my_mutex; member in TBB_MutexFromISO_Mutex::scoped_lock
98 scoped_lock() : my_mutex(NULL) {} in scoped_lock()
107 my_mutex = &m; in acquire()
111 my_mutex = &m; in try_acquire()
119 my_mutex = NULL; in release()
128 my_mutex = &m; in acquire()
132 my_mutex = &m; in try_acquire()
140 my_mutex->my_iso_mutex.lock(); in upgrade_to_writer()
149 if( my_mutex ) in ~scoped_lock()
483 M& my_mutex; member
[all …]
|
| /dports/devel/tbb/oneTBB-2020.3/src/test/ |
| H A D | test_mutex.cpp | 96 mutex_type* my_mutex; member in TBB_MutexFromISO_Mutex::scoped_lock
98 scoped_lock() : my_mutex(NULL) {} in scoped_lock()
107 my_mutex = &m; in acquire()
111 my_mutex = &m; in try_acquire()
119 my_mutex = NULL; in release()
128 my_mutex = &m; in acquire()
132 my_mutex = &m; in try_acquire()
140 my_mutex->my_iso_mutex.lock(); in upgrade_to_writer()
149 if( my_mutex ) in ~scoped_lock()
483 M& my_mutex; member
[all …]
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/ |
| H A D | test_mutex.cpp | 96 mutex_type* my_mutex; member in TBB_MutexFromISO_Mutex::scoped_lock
98 scoped_lock() : my_mutex(NULL) {} in scoped_lock()
107 my_mutex = &m; in acquire()
111 my_mutex = &m; in try_acquire()
119 my_mutex = NULL; in release()
128 my_mutex = &m; in acquire()
132 my_mutex = &m; in try_acquire()
140 my_mutex->my_iso_mutex.lock(); in upgrade_to_writer()
149 if( my_mutex ) in ~scoped_lock()
483 M& my_mutex; member
[all …]
|
| /dports/games/gtkradiant/GPL/Q2Tools/common/ |
| H A D | threads.c | 227 pthread_mutex_t *my_mutex; variable
231 if (my_mutex) in ThreadLock()
232 pthread_mutex_lock (my_mutex); in ThreadLock()
237 if (my_mutex) in ThreadUnlock()
238 pthread_mutex_unlock (my_mutex); in ThreadUnlock()
266 if (!my_mutex) in RunThreadsOn()
268 my_mutex = malloc (sizeof(*my_mutex)); in RunThreadsOn()
273 if (pthread_mutex_init (my_mutex, mattrib) == -1) in RunThreadsOn()
|
| /dports/games/netradiant/netradiant-20150621-src/tools/quake2/extra/common/ |
| H A D | threads.c | 227 pthread_mutex_t *my_mutex; variable
231 if (my_mutex) in ThreadLock()
232 pthread_mutex_lock (my_mutex); in ThreadLock()
237 if (my_mutex) in ThreadUnlock()
238 pthread_mutex_unlock (my_mutex); in ThreadUnlock()
266 if (!my_mutex) in RunThreadsOn()
268 my_mutex = malloc (sizeof(*my_mutex)); in RunThreadsOn()
273 if (pthread_mutex_init (my_mutex, mattrib) == -1) in RunThreadsOn()
|
| /dports/games/zhlt/zhlt-3.4/common/ |
| H A D | threads.cpp | 481 pthread_mutex_t* my_mutex; variable
485 if (my_mutex) in ThreadLock()
487 pthread_mutex_lock(my_mutex); in ThreadLock()
493 if (my_mutex) in ThreadUnlock()
495 pthread_mutex_unlock(my_mutex); in ThreadUnlock()
511 if (!my_mutex) in threads_InitCrit()
513 my_mutex = (pthread_mutex_t*)Alloc(sizeof(*my_mutex)); in threads_InitCrit()
518 if (pthread_mutex_init(my_mutex, &mattrib) == -1) in threads_InitCrit()
527 Free(my_mutex); in threads_UninitCrit()
528 my_mutex = NULL; in threads_UninitCrit()
|
| /dports/cad/basicdsp/basicdsp-1.01/ |
| H A D | mutex.cpp | 10 pthread_mutex_init(&my_mutex, NULL); in Mutex()
19 pthread_mutex_destroy(&my_mutex); in ~Mutex()
28 pthread_mutex_lock(&my_mutex); in Lock()
37 pthread_mutex_unlock(&my_mutex); in Unlock()
|
| /dports/benchmarks/iperf/iperf-2.1.4/src/ |
| H A D | active_hosts.cpp | 94 Mutex_Initialize(&active_table.my_mutex); in Iperf_initialize_active_table()
139 Mutex_Lock(&active_table.my_mutex); in Iperf_push_host()
142 Mutex_Unlock(&active_table.my_mutex); in Iperf_push_host()
151 Mutex_Lock(&active_table.my_mutex); in Iperf_push_host_port_conditional()
156 Mutex_Unlock(&active_table.my_mutex); in Iperf_push_host_port_conditional()
171 Mutex_Lock(&active_table.my_mutex); in Iperf_remove_host()
194 Mutex_Unlock(&active_table.my_mutex); in Iperf_remove_host()
207 Mutex_Destroy(&active_table.my_mutex); in Iperf_destroy_active_table()
|
| /dports/devel/onetbb/oneTBB-2021.4.0/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 164 s.my_mutex = &m; in acquire()
176 ITT_NOTIFY(sync_prepare, s.my_mutex); in acquire()
232 ITT_NOTIFY(sync_acquired, s.my_mutex); in acquire()
263 s.my_mutex = &m; in try_acquire()
264 ITT_NOTIFY(sync_acquired, s.my_mutex); in try_acquire()
272 ITT_NOTIFY(sync_releasing, s.my_mutex); in release()
386 ITT_NOTIFY(sync_releasing, s.my_mutex); in downgrade_to_reader()
390 if( &s==s.my_mutex->q_tail.load() ) { in downgrade_to_reader()
421 ITT_NOTIFY(sync_releasing, s.my_mutex); in upgrade_to_writer()
467 ITT_NOTIFY(sync_prepare, s.my_mutex); in upgrade_to_writer()
[all …]
|
| /dports/devel/allegro/allegro-4.4.3.1/src/beos/ |
| H A D | bsysapi.cpp | 439 struct my_mutex { struct
452 struct my_mutex *mx; in be_sys_create_mutex() argument
454 mx = (struct my_mutex *)malloc(sizeof(struct my_mutex)); in be_sys_create_mutex()
479 struct my_mutex *mx = (struct my_mutex *)handle; in be_sys_destroy_mutex()
493 struct my_mutex *mx = (struct my_mutex *)handle; in be_sys_lock_mutex()
510 struct my_mutex *mx = (struct my_mutex *)handle; in be_sys_unlock_mutex()
|
| /dports/games/quakeforge/quakeforge-0.7.2/tools/qflight/source/ |
| H A D | threads.c | 54 pthread_mutex_t *my_mutex; variable
64 my_mutex = malloc (sizeof (*my_mutex)); in InitThreads()
69 if (pthread_mutex_init (my_mutex, &mattrib) == -1) in InitThreads()
|
| /dports/games/gtkradiant/GPL/GtkRadiant/tools/quake2/qdata_heretic2/common/ |
| H A D | threads.c | 242 pthread_mutex_t *my_mutex; variable
246 if (my_mutex) in ThreadLock()
247 pthread_mutex_lock (my_mutex); in ThreadLock()
252 if (my_mutex) in ThreadUnlock()
253 pthread_mutex_unlock (my_mutex); in ThreadUnlock()
281 if (!my_mutex) in RunThreadsOn()
283 my_mutex = safe_malloc (sizeof(*my_mutex)); in RunThreadsOn()
288 if (pthread_mutex_init (my_mutex, mattrib) == -1) in RunThreadsOn()
|
| /dports/games/gtkradiant/GPL/GtkRadiant/tools/quake3/common/ |
| H A D | threads.c | 242 pthread_mutex_t *my_mutex; variable
246 if (my_mutex) in ThreadLock()
247 pthread_mutex_lock (my_mutex); in ThreadLock()
252 if (my_mutex) in ThreadUnlock()
253 pthread_mutex_unlock (my_mutex); in ThreadUnlock()
281 if (!my_mutex) in RunThreadsOn()
283 my_mutex = safe_malloc (sizeof(*my_mutex)); in RunThreadsOn()
288 if (pthread_mutex_init (my_mutex, mattrib) == -1) in RunThreadsOn()
|
| /dports/games/netradiant/netradiant-20150621-src/tools/quake2/common/ |
| H A D | threads.c | 237 pthread_mutex_t *my_mutex; variable
240 if ( my_mutex ) { in ThreadLock()
241 pthread_mutex_lock( my_mutex ); in ThreadLock()
246 if ( my_mutex ) { in ThreadUnlock()
247 pthread_mutex_unlock( my_mutex ); in ThreadUnlock()
276 if ( !my_mutex ) { in RunThreadsOn()
277 my_mutex = safe_malloc( sizeof( *my_mutex ) ); in RunThreadsOn()
284 if ( pthread_mutex_init( my_mutex, mattrib ) == -1 ) { in RunThreadsOn()
|
| /dports/games/netradiant/netradiant-20150621-src/tools/quake2/qdata_heretic2/common/ |
| H A D | threads.c | 236 pthread_mutex_t *my_mutex; variable
239 if ( my_mutex ) { in ThreadLock()
240 pthread_mutex_lock( my_mutex ); in ThreadLock()
245 if ( my_mutex ) { in ThreadUnlock()
246 pthread_mutex_unlock( my_mutex ); in ThreadUnlock()
275 if ( !my_mutex ) { in RunThreadsOn()
276 my_mutex = safe_malloc( sizeof( *my_mutex ) ); in RunThreadsOn()
283 if ( pthread_mutex_init( my_mutex, mattrib ) == -1 ) { in RunThreadsOn()
|
| /dports/games/gtkradiant/GPL/GtkRadiant/tools/quake2/common/ |
| H A D | threads.c | 243 pthread_mutex_t *my_mutex; variable
247 if (my_mutex) in ThreadLock()
248 pthread_mutex_lock (my_mutex); in ThreadLock()
253 if (my_mutex) in ThreadUnlock()
254 pthread_mutex_unlock (my_mutex); in ThreadUnlock()
282 if (!my_mutex) in RunThreadsOn()
284 my_mutex = safe_malloc (sizeof(*my_mutex)); in RunThreadsOn()
289 if (pthread_mutex_init (my_mutex, mattrib) == -1) in RunThreadsOn()
|
| /dports/games/netradiant/netradiant-20150621-src/tools/quake3/common/ |
| H A D | threads.c | 246 pthread_mutex_t *my_mutex; variable
249 if ( my_mutex ) { in ThreadLock()
250 pthread_mutex_lock( my_mutex ); in ThreadLock()
255 if ( my_mutex ) { in ThreadUnlock()
256 pthread_mutex_unlock( my_mutex ); in ThreadUnlock()
285 if ( !my_mutex ) { in RunThreadsOn()
286 my_mutex = safe_malloc( sizeof( *my_mutex ) ); in RunThreadsOn()
293 if ( pthread_mutex_init( my_mutex, mattrib ) == -1 ) { in RunThreadsOn()
|
| /dports/games/quakeforge/quakeforge-0.7.2/tools/qflight/include/ |
| H A D | threads.h | 34 extern pthread_mutex_t *my_mutex;
35 #define LOCK do { if (options.threads > 1) pthread_mutex_lock (my_mutex); } while (0);
36 #define UNLOCK do { if (options.threads > 1) pthread_mutex_unlock (my_mutex); } while (0);
|