Lines Matching refs:thread_id

344 			    thread_id_t thread_id, char *buffer, size_t buffer_length)  in get_thread_name()  argument
346 if (thread_id == thread_config->journal_thread) { in get_thread_name()
347 if (thread_config->packer_thread == thread_id) { in get_thread_name()
359 } else if (thread_id == thread_config->admin_thread) { in get_thread_name()
363 } else if (thread_id == thread_config->packer_thread) { in get_thread_name()
366 } else if (thread_id == thread_config->dedupe_thread) { in get_thread_name()
369 } else if (thread_id == thread_config->bio_ack_thread) { in get_thread_name()
372 } else if (thread_id == thread_config->cpu_thread) { in get_thread_name()
379 thread_id, "logQ", buffer, buffer_length)) in get_thread_name()
384 thread_id, "physQ", buffer, buffer_length)) in get_thread_name()
389 thread_id, "hashQ", buffer, buffer_length)) in get_thread_name()
394 thread_id, "bioQ", buffer, buffer_length)) in get_thread_name()
398 snprintf(buffer, buffer_length, "reqQ%d", thread_id); in get_thread_name()
416 int vdo_make_thread(struct vdo *vdo, thread_id_t thread_id, in vdo_make_thread() argument
420 struct vdo_thread *thread = &vdo->threads[thread_id]; in vdo_make_thread()
429 thread_id); in vdo_make_thread()
433 thread->thread_id = thread_id; in vdo_make_thread()
434 get_thread_name(&vdo->thread_config, thread_id, queue_name, sizeof(queue_name)); in vdo_make_thread()
995 thread_id_t thread_id) in vdo_register_read_only_listener() argument
997 struct vdo_thread *thread = &vdo->threads[thread_id]; in vdo_register_read_only_listener()
1001 result = VDO_ASSERT(thread_id != vdo->thread_config.dedupe_thread, in vdo_register_read_only_listener()
1146 thread_id_t thread_id = completion->callback_thread_id; in make_thread_read_only() local
1152 struct vdo_thread *thread = &vdo->threads[thread_id]; in make_thread_read_only()
1156 if (thread_id == 0) in make_thread_read_only()
1167 make_thread_read_only, thread_id, in make_thread_read_only()
1174 if (++thread_id == vdo->thread_config.dedupe_thread) { in make_thread_read_only()
1179 thread_id++; in make_thread_read_only()
1182 if (thread_id >= vdo->thread_config.thread_count) { in make_thread_read_only()
1189 make_thread_read_only, thread_id, NULL); in make_thread_read_only()
1251 thread_id_t thread_id = vdo_get_callback_thread_id(); in vdo_enter_read_only_mode() local
1255 if (thread_id != VDO_INVALID_THREAD_ID) { in vdo_enter_read_only_mode()
1256 thread = &vdo->threads[thread_id]; in vdo_enter_read_only_mode()
1355 thread_id_t thread_id, void *parent) in perform_synchronous_action() argument
1362 vdo_launch_completion_callback(&sync.vdo_completion, action, thread_id); in perform_synchronous_action()
1610 thread_id_t thread_id; in vdo_get_callback_thread_id() local
1616 thread_id = thread->thread_id; in vdo_get_callback_thread_id()
1619 BUG_ON(thread_id >= thread->vdo->thread_config.thread_count); in vdo_get_callback_thread_id()
1620 BUG_ON(thread != &thread->vdo->threads[thread_id]); in vdo_get_callback_thread_id()
1623 return thread_id; in vdo_get_callback_thread_id()