if (queue->name) {
char name[16];
util_snprintf(name, sizeof(name), "%s:%i", queue->name, thread_index);
- pipe_thread_setname(name);
+ u_thread_setname(name);
}
while (1) {
input->queue = queue;
input->thread_index = i;
- queue->threads[i] = pipe_thread_create(util_queue_thread_func, input);
+ queue->threads[i] = u_thread_create(util_queue_thread_func, input);
if (!queue->threads[i]) {
free(input);
if (thread_index >= queue->num_threads)
return 0;
- return pipe_thread_get_time_nano(queue->threads[thread_index]);
+ return u_thread_get_time_nano(queue->threads[thread_index]);
}