| /barrelfish-2018-10-04/lib/phoenix/ |
| H A D | tpool.c | 42 int *num_workers; member in struct:__anon1390
48 int num_workers; member in struct:tpool_t
71 tpool->num_workers = num_threads;
120 tpool->thread_args[i].num_workers = &tpool->num_workers;
156 tpool_t *tpool, thread_func thread_func, void **args, int num_workers)
164 assert (num_workers <= tpool->num_threads);
165 tpool->num_workers = num_workers;
167 for (i = 0; i < num_workers;
155 tpool_set( tpool_t *tpool, thread_func thread_func, void **args, int num_workers) argument
[all...] |
| H A D | tpool.h | 36 int tpool_set (tpool_t *tpool, thread_func thread_func, void **args, int num_workers);
|
| H A D | map_reduce.c | 530 tpool_t *tpool, TASK_TYPE_T task_type, thread_arg_t** th_arg_array, int num_workers)
549 CHECK_ERROR (tpool_set (tpool, thread_func, (void **)th_arg_array, num_workers));
529 start_thread_pool( tpool_t *tpool, TASK_TYPE_T task_type, thread_arg_t** th_arg_array, int num_workers) argument
|
| /barrelfish-2018-10-04/lib/tweed/ |
| H A D | tweed.c | 24 static int num_workers; variable
94 int steal_id = (id+1) % num_workers;
99 steal_id = (steal_id+1) % num_workers;
143 num_workers = workers_requested;
145 num_workers * sizeof(struct worker_desc));
147 task_stack_space = malloc (TWEED_TASK_STACK_SIZE * (num_workers + 1));
151 for (i=0; i<num_workers; i++) {
156 // create dispatchers on all other cores required for num_workers
157 for (i=1; i<num_workers; i++) {
168 while (num_dispatchers < num_workers) {
[all...] |
| /barrelfish-2018-10-04/usr/eclipseclp/Kernel/src/ |
| H A D | wm_types.h | 56 int num_workers; member in struct:__anon1675
|
| H A D | wm_msgs.h | 155 int num_workers; member in struct:__anon1669
|
| H A D | wm_interface.c | 216 /* printf("hostname = %s num_workers = %d", hostname, num_workers); */
258 num_sleeping = mc->num_workers - mc->num_awake;
259 /* printf("hostname = %s num_workers = %d", hostname, num_workers); */
437 (char *) &(mc_list.machines[i].num_workers),
|
| H A D | wm.c | 166 static int num_workers = 0; /* set by -w flag */ variable
258 mc_list.machines[mc_id].num_workers = 0;
316 mc->num_workers++;
1199 stat_msg->machines[i].num_workers = mc_list.machines[i].num_workers;
1437 if (workers <= mc->num_workers - mc->num_awake)
1775 <host_name> <eclipse_exe_file> <num_workers> <auto_start>
1781 num_workers is the number of workers to start initially
1793 int num_workers, i, done, val; local
1809 val = fscanf(mcfile, "%s %s %d %d", hostname, exec_file, &num_workers,
[all...] |
| H A D | worker.c | 118 int num_workers; member in struct:__anon1677
240 worker_list.num_workers = 0;
264 worker_list.num_workers++;
1223 while (open_bports != (worker_list.num_workers - 1))
1451 while (closed_bports != (worker_list.num_workers - 1))
1463 while (closed_bports != (worker_list.num_workers))
1769 Make_Integer(cur_head,status.machines[i].num_workers)
|
| /barrelfish-2018-10-04/usr/bench/sdma_bench/ |
| H A D | sdma_bench.c | 45 static size_t num_workers; variable
143 size_t nt = synchronized ? num_workers+1 : 1;
211 size_t nt = synchronized ? num_workers+1 : 1;
291 num_workers = atoi(argv[3]);
297 num_workers = atoi(argv[2]);
301 bench_max = num_workers;
303 debug_printf("master bench, spawning %zu workers...\n", num_workers);
306 for (uint32_t id = 1; id <= num_workers; id++) {
310 snprintf(num_str, sizeof(num_str), "%lu", num_workers);
|
| /barrelfish-2018-10-04/usr/eclipseclp/Kernel/lib/ |
| H A D | menu.tcl | 471 global num_workers
476 set canvas_height [expr $num_workers * 20 + 50]
497 global num_workers
500 set y1 [expr $num_workers * 20 + 30 + 20]
525 global num_workers
528 for {set i 1} {$i <= $num_workers} {incr i} {
544 global num_workers
551 set canvas_height [expr $num_workers * 20 + 80]
558 for {set i 1} {$i <= $num_workers} {incr i} {
615 global num_workers
[all...] |