935 	struct tcpcb *tp1, *tp2;  in KTEST_FUNC()  local
946 	tp1 = test_hpts_create_tcpcb(ctx, pace);  in KTEST_FUNC()
948 	KTEST_NEQUAL(tp1, NULL);  in KTEST_FUNC()
952 	tp1->t_hpts_cpu = 0;  in KTEST_FUNC()
956 	INP_WLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
957 	tp1->t_flags2 |= TF2_HPTS_CALLS;  in KTEST_FUNC()
958 	tcp_hpts_insert(pace, tp1, 100, NULL);  in KTEST_FUNC()
959 	INP_WUNLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
968 	/* Manually transition tp1 to MOVING state to simulate race condition */  in KTEST_FUNC()
970 	tp1->t_in_hpts = IHPTS_MOVING;  in KTEST_FUNC()
971 	tp1->t_hpts_slot = -1; /* Mark for removal */  in KTEST_FUNC()
985 	/* tp1 should be cleaned up and removed */  in KTEST_FUNC()
986 	KTEST_EQUAL(tp1->t_in_hpts, IHPTS_NONE);  in KTEST_FUNC()
990 	test_hpts_free_tcpcb(tp1);  in KTEST_FUNC()
1124 	struct tcpcb *tp1, *tp2, *tp2_dup, *tp3;  in KTEST_FUNC()  local
1132 	tp1 = test_hpts_create_tcpcb(ctx, pace);  in KTEST_FUNC()
1133 	KTEST_NEQUAL(tp1, NULL);  in KTEST_FUNC()
1134 	tp1->t_inpcb.inp_flowtype = M_HASHTYPE_NONE;  in KTEST_FUNC()
1135 	INP_WLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1136 	tcp_set_hpts(pace, tp1);  in KTEST_FUNC()
1137 	INP_WUNLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1138 	KTEST_VERIFY(tp1->t_hpts_cpu < pace->rp_num_hptss);  in KTEST_FUNC()
1139 	KTEST_VERIFY(tp1->t_flags2 & TF2_HPTS_CPU_SET);  in KTEST_FUNC()
1172 	test_hpts_free_tcpcb(tp1);  in KTEST_FUNC()
1313 	struct tcpcb *tp1, *tp2;  in KTEST_FUNC()  local
1322 	tp1 = test_hpts_create_tcpcb(ctx, pace);  in KTEST_FUNC()
1324 	KTEST_NEQUAL(tp1, NULL);  in KTEST_FUNC()
1328 	tp1->t_hpts_cpu = 0;  in KTEST_FUNC()
1331 	/* Insert tp1 */  in KTEST_FUNC()
1332 	INP_WLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1333 	tp1->t_flags2 |= TF2_HPTS_CALLS;  in KTEST_FUNC()
1334 	tcp_hpts_insert(pace, tp1, 100, NULL);  in KTEST_FUNC()
1335 	INP_WUNLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1344 	KTEST_EQUAL(tp1->t_in_hpts, IHPTS_ONQUEUE);  in KTEST_FUNC()
1348 	KTEST_EQUAL(tp1->t_hpts_slot, tp2->t_hpts_slot);  in KTEST_FUNC()
1351 	KTEST_EQUAL(tp1->t_hpts_cpu, tp2->t_hpts_cpu); /* Should be on same CPU */  in KTEST_FUNC()
1352 	hpts = pace->rp_ent[tp1->t_hpts_cpu];  in KTEST_FUNC()
1355 	/* Remove tp1 while tp2 is still there */  in KTEST_FUNC()
1356 	INP_WLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1357 	tcp_hpts_remove(pace, tp1);  in KTEST_FUNC()
1358 	INP_WUNLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1360 	/* Verify tp1 removed, tp2 still there */  in KTEST_FUNC()
1361 	KTEST_EQUAL(tp1->t_in_hpts, IHPTS_NONE);  in KTEST_FUNC()
1377 	test_hpts_free_tcpcb(tp1);  in KTEST_FUNC()
1548 	struct tcpcb *tp1, *tp2;  in KTEST_FUNC()  local
1566 	tp1 = test_hpts_create_tcpcb(ctx, pace);  in KTEST_FUNC()
1567 	KTEST_NEQUAL(tp1, NULL);  in KTEST_FUNC()
1568 	tp1->t_hpts_cpu = 0; /* Force to CPU 0 */  in KTEST_FUNC()
1570 	INP_WLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1571 	tp1->t_flags2 |= TF2_HPTS_CALLS;  in KTEST_FUNC()
1572 	tcp_hpts_insert(pace, tp1, timeout_usecs, NULL);  in KTEST_FUNC()
1573 	INP_WUNLOCK(&tp1->t_inpcb);  in KTEST_FUNC()
1576 	KTEST_EQUAL(tp1->t_in_hpts, IHPTS_ONQUEUE);  in KTEST_FUNC()
1577 	KTEST_EQUAL(tp1->t_hpts_slot, slot_to_test);  in KTEST_FUNC()
1578 	KTEST_EQUAL(tp1->t_hpts_gencnt, initial_gencnt);  in KTEST_FUNC()
1601 	KTEST_EQUAL(tp1->t_in_hpts, IHPTS_NONE);  in KTEST_FUNC()
1633 	test_hpts_free_tcpcb(tp1);  in KTEST_FUNC()