Lines Matching refs:thread

255 fha_hash_entry_add_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread)  in fha_hash_entry_add_thread()  argument
259 thread->st_p2 = 0; in fha_hash_entry_add_thread()
260 LIST_INSERT_HEAD(&fhe->threads, thread, st_alink); in fha_hash_entry_add_thread()
265 fha_hash_entry_remove_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread) in fha_hash_entry_remove_thread() argument
269 KASSERT(thread->st_p2 == 0, in fha_hash_entry_remove_thread()
270 ("%d reqs on removed thread %p", thread->st_p2, thread)); in fha_hash_entry_remove_thread()
271 LIST_REMOVE(thread, st_alink); in fha_hash_entry_remove_thread()
297 SVCTHREAD *thread, *min_thread = NULL; in fha_hash_entry_choose_thread() local
304 LIST_FOREACH(thread, &fhe->threads, st_alink) { in fha_hash_entry_choose_thread()
305 req_count = thread->st_p2; in fha_hash_entry_choose_thread()
311 "fha: %p(%d)w", thread, req_count); in fha_hash_entry_choose_thread()
313 return (thread); in fha_hash_entry_choose_thread()
321 offset2 = thread->st_p3; in fha_hash_entry_choose_thread()
331 "fha: %p(%d)r", thread, req_count); in fha_hash_entry_choose_thread()
333 return (thread); in fha_hash_entry_choose_thread()
344 "fha: %p(%d)s off1 %llu off2 %llu", thread, in fha_hash_entry_choose_thread()
349 min_thread = thread; in fha_hash_entry_choose_thread()
359 thread = this_thread; in fha_hash_entry_choose_thread()
362 "fha: %p(%d)t", thread, thread->st_p2); in fha_hash_entry_choose_thread()
364 fha_hash_entry_add_thread(fhe, thread); in fha_hash_entry_choose_thread()
370 thread = min_thread; in fha_hash_entry_choose_thread()
373 return (thread); in fha_hash_entry_choose_thread()
384 SVCTHREAD *thread; in fha_assign() local
419 thread = fha_hash_entry_choose_thread(softc, fhe, &i, this_thread); in fha_assign()
420 KASSERT(thread, ("fha_assign: NULL thread!")); in fha_assign()
422 thread->st_p2++; in fha_assign()
423 thread->st_p3 = i.offset; in fha_assign()
429 mtx_lock(&thread->st_lock); in fha_assign()
432 return (thread); in fha_assign()
444 fha_nd_complete(SVCTHREAD *thread, struct svc_req *req) in fha_nd_complete() argument
459 thread->st_p2--; in fha_nd_complete()
460 KASSERT(thread->st_p2 >= 0, ("Negative request count %d on %p", in fha_nd_complete()
461 thread->st_p2, thread)); in fha_nd_complete()
462 if (thread->st_p2 == 0) { in fha_nd_complete()
463 fha_hash_entry_remove_thread(fhe, thread); in fha_nd_complete()
477 SVCTHREAD *thread; in fhe_stats_sysctl() local
516 LIST_FOREACH(thread, &fhe->threads, st_alink) { in fhe_stats_sysctl()
518 "reqs %d\n", thread, in fhe_stats_sysctl()
519 thread->st_p3, thread->st_p2); in fhe_stats_sysctl()