Lines Matching refs:j
339 int j; in main() local
437 for (j = 0; j < stages; j++) { in main()
438 sp = &stage_info[(i * stages) + j]; in main()
439 sp->stagenum = j; in main()
441 lp->stage[j] = sp; in main()
452 for (j = 0; j < stages; j++) { in main()
453 sp = lp->stage[j]; in main()
454 if (j == 0) { in main()
461 sp->input = &lp->stage[j]->bufq; in main()
462 sp->output = &lp->stage[(j + 1) % stages]->bufq; in main()
467 for (j = 0; j < buffers; j++) { in main()
468 work_array[j].data = lp->data + (lp->isize * j); in main()
469 TAILQ_INSERT_TAIL(&lp->stage[0]->bufq.queue, &work_array[j], link); in main()
471 &work_array[j], i, work_array[j].data); in main()
475 for (j = 0; j < stages; j++) { in main()
476 if (ret = pthread_create(&lp->stage[j]->thread, NULL, in main()
478 (void *) lp->stage[j])) { in main()
479 err(1, "pthread_create %d,%d", i, j); in main()
489 for (j = 0; j < stages; j++) { in main()
490 if (ret = pthread_join(lp->stage[j]->thread, (void **)&status)) { in main()
491 err(1, "pthread_join %d,%d", i, j); in main()
493 DBG("Thread %d,%d status %d\n", i, j, status); in main()