| /dports/devel/ode/ode-0.13/ode/src/ |
| H A D | objects.cpp | 162 unsigned active_thread_count = RetrieveThreadingThreadCount(); in GetThreadingIslandsMaxThreadsCount() local
165 *out_active_thread_count_ptr = active_thread_count; in GetThreadingIslandsMaxThreadsCount()
169 ? active_thread_count in GetThreadingIslandsMaxThreadsCount()
170 : (islands_max_threads < active_thread_count ? islands_max_threads : active_thread_count); in GetThreadingIslandsMaxThreadsCount()
|
| /dports/devel/grpc130/grpc-1.30.2/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | fork_posix.pyx.pxi | 43 if not _fork_state.active_thread_count.await_zero_threads(
68 _fork_state.active_thread_count = _ActiveThreadCount()
104 _fork_state.active_thread_count.decrement()
114 _fork_state.active_thread_count.increment()
128 _fork_state.active_thread_count.decrement()
130 _fork_state.active_thread_count.increment()
135 _fork_state.active_thread_count.decrement()
140 _fork_state.active_thread_count.increment()
201 self.active_thread_count = _ActiveThreadCount()
|
| /dports/devel/grpc134/grpc-1.34.1/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | fork_posix.pyx.pxi | 43 if not _fork_state.active_thread_count.await_zero_threads(
68 _fork_state.active_thread_count = _ActiveThreadCount()
106 _fork_state.active_thread_count.decrement()
116 _fork_state.active_thread_count.increment()
130 _fork_state.active_thread_count.decrement()
132 _fork_state.active_thread_count.increment()
137 _fork_state.active_thread_count.decrement()
142 _fork_state.active_thread_count.increment()
203 self.active_thread_count = _ActiveThreadCount()
|
| /dports/devel/grpc/grpc-1.42.0/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | fork_posix.pyx.pxi | 43 if not _fork_state.active_thread_count.await_zero_threads(
68 _fork_state.active_thread_count = _ActiveThreadCount()
106 _fork_state.active_thread_count.decrement()
116 _fork_state.active_thread_count.increment()
130 _fork_state.active_thread_count.decrement()
132 _fork_state.active_thread_count.increment()
137 _fork_state.active_thread_count.decrement()
142 _fork_state.active_thread_count.increment()
203 self.active_thread_count = _ActiveThreadCount()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | fork_posix.pyx.pxi | 47 if not _fork_state.active_thread_count.await_zero_threads(
72 _fork_state.active_thread_count = _ActiveThreadCount()
108 _fork_state.active_thread_count.decrement()
118 _fork_state.active_thread_count.increment()
132 _fork_state.active_thread_count.decrement()
134 _fork_state.active_thread_count.increment()
139 _fork_state.active_thread_count.decrement()
144 _fork_state.active_thread_count.increment()
205 self.active_thread_count = _ActiveThreadCount()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | fork_posix.pyx.pxi | 43 if not _fork_state.active_thread_count.await_zero_threads(
68 _fork_state.active_thread_count = _ActiveThreadCount()
106 _fork_state.active_thread_count.decrement()
116 _fork_state.active_thread_count.increment()
130 _fork_state.active_thread_count.decrement()
132 _fork_state.active_thread_count.increment()
137 _fork_state.active_thread_count.decrement()
142 _fork_state.active_thread_count.increment()
203 self.active_thread_count = _ActiveThreadCount()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 148 int active_thread_count; member
419 return (thread_group->active_thread_count in too_many_active_threads()
814 if(thread_group->active_thread_count==0) in listener()
858 thread_group->active_thread_count += count; in add_thread_count()
960 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1162 thread_group->active_thread_count--; in get_event()
1168 thread_group->active_thread_count++; in get_event()
1226 thread_group->active_thread_count--; in get_event()
1236 thread_group->active_thread_count++; in get_event()
1269 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 148 int active_thread_count; member
419 return (thread_group->active_thread_count in too_many_active_threads()
814 if(thread_group->active_thread_count==0) in listener()
858 thread_group->active_thread_count += count; in add_thread_count()
960 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1162 thread_group->active_thread_count--; in get_event()
1168 thread_group->active_thread_count++; in get_event()
1226 thread_group->active_thread_count--; in get_event()
1236 thread_group->active_thread_count++; in get_event()
1269 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 146 int active_thread_count; member
409 return (thread_group->active_thread_count in too_many_active_threads()
812 if(thread_group->active_thread_count==0) in listener()
856 thread_group->active_thread_count += count; in add_thread_count()
958 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1157 thread_group->active_thread_count--; in get_event()
1163 thread_group->active_thread_count++; in get_event()
1221 thread_group->active_thread_count--; in get_event()
1231 thread_group->active_thread_count++; in get_event()
1264 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 146 int active_thread_count; member
409 return (thread_group->active_thread_count in too_many_active_threads()
812 if(thread_group->active_thread_count==0) in listener()
856 thread_group->active_thread_count += count; in add_thread_count()
958 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1157 thread_group->active_thread_count--; in get_event()
1163 thread_group->active_thread_count++; in get_event()
1221 thread_group->active_thread_count--; in get_event()
1231 thread_group->active_thread_count++; in get_event()
1264 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | threadpool_unix.cc | 146 int active_thread_count; member
409 return (thread_group->active_thread_count in too_many_active_threads()
812 if(thread_group->active_thread_count==0) in listener()
856 thread_group->active_thread_count += count; in add_thread_count()
958 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1157 thread_group->active_thread_count--; in get_event()
1163 thread_group->active_thread_count++; in get_event()
1221 thread_group->active_thread_count--; in get_event()
1231 thread_group->active_thread_count++; in get_event()
1264 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | threadpool_unix.cc | 148 int active_thread_count; member
419 return (thread_group->active_thread_count in too_many_active_threads()
814 if(thread_group->active_thread_count==0) in listener()
858 thread_group->active_thread_count += count; in add_thread_count()
960 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1162 thread_group->active_thread_count--; in get_event()
1168 thread_group->active_thread_count++; in get_event()
1226 thread_group->active_thread_count--; in get_event()
1236 thread_group->active_thread_count++; in get_event()
1269 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/graphics/proj/proj-7.2.1/src/tests/ |
| H A D | multistresstest.cpp | 177 static volatile int active_thread_count = 0; variable
303 active_thread_count--; in TestThread()
404 active_thread_count++; in do_main()
430 active_thread_count++; in do_main()
438 while( active_thread_count > 0 ) in do_main()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
| H A D | threadpool_generic.cc | 190 int active_thread_count; in MY_ALIGNED() local
876 if(thread_group->active_thread_count==0) in listener()
920 thread_group->active_thread_count += count; in add_thread_count()
1022 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1183 if (thread_group->active_thread_count == 0) in queue_put()
1249 thread_group->active_thread_count--; in get_event()
1255 thread_group->active_thread_count++; in get_event()
1291 thread_group->active_thread_count--; in get_event()
1301 thread_group->active_thread_count++; in get_event()
1334 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
| H A D | threadpool_generic.cc | 190 int active_thread_count; in MY_ALIGNED() local
876 if(thread_group->active_thread_count==0) in listener()
920 thread_group->active_thread_count += count; in add_thread_count()
1022 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1183 if (thread_group->active_thread_count == 0) in queue_put()
1249 thread_group->active_thread_count--; in get_event()
1255 thread_group->active_thread_count++; in get_event()
1291 thread_group->active_thread_count--; in get_event()
1301 thread_group->active_thread_count++; in get_event()
1334 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/sql/ |
| H A D | threadpool_generic.cc | 190 int active_thread_count; in MY_ALIGNED() local
875 if(thread_group->active_thread_count==0) in listener()
919 thread_group->active_thread_count += count; in add_thread_count()
1021 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1182 if (thread_group->active_thread_count == 0) in queue_put()
1248 thread_group->active_thread_count--; in get_event()
1254 thread_group->active_thread_count++; in get_event()
1290 thread_group->active_thread_count--; in get_event()
1300 thread_group->active_thread_count++; in get_event()
1333 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/sql/ |
| H A D | threadpool_generic.cc | 190 int active_thread_count; in MY_ALIGNED() local
875 if(thread_group->active_thread_count==0) in listener()
919 thread_group->active_thread_count += count; in add_thread_count()
1021 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1182 if (thread_group->active_thread_count == 0) in queue_put()
1248 thread_group->active_thread_count--; in get_event()
1254 thread_group->active_thread_count++; in get_event()
1290 thread_group->active_thread_count--; in get_event()
1300 thread_group->active_thread_count++; in get_event()
1333 thread_group->active_thread_count--; in wait_begin()
[all …]
|
| /dports/graphics/opencv/opencv-4.5.3/modules/core/src/ |
| H A D | parallel_impl.cpp | 295 active_thread_count.store(0, std::memory_order_relaxed); in ParallelJob()
332 …R(NULL, "\t\t\t\tBUG! Job: " << (void*)this << " " << id << " " << active_thread_count << " " << c… in execute()
347 std::atomic<int> active_thread_count; // number of threads worked on this job member in cv::ParallelJob
431 int other = j->active_thread_count.fetch_add(1, std::memory_order_seq_cst); in thread_body()
441 int active = j->active_thread_count.load(std::memory_order_acquire); in thread_body()
641 …CV_LOG_VERBOSE(NULL, 5, "MainThread: complete self-tasks: " << j.active_thread_count << " " << j.c… in run()
642 if (job->is_completed || j.active_thread_count == 0) in run()
655 …OG_VERBOSE(NULL, 5, "MainThread: job finalize (active wait) " << j.active_thread_count << " " << j… in run()
666 …CV_LOG_VERBOSE(NULL, 5, "MainThread: prepare wait " << j.active_thread_count << " " << j.completed… in run()
672 …CV_LOG_VERBOSE(NULL, 5, "MainThread: job finalize (wait) " << j.active_thread_count << " " << j.co… in run()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
| H A D | threadpool_generic.cc | 811 if(thread_group->active_thread_count==0) in listener()
855 thread_group->active_thread_count += count; in add_thread_count()
964 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1131 if (thread_group->active_thread_count == 0) in queue_put()
1199 thread_group->active_thread_count--; in get_event()
1205 thread_group->active_thread_count++; in get_event()
1241 thread_group->active_thread_count--; in get_event()
1251 thread_group->active_thread_count++; in get_event()
1285 thread_group->active_thread_count--; in wait_begin()
1290 if ((thread_group->active_thread_count == 0) && in wait_begin()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | threadpool_generic.cc | 811 if(thread_group->active_thread_count==0) in listener()
855 thread_group->active_thread_count += count; in add_thread_count()
964 if (thread_group->active_thread_count == 0) in wake_or_create_thread()
1131 if (thread_group->active_thread_count == 0) in queue_put()
1199 thread_group->active_thread_count--; in get_event()
1205 thread_group->active_thread_count++; in get_event()
1241 thread_group->active_thread_count--; in get_event()
1251 thread_group->active_thread_count++; in get_event()
1285 thread_group->active_thread_count--; in wait_begin()
1290 if ((thread_group->active_thread_count == 0) && in wait_begin()
[all …]
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/loggen/socket_plugin/ |
| H A D | socket_plugin.c | 62 static gint active_thread_count; variable
112 int num = active_thread_count + idle_thread_count; in get_thread_count()
163 active_thread_count = option->active_connections; in start()
292 while (fd > 0 && thread_run && active_thread_count > 0) in idle_thread_func()
429 active_thread_count--; in active_thread_func()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/loggen/ssl_plugin/ |
| H A D | ssl_plugin.c | 61 static gint active_thread_count; variable
107 int num = active_thread_count + idle_thread_count; in get_thread_count()
150 active_thread_count = option->active_connections; in start()
274 while (thread_run && active_thread_count>0) in idle_thread_func()
444 active_thread_count--; in active_thread_func()
|
| /dports/lang/rust/rustc-1.58.1-src/src/tools/miri/src/ |
| H A D | data_race.rs | 1121 active_thread_count: Cell<usize>, field
1141 active_thread_count: Cell::new(1), in new()
1202 let active_threads = self.active_thread_count.get(); in thread_created()
1203 self.active_thread_count.set(active_threads + 1); in thread_created()
1289 let active_threads = self.active_thread_count.get(); in thread_joined()
1347 let mut active_threads = self.active_thread_count.get(); in thread_terminated()
1349 self.active_thread_count.set(active_threads); in thread_terminated()
|
| /dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_tests/tests/unit/_cython/ |
| H A D | _fork_test.py | 23 return cygrpc._fork_state.active_thread_count._num_active_threads
|
| /dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_tests/tests/unit/_cython/ |
| H A D | _fork_test.py | 23 return cygrpc._fork_state.active_thread_count._num_active_threads
|