Lines Matching refs:thread
41 pthread_t thread;
63 static void my_exit(struct loopback_thread *thread, int exitcode)
67 for (i = 0; i < thread->loopbacks_count; i++)
68 pcmjob_done(thread->loopbacks[i]);
69 if (thread->threaded) {
70 thread->exitcode = exitcode;
196 "-T,--thread thread number (-1 = create unique)\n"
384 {"thread", 1, NULL, 'T'},
627 loop->thread = arg_thread;
728 struct loopback_thread *thread = _data;
729 snd_output_t *output = thread->output;
736 for (i = 0; i < thread->loopbacks_count; i++) {
737 err = pcmjob_init(thread->loopbacks[i]);
740 my_exit(thread, EXIT_FAILURE);
743 for (i = 0; i < thread->loopbacks_count; i++) {
744 err = pcmjob_start(thread->loopbacks[i]);
747 my_exit(thread, EXIT_FAILURE);
749 pfds_count += thread->loopbacks[i]->pollfd_count;
750 j = thread->loopbacks[i]->wake;
759 my_exit(thread, EXIT_FAILURE);
763 for (i = j = 0; i < thread->loopbacks_count; i++) {
764 err = pcmjob_pollfds_init(thread->loopbacks[i], &pfds[j]);
767 my_exit(thread, EXIT_FAILURE);
784 my_exit(thread, EXIT_FAILURE);
786 for (i = j = 0; i < thread->loopbacks_count; i++) {
787 struct loopback *loop = thread->loopbacks[i];
799 my_exit(thread, EXIT_SUCCESS);
802 static void thread_job(struct loopback_thread *thread)
804 if (!thread->threaded) {
805 thread_job1(thread);
808 pthread_create(&thread->thread, NULL, (void *) &thread_job1,
809 (void *) thread);
814 struct loopback_thread *thread;
818 thread = &threads[i];
819 if (thread->threaded)
820 pthread_kill(thread->thread, sig);
833 struct loopback_thread *thread;
839 thread = &threads[i];
840 if (thread->thread == self) {
841 for (j = 0; j < thread->loopbacks_count; j++)
842 pcmjob_state(thread->loopbacks[j]);
893 /* we must sort thread IDs */
898 if (loopbacks[i]->thread < k &&
899 loopbacks[i]->thread > j)
900 k = loopbacks[i]->thread;
904 if (loopbacks[i]->thread == k)
905 loopbacks[i]->thread = j;
908 /* fix maximum thread id */
910 if (loopbacks[i]->thread > j)
911 j = loopbacks[i]->thread;
922 if (loopbacks[i]->thread == k)
929 if (loopbacks[i]->thread == k)
946 pthread_join(threads[k].thread, NULL);