Lines Matching full:workers
534 if (verbose() && !env.workers) in test__end_subtest()
886 { "workers", ARG_NUM_WORKERS, "WORKERS", OPTION_ARG_OPTIONAL,
887 "Number of workers to run in parallel, default to number of cpus." },
1086 env->workers = atoi(arg); in parse_arg()
1087 if (!env->workers) { in parse_arg()
1092 env->workers = get_nprocs(); in parse_arg()
1303 for (i = 0; i < env.workers; i++) in sigint_handler()
1681 dispatcher_threads = calloc(sizeof(pthread_t), env.workers); in server_main()
1682 data = calloc(sizeof(struct dispatch_data), env.workers); in server_main()
1684 env.worker_current_test = calloc(sizeof(int), env.workers); in server_main()
1685 for (i = 0; i < env.workers; i++) { in server_main()
1698 for (i = 0; i < env.workers; i++) { in server_main()
1738 /* reap all workers */ in server_main()
1739 for (i = 0; i < env.workers; i++) { in server_main()
2006 /* ignore workers if we are just listing */ in main()
2008 env.workers = 0; in main()
2010 /* launch workers if requested */ in main()
2012 if (env.workers) { in main()
2013 env.worker_pids = calloc(sizeof(pid_t), env.workers); in main()
2014 env.worker_socks = calloc(sizeof(int), env.workers); in main()
2016 fprintf(stdout, "Launching %d workers.\n", env.workers); in main()
2017 for (i = 0; i < env.workers; i++) { in main()