Lines Matching refs:tcpcbs
786 struct tcpcb **tcpcbs; in KTEST_FUNC() local
796 tcpcbs = malloc(num_tcpcbs * sizeof(struct tcpcb *), M_TCPHPTS, M_WAITOK | M_ZERO); in KTEST_FUNC()
797 KTEST_VERIFY_RET(tcpcbs != NULL, ENOMEM); in KTEST_FUNC()
802 tcpcbs[i] = test_hpts_create_tcpcb(ctx, pace); in KTEST_FUNC()
803 if (tcpcbs[i] == NULL) { in KTEST_FUNC()
812 INP_WLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
813 tcpcbs[i]->t_flags2 |= TF2_HPTS_CALLS; in KTEST_FUNC()
815 tcp_hpts_insert(pace, tcpcbs[i], 100 + (i % 1000), NULL); in KTEST_FUNC()
816 INP_WUNLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
831 INP_WLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
832 if (tcpcbs[i]->t_in_hpts != IHPTS_NONE) { in KTEST_FUNC()
833 tcp_hpts_remove(pace, tcpcbs[i]); in KTEST_FUNC()
835 INP_WUNLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
847 test_hpts_free_tcpcb(tcpcbs[i]); in KTEST_FUNC()
849 free(tcpcbs, M_TCPHPTS); in KTEST_FUNC()
864 struct tcpcb **tcpcbs; in KTEST_FUNC() local
875 tcpcbs = malloc(num_tcpcbs * sizeof(struct tcpcb *), M_TCPHPTS, M_WAITOK | M_ZERO); in KTEST_FUNC()
876 KTEST_VERIFY_RET(tcpcbs != NULL, ENOMEM); in KTEST_FUNC()
880 tcpcbs[i] = test_hpts_create_tcpcb(ctx, pace); in KTEST_FUNC()
881 KTEST_NEQUAL(tcpcbs[i], NULL); in KTEST_FUNC()
882 TP_REMOVE_FROM_HPTS(tcpcbs[i]) = 1; in KTEST_FUNC()
886 INP_WLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
887 tcpcbs[i]->t_flags2 |= TF2_HPTS_CALLS; in KTEST_FUNC()
888 tcp_hpts_insert(pace, tcpcbs[i], timeout_usecs, NULL); in KTEST_FUNC()
889 INP_WUNLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
913 INP_WLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
914 if (tcpcbs[i]->t_in_hpts != IHPTS_NONE) { in KTEST_FUNC()
915 tcp_hpts_remove(pace, tcpcbs[i]); in KTEST_FUNC()
917 INP_WUNLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
918 test_hpts_free_tcpcb(tcpcbs[i]); in KTEST_FUNC()
920 free(tcpcbs, M_TCPHPTS); in KTEST_FUNC()
1248 struct tcpcb **tcpcbs; in KTEST_FUNC() local
1260 tcpcbs = malloc(num_tcpcbs * sizeof(struct tcpcb *), M_TCPHPTS, M_WAITOK | M_ZERO); in KTEST_FUNC()
1261 KTEST_VERIFY_RET(tcpcbs != NULL, ENOMEM); in KTEST_FUNC()
1264 tcpcbs[i] = test_hpts_create_tcpcb(ctx, pace); in KTEST_FUNC()
1265 KTEST_NEQUAL(tcpcbs[i], NULL); in KTEST_FUNC()
1266 tcpcbs[i]->t_hpts_cpu = 0; /* Force all to CPU 0 */ in KTEST_FUNC()
1267 INP_WLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
1268 tcpcbs[i]->t_flags2 |= TF2_HPTS_CALLS; in KTEST_FUNC()
1269 TP_REMOVE_FROM_HPTS(tcpcbs[i]) = 1; /* Will be removed after output */ in KTEST_FUNC()
1270 tcp_hpts_insert(pace, tcpcbs[i], 100, NULL); in KTEST_FUNC()
1271 INP_WUNLOCK(&tcpcbs[i]->t_inpcb); in KTEST_FUNC()
1297 test_hpts_free_tcpcb(tcpcbs[i]); in KTEST_FUNC()
1299 free(tcpcbs, M_TCPHPTS); in KTEST_FUNC()