Lines Matching refs:thread

253 fha_hash_entry_add_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread)  in fha_hash_entry_add_thread()  argument
257 thread->st_p2 = 0; in fha_hash_entry_add_thread()
258 LIST_INSERT_HEAD(&fhe->threads, thread, st_alink); in fha_hash_entry_add_thread()
263 fha_hash_entry_remove_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread) in fha_hash_entry_remove_thread() argument
267 KASSERT(thread->st_p2 == 0, in fha_hash_entry_remove_thread()
268 ("%d reqs on removed thread %p", thread->st_p2, thread)); in fha_hash_entry_remove_thread()
269 LIST_REMOVE(thread, st_alink); in fha_hash_entry_remove_thread()
295 SVCTHREAD *thread, *min_thread = NULL; in fha_hash_entry_choose_thread() local
302 LIST_FOREACH(thread, &fhe->threads, st_alink) { in fha_hash_entry_choose_thread()
303 req_count = thread->st_p2; in fha_hash_entry_choose_thread()
309 "fha: %p(%d)w", thread, req_count); in fha_hash_entry_choose_thread()
311 return (thread); in fha_hash_entry_choose_thread()
319 offset2 = thread->st_p3; in fha_hash_entry_choose_thread()
329 "fha: %p(%d)r", thread, req_count); in fha_hash_entry_choose_thread()
331 return (thread); in fha_hash_entry_choose_thread()
342 "fha: %p(%d)s off1 %llu off2 %llu", thread, in fha_hash_entry_choose_thread()
347 min_thread = thread; in fha_hash_entry_choose_thread()
357 thread = this_thread; in fha_hash_entry_choose_thread()
360 "fha: %p(%d)t", thread, thread->st_p2); in fha_hash_entry_choose_thread()
362 fha_hash_entry_add_thread(fhe, thread); in fha_hash_entry_choose_thread()
368 thread = min_thread; in fha_hash_entry_choose_thread()
371 return (thread); in fha_hash_entry_choose_thread()
382 SVCTHREAD *thread; in fha_assign() local
417 thread = fha_hash_entry_choose_thread(softc, fhe, &i, this_thread); in fha_assign()
418 KASSERT(thread, ("fha_assign: NULL thread!")); in fha_assign()
420 thread->st_p2++; in fha_assign()
421 thread->st_p3 = i.offset; in fha_assign()
427 mtx_lock(&thread->st_lock); in fha_assign()
430 return (thread); in fha_assign()
442 fha_nd_complete(SVCTHREAD *thread, struct svc_req *req) in fha_nd_complete() argument
457 thread->st_p2--; in fha_nd_complete()
458 KASSERT(thread->st_p2 >= 0, ("Negative request count %d on %p", in fha_nd_complete()
459 thread->st_p2, thread)); in fha_nd_complete()
460 if (thread->st_p2 == 0) { in fha_nd_complete()
461 fha_hash_entry_remove_thread(fhe, thread); in fha_nd_complete()
475 SVCTHREAD *thread; in fhe_stats_sysctl() local
514 LIST_FOREACH(thread, &fhe->threads, st_alink) { in fhe_stats_sysctl()
516 "reqs %d\n", thread, in fhe_stats_sysctl()
517 thread->st_p3, thread->st_p2); in fhe_stats_sysctl()