Lines Matching refs:worker
150 static void create_thread_worker(union messaging_worker *worker, in create_thread_worker() argument
164 ret = pthread_create(&worker->thread, &attr, func, ctx); in create_thread_worker()
171 static void create_process_worker(union messaging_worker *worker, in create_process_worker() argument
175 worker->pid = fork(); in create_process_worker()
177 if (worker->pid == -1) { in create_process_worker()
179 } else if (worker->pid == 0) { in create_process_worker()
185 static void create_worker(union messaging_worker *worker, in create_worker() argument
189 return create_process_worker(worker, ctx, func); in create_worker()
191 return create_thread_worker(worker, ctx, func); in create_worker()
194 static void reap_worker(union messaging_worker *worker) in reap_worker() argument
205 pthread_join(worker->thread, &thread_status); in reap_worker()
210 static unsigned int group(union messaging_worker *worker, in group() argument
241 create_worker(worker + i, ctx, (void *)receiver); in group()
254 create_worker(worker + num_fds + i, snd_ctx, (void *)sender); in group()