201 IOPerfControlClient::allocateToken(thread_group *thread_group)  in allocateToken()  argument
212 		if (workTable[index].thread_group == nullptr) {  in allocateToken()
213 			thread_group_retain(thread_group);  in allocateToken()
214 			workTable[index].thread_group = thread_group;  in allocateToken()
259 	auto *thread_group = entry.thread_group;  in deallocateToken()  local
268 	thread_group_release(thread_group);  in deallocateToken()
287 	assertf(entry->thread_group, "Invalid work token: %llu", token);  in getEntryForToken()
307 static struct thread_group *
320 	struct thread_group * thread_group = thread_group_get(thread);  in threadGroupForDextService()  local
321 	assert(thread_group != nullptr);  in threadGroupForDextService()
322 	return thread_group;  in threadGroupForDextService()
337 		struct thread_group *dext_thread_group = threadGroupForDextService(device);  in registerDevice()
397 	auto *thread_group = thread_group_get(current_thread());  in workSubmit()  local
398 	if (!thread_group) {  in workSubmit()
403 		.thread_group_id = thread_group_get_id(thread_group),  in workSubmit()
404 		.thread_group_data = thread_group_get_machine_data(thread_group),  in workSubmit()
414 	uint64_t token = allocateToken(thread_group);  in workSubmit()
430 	auto *thread_group = thread_group_get(current_thread());  in workSubmitAndBegin()  local
431 	if (!thread_group) {  in workSubmitAndBegin()
436 		.thread_group_id = thread_group_get_id(thread_group),  in workSubmitAndBegin()
437 		.thread_group_data = thread_group_get_machine_data(thread_group),  in workSubmitAndBegin()
447 	uint64_t token = allocateToken(thread_group);  in workSubmitAndBegin()
475 		.thread_group_id = thread_group_get_id(entry->thread_group),  in workBegin()
476 		.thread_group_data = thread_group_get_machine_data(entry->thread_group),  in workBegin()
497 		.thread_group_id = thread_group_get_id(entry->thread_group),  in workEnd()
498 		.thread_group_data = thread_group_get_machine_data(entry->thread_group),  in workEnd()
531 	struct thread_group *thread_group;  member in IOPerfControlWorkContext
557 	thread_group = nullptr;  in reset()
566 …assertf(thread_group == nullptr, "IOPerfControlWorkContext ID %llu being released without calling …  in free()
600 		.thread_group_id = thread_group_get_id(work_context->thread_group),  in workSubmitAndBeginWithContext()
601 		.thread_group_data = thread_group_get_machine_data(work_context->thread_group),  in workSubmitAndBeginWithContext()
628 	auto *thread_group = thread_group_get(current_thread());  in workSubmitWithContext()  local
629 	assert(thread_group != nullptr);  in workSubmitWithContext()
632 …thread_group == nullptr, "IOPerfControlWorkContext ID %llu has already taken a refcount on TG 0x%p…  in workSubmitWithContext()
635 		.thread_group_id = thread_group_get_id(thread_group),  in workSubmitWithContext()
636 		.thread_group_data = thread_group_get_machine_data(thread_group),  in workSubmitWithContext()
646 	work_context->thread_group = thread_group_retain(thread_group);  in workSubmitWithContext()
675 	if (work_context->thread_group == nullptr) {  in workUpdateWithContext()
681 		.thread_group_id = thread_group_get_id(work_context->thread_group),  in workUpdateWithContext()
682 		.thread_group_data = thread_group_get_machine_data(work_context->thread_group),  in workUpdateWithContext()
701 	if (work_context->thread_group == nullptr) {  in workBeginWithContext()
709 		.thread_group_id = thread_group_get_id(work_context->thread_group),  in workBeginWithContext()
710 		.thread_group_data = thread_group_get_machine_data(work_context->thread_group),  in workBeginWithContext()
732 	if (work_context->thread_group == nullptr) {  in workEndWithContext()
737 		.thread_group_id = thread_group_get_id(work_context->thread_group),  in workEndWithContext()
738 		.thread_group_data = thread_group_get_machine_data(work_context->thread_group),  in workEndWithContext()
756 		thread_group_release(work_context->thread_group);  in workEndWithContext()