Lines Matching refs:wp
191 worker_info_t *wp = (worker_info_t *) arg; in manager_fn() local
192 stage_info_t *sp = wp->stage; in manager_fn()
213 affinity_set(wp->setnum); in manager_fn()
214 current_tag = wp->setnum; in manager_fn()
217 DBG("Starting %s %d, stage: %d\n", sp->name, wp->setnum, sp->stagenum); in manager_fn()
259 sp->name, wp->setnum, sp->stagenum, sp->work_todo); in manager_fn()
270 workp->tag = wp->setnum; in manager_fn()
279 sp->name, wp->setnum, sp->stagenum, iteration, workp, workp->data); in manager_fn()
292 sp->name, wp->setnum, sp->stagenum, iteration); in manager_fn()
301 DBG("Ending %s[%d,%d]\n", sp->name, wp->setnum, sp->stagenum); in manager_fn()
324 worker_info_t *wp; in main() local
444 wp = &worker_info[i]; in main()
445 wp->setnum = i + 1; in main()
446 wp->stage = &stage_info[0]; in main()
447 if (ret = pthread_create(&wp->thread, in main()
450 (void *) wp)) { in main()
458 wp = &worker_info[producers + (consumers * (i - 1)) + j]; in main()
459 wp->setnum = j + 1; in main()
460 wp->stage = &stage_info[i]; in main()
461 if (ret = pthread_create(&wp->thread, in main()
464 (void *) wp)) { in main()
477 wp = &worker_info[k]; in main()
485 if (ret = pthread_join(wp->thread, (void **)&status)) { in main()