| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/job_submit/throttle/ |
| H A D | job_submit_throttle.c | 84 uint32_t job_count; member
121 orig_count = thru_put_array[i].job_count; in _reset_counters()
122 if (thru_put_array[i].job_count <= 10) { in _reset_counters()
123 if (thru_put_array[i].job_count > delta_t) in _reset_counters()
124 thru_put_array[i].job_count -= delta_t; in _reset_counters()
126 thru_put_array[i].job_count = 0; in _reset_counters()
128 thru_put_array[i].job_count = 0; in _reset_counters()
130 thru_put_array[i].job_count *= (delta_t - 1); in _reset_counters()
131 thru_put_array[i].job_count /= delta_t; in _reset_counters()
135 thru_put_array[i].job_count); in _reset_counters()
[all …]
|
| /dports/editors/calligraplan/calligraplan-3.3.0/src/plugins/schedulers/rcps/3rdparty/LibRCPS/src/ |
| H A D | ops.c | 16 q = rand() % problem->job_count; in sched_crossover()
28 for (i = 0; i < problem->job_count; i++) { in sched_crossover()
56 q1 = irand(problem->job_count); in sched_crossover2()
57 q2 = irand(problem->job_count-1); in sched_crossover2()
67 assert(q2 < problem->job_count); in sched_crossover2()
84 if (j < problem->job_count) { in sched_crossover2()
89 for (; i < problem->job_count; i++) { in sched_crossover2()
94 if (j < problem->job_count) { in sched_crossover2()
110 if (j < problem->job_count) { in sched_crossover2()
115 for (; i < problem->job_count; i++) { in sched_crossover2()
[all …]
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/testsuite/expect/ |
| H A D | test9.8 | 93 set job_count 0
95 wait_for -timeout $delay {$job_count >= $job_cnt} {
96 set job_count [
103 …log_warn "Not all jobs were started ($job_count < $job_cnt). This is ok as long as it is at least …
105 if {$job_count < 1} {
125 …fail "Only started $job_count jobs and $step_count steps. We expected at least $desired_tasks and …
128 log_debug "We found $job_count jobs and $step_count steps"
|
| /dports/sysutils/xvidcap/xvidcap-1.1.7/ffmpeg/libavcodec/ |
| H A D | pthread.c | 36 int job_count; member
49 int our_job = c->job_count; in worker()
56 while (our_job >= c->job_count) { in worker()
57 if (c->current_job == thread_count + c->job_count) in worker()
103 … avcodec_thread_execute(AVCodecContext *avctx, action_t* func, void **arg, int *ret, int job_count) in avcodec_thread_execute() argument
108 if (job_count <= 0) in avcodec_thread_execute()
114 c->job_count = job_count; in avcodec_thread_execute()
119 c->rets_count = job_count; in avcodec_thread_execute()
149 c->job_count = 0; in avcodec_thread_init()
|
| /dports/emulators/vice/vice-3.5/src/lib/libffmpeg/libavcodec/ |
| H A D | pthread_slice.c | 54 int job_count; member
76 int our_job = c->job_count; in worker()
83 while (our_job >= c->job_count) { in worker()
84 if (c->current_job == thread_count + c->job_count) in worker()
129 while (c->current_job != thread_count + c->job_count) in thread_park_workers()
140 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
142 if (job_count <= 0) in thread_execute()
148 c->job_count = job_count; in thread_execute()
154 c->rets_count = job_count; in thread_execute()
171 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
[all …]
|
| /dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/lib/libffmpeg/libavcodec/ |
| H A D | pthread_slice.c | 54 int job_count; member
76 int our_job = c->job_count; in worker()
83 while (our_job >= c->job_count) { in worker()
84 if (c->current_job == thread_count + c->job_count) in worker()
129 while (c->current_job != thread_count + c->job_count) in thread_park_workers()
140 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
142 if (job_count <= 0) in thread_execute()
148 c->job_count = job_count; in thread_execute()
154 c->rets_count = job_count; in thread_execute()
171 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
[all …]
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/media/ffvpx/libavcodec/ |
| H A D | pthread_slice.c | 47 int job_count; member
69 int our_job = c->job_count; in worker()
77 while (our_job >= c->job_count) { in worker()
78 if (c->current_job == thread_count + c->job_count) in worker()
96 c->rets[our_job%c->job_count] = ret; in worker()
137 while (c->current_job != thread_count + c->job_count) in thread_park_workers()
147 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
149 if (job_count <= 0) in thread_execute()
155 c->job_count = job_count; in thread_execute()
176 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
[all …]
|
| /dports/devel/glib20/glib-2.70.4/gio/ |
| H A D | gthreadedsocketservice.c | 57 gint job_count; member
71 G_LOCK_DEFINE_STATIC(job_count);
99 G_LOCK (job_count); in g_threaded_socket_service_func()
100 if (data->service->priv->job_count-- == data->service->priv->max_threads) in g_threaded_socket_service_func()
102 G_UNLOCK (job_count); in g_threaded_socket_service_func()
123 G_LOCK (job_count); in g_threaded_socket_service_incoming()
124 if (++threaded->priv->job_count == threaded->priv->max_threads) in g_threaded_socket_service_incoming()
126 G_UNLOCK (job_count); in g_threaded_socket_service_incoming()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/drm/ |
| H A D | spsc_queue.h | 45 atomic_t job_count; member
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
62 return atomic_read(&queue->job_count); in spsc_queue_count()
75 atomic_inc(&queue->job_count); in spsc_queue_push()
116 atomic_dec(&queue->job_count); in spsc_queue_pop()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/drm/ |
| H A D | spsc_queue.h | 45 atomic_t job_count; member
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
62 return atomic_read(&queue->job_count); in spsc_queue_count()
75 atomic_inc(&queue->job_count); in spsc_queue_push()
116 atomic_dec(&queue->job_count); in spsc_queue_pop()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/drm/ |
| H A D | spsc_queue.h | 45 atomic_t job_count; member
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
62 return atomic_read(&queue->job_count); in spsc_queue_count()
75 atomic_inc(&queue->job_count); in spsc_queue_push()
116 atomic_dec(&queue->job_count); in spsc_queue_pop()
|
| /dports/devel/p5-Qudo/Qudo-0.0213/lib/ |
| H A D | Qudo.pm | 109 sub job_count { subroutine
113 return $self->driver_for($dsn)->job_count($funcs);
116 my %job_count;
118 $job_count{$db} = $self->driver_for($db)->job_count($funcs);
120 return \%job_count;
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/gpu/drm/scheduler/ |
| H A D | gpu_scheduler_trace.h | 43 __field(u32, job_count)
52 __entry->job_count = spsc_queue_count(&entity->job_queue);
59 __entry->job_count, __entry->hw_job_count)
70 __field(u32, job_count)
79 __entry->job_count = spsc_queue_count(&entity->job_queue);
86 __entry->job_count, __entry->hw_job_count)
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/gpu/drm/scheduler/ |
| H A D | gpu_scheduler_trace.h | 43 __field(u32, job_count)
52 __entry->job_count = spsc_queue_count(&entity->job_queue);
59 __entry->job_count, __entry->hw_job_count)
70 __field(u32, job_count)
79 __entry->job_count = spsc_queue_count(&entity->job_queue);
86 __entry->job_count, __entry->hw_job_count)
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/drm/scheduler/ |
| H A D | gpu_scheduler_trace.h | 43 __field(u32, job_count)
52 __entry->job_count = spsc_queue_count(&entity->job_queue);
59 __entry->job_count, __entry->hw_job_count)
70 __field(u32, job_count)
79 __entry->job_count = spsc_queue_count(&entity->job_queue);
86 __entry->job_count, __entry->hw_job_count)
|
| /dports/devel/p5-Qudo/Qudo-0.0213/t/004worker/ |
| H A D | replace.t | 12 ($dsn, $cnt) = each %{$master->job_count('Worker::Test2')};
14 ($dsn, $cnt) = each %{$master->job_count('Worker::Test3')};
22 ($dsn, $cnt) = each %{$master->job_count('Worker::Test2')};
24 ($dsn, $cnt) = each %{$master->job_count('Worker::Test3')};
|
| /dports/devel/p5-Qudo/Qudo-0.0213/t/002master/ |
| H A D | job_count.t | 13 my $row = $master->job_count;
17 $row = $master->job_count([qw/Worker::Test1/]);
21 $row = $master->job_count([qw/Worker::Test2/]);
25 $row = $master->job_count([qw/Worker::Test1 Worker::Test2/]);
|
| /dports/multimedia/handbrake/ffmpeg-4.4/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/multimedia/gstreamer1-libav/gst-libav-1.16.2/gst-libs/ext/libav/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/www/firefox-esr/firefox-91.8.0/media/ffvpx/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/ffvpx/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/multimedia/ffmpeg/ffmpeg-4.4.1/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/ffmpeg/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/www/firefox/firefox-99.0/media/ffvpx/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/ffmpeg/libavcodec/ |
| H A D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|