Home
last modified time | relevance | path

Searched refs:tp (Results 1 – 25 of 182) sorted by relevance

12345678

/f-stack/freebsd/netinet/
H A Dtcp_timer.c295 (void) tp->t_fb->tfb_tcp_output(tp); in tcp_timer_delack()
365 tp = tcp_close(tp); in tcp_timer_2msl()
379 tp = tcp_close(tp); in tcp_timer_2msl()
459 if (ticks - tp->t_rcvtime >= TP_KEEPIDLE(tp) + TP_MAXIDLE(tp)) in tcp_timer_keep()
506 tp = tcp_drop(tp, ETIMEDOUT); in tcp_timer_keep()
570 tp = tcp_drop(tp, ETIMEDOUT); in tcp_timer_persist()
587 tp = tcp_drop(tp, ETIMEDOUT); in tcp_timer_persist()
659 tp = tcp_drop(tp, ETIMEDOUT); in tcp_timer_rexmt()
680 tp->snd_cwnd_prev = tp->snd_cwnd; in tcp_timer_rexmt()
866 tp->snd_nxt = tp->snd_una; in tcp_timer_rexmt()
[all …]
H A Dtcp_input.c299 hhook_data.tp = tp; in hhook_run_tcp_est_in()
487 tp->snd_nxt = tp->snd_max; in cc_cong_signal()
1904 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
1953 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in tcp_do_segment()
2184 tp = tcp_close(tp); in tcp_do_segment()
2333 tp = tcp_close(tp); in tcp_do_segment()
2998 tp = tcp_close(tp); in tcp_do_segment()
3088 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
3598 if (tp->t_rttbest > tp->t_srtt + tp->t_rttvar) in tcp_xmit_timer()
3599 tp->t_rttbest = tp->t_srtt + tp->t_rttvar; in tcp_xmit_timer()
[all …]
H A Dtcp_output.c167 hhook_data.tp = tp; in hhook_run_tcp_est_out()
188 CC_ALGO(tp)->after_idle(tp->ccv); in cc_after_idle()
262 idle = (tp->t_flags & TF_LASTIDLE) || (tp->snd_max == tp->snd_una); in tcp_output()
264 (tp->t_sndtime && ((ticks - tp->t_sndtime) >= tp->t_rxtcur)))) in tcp_output()
285 off = tp->snd_nxt - tp->snd_una; in tcp_output()
502 tp->snd_nxt = tp->snd_una; in tcp_output()
789 tp->snd_nxt = tp->iss; in tcp_output()
1162 tp->snd_nxt == tp->snd_max) in tcp_output()
1525 tp->snd_max = tp->snd_nxt; in tcp_output()
1649 tp->snd_cwnd = tp->t_maxseg; in tcp_output()
[all …]
H A Dtcp_sack.c171 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list()
236 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) in tcp_update_dsack_list()
440 tp->sackblks[i].start = tp->sackblks[i].end=0; in tcp_clean_sackreport()
612 tp->snd_fack = SEQ_MAX(tp->snd_una, th_ack); in tcp_sack_doack()
798 tp->snd_cwnd = (tp->sackhint.sack_bytes_rexmit + in tcp_sack_partialack()
799 (tp->snd_nxt - tp->snd_recover) + num_segs * maxseg); in tcp_sack_partialack()
800 if (tp->snd_cwnd > tp->snd_ssthresh) in tcp_sack_partialack()
801 tp->snd_cwnd = tp->snd_ssthresh; in tcp_sack_partialack()
803 (void) tp->t_fb->tfb_tcp_output(tp); in tcp_sack_partialack()
882 if (SEQ_GEQ(tp->snd_nxt, tp->snd_fack)) in tcp_sack_adjust()
[all …]
H A Dtcp_offload.c134 struct toedev *tod = tp->tod; in tcp_offload_input()
139 tod->tod_input(tod, tp, m); in tcp_offload_input()
145 struct toedev *tod = tp->tod; in tcp_offload_output()
160 tp->t_flags |= TF_SENTFIN; in tcp_offload_output()
170 struct toedev *tod = tp->tod; in tcp_offload_rcvd()
175 tod->tod_rcvd(tod, tp); in tcp_offload_rcvd()
181 struct toedev *tod = tp->tod; in tcp_offload_ctloutput()
192 struct toedev *tod = tp->tod; in tcp_offload_tcp_info()
204 struct toedev *tod = tp->tod; in tcp_offload_alloc_tls_session()
215 struct toedev *tod = tp->tod; in tcp_offload_detach()
[all …]
H A Dtcp_usrreq.c2666 tp = tcp_close(tp); in tcp_disconnect()
2670 tp = tcp_drop(tp, 0); in tcp_disconnect()
2707 tp = tcp_close(tp); in tcp_usrclosed()
2977 tp->snd_una, tp->snd_max, tp->snd_nxt); in db_print_tcpcb()
2981 tp->snd_up, tp->snd_wl1, tp->snd_wl2); in db_print_tcpcb()
2985 tp->iss, tp->irs, tp->rcv_nxt); in db_print_tcpcb()
2989 tp->rcv_adv, tp->rcv_wnd, tp->rcv_up); in db_print_tcpcb()
3009 tp->t_rxtcur, tp->t_maxseg, tp->t_srtt); in db_print_tcpcb()
3018 tp->t_rttupdated, tp->max_sndwnd, tp->t_softerror); in db_print_tcpcb()
3027 tp->snd_scale, tp->rcv_scale, tp->request_r_scale); in db_print_tcpcb()
[all …]
H A Dtcp_reass.c315 tp->t_segqlen--; in tcp_reass_flush()
320 tp, tp->t_segqlen)); in tcp_reass_flush()
339 tp->t_rcvoopack++; in tcp_reass_append()
375 tp->t_rcvoopack++; in tcp_reass_prepend()
410 tp->t_rcvoopack++; in tcp_reass_replace()
441 tp->t_segqlen--; in tcp_reass_merge_into()
557 th, tp)); in tcp_reass()
737 th->th_seq, tp->rcv_nxt, tp); in tcp_reass()
876 p, tp); in tcp_reass()
1023 tp->t_segqlen++; in tcp_reass()
[all …]
H A Dtcp_log_buf.c579 if ((tp->t_lib != NULL && !strcmp(tp->t_lib->tlb_id, id)) || in tcp_log_set_id()
587 tp->t_logstate = tp->t_lib->tlb_logstate; in tcp_log_set_id()
593 tp->t_loglimit = tp->t_lib->tlb_loglimit; in tcp_log_set_id()
683 if (tp->t_lib != NULL || tp->t_lin != NULL) in tcp_log_set_id()
878 tp->t_logstate = tp->t_lib->tlb_logstate; in tcp_log_set_id()
883 tp->t_loglimit = tp->t_lib->tlb_loglimit; in tcp_log_set_id()
993 return ((tp->t_lib == NULL) ? 0 : tp->t_lib->tlb_refcnt); in tcp_log_get_id_cnt()
1071 tp->t_lognum--; in tcp_log_remove_log_cleanup()
1567 if (tp->t_lognum < tp->t_loglimit) { in tcp_log_event_()
1581 if (tp->t_lib == NULL && (tp->t_flags2 & TF2_LOG_AUTO) && in tcp_log_event_()
[all …]
H A Dtcp_subr.c446 (*tp->t_fb->tfb_tcp_fb_fini)(tp, 0); in tcp_switch_back_to_default()
724 tp->snd_una != tp->snd_max) && !(tcp_timer_active(tp, TT_REXMT) || in tcp_default_fb_init()
752 tp->snd_nxt - tp->snd_una); in tcp_default_fb_init()
1707 tp->ccv->ccvc.tcp = tp; in tcp_newtcpcb()
2027 CC_ALGO(tp)->cb_destroy(tp->ccv); in tcp_discardcb()
2232 tp = tcp_drop(tp, error); in tcp_notify()
2880 tp = tcp_drop(tp, errno); in tcp_drop_syn_sent()
2926 tp->snd_nxt = tp->snd_una; in tcp_mtudisc()
2928 tp->snd_recover = tp->snd_max; in tcp_mtudisc()
2931 tp->t_fb->tfb_tcp_output(tp); in tcp_mtudisc()
[all …]
/f-stack/freebsd/kern/
H A Dtty.c220 if (tty_gone(tp) || !tty_opened(tp)) { in ttydev_enter()
294 error = tty_wait(tp, &tp->t_dcdwait); in ttydev_open()
328 tp->t_termios = tp->t_termios_init_in; in ttydev_open()
329 ttydevsw_param(tp, &tp->t_termios); in ttydev_open()
351 error = tty_wait(tp, &tp->t_dcdwait); in ttydev_open()
497 error = tty_wait(tp, &tp->t_bgwait); in tty_wait_background()
1098 tp->t_mtx = &tp->t_mtxobj; in tty_alloc_mutex()
1133 if (tp->t_mtx == &tp->t_mtxobj) in tty_dealloc()
1847 tp->t_session->s_ttyp = tp; in tty_generic_ioctl()
2373 tp->t_inq.ti_linestart, tp->t_inq.ti_reprint, tp->t_inq.ti_end, in DB_SHOW_COMMAND()
[all …]
H A Dtty_ttydisc.c161 error = tty_wait(tp, &tp->t_inwait); in ttydisc_read_canonical()
216 error = tty_wait(tp, &tp->t_inwait); in ttydisc_read_raw_no_timer()
317 error = tty_wait(tp, &tp->t_inwait); in ttydisc_read_raw_interbyte_timer()
420 tp->t_column = tp->t_writepos = 0; in ttydisc_write_oproc()
435 tp->t_column = tp->t_writepos = 0; in ttydisc_write_oproc()
527 tp->t_writepos = tp->t_column; in ttydisc_write()
538 tp->t_writepos = tp->t_column; in ttydisc_write()
562 error = tty_wait(tp, &tp->t_outwait); in ttydisc_write()
727 struct tty *tp = data->tp; in ttydisc_recalc_charlength() local
766 if (tp->t_writepos >= tp->t_column) { in ttydisc_rubchar()
[all …]
H A Dtty_pts.c125 tty_lock(tp); in ptsdev_read()
205 tty_lock(tp); in ptsdev_write()
276 tty_lock(tp); in ptsdev_ioctl()
315 tty_lock(tp); in ptsdev_ioctl()
342 tty_lock(tp); in ptsdev_ioctl()
351 tty_lock(tp); in ptsdev_ioctl()
367 tty_lock(tp); in ptsdev_ioctl()
383 tty_lock(tp); in ptsdev_ioctl()
400 tty_lock(tp); in ptsdev_poll()
517 tty_lock(tp); in ptsdev_kqfilter()
[all …]
/f-stack/freebsd/sys/
H A Dttydevsw.h92 return (tp->t_devsw->tsw_open(tp)); in ttydevsw_open()
102 tp->t_devsw->tsw_close(tp); in ttydevsw_close()
116 tp->t_devsw->tsw_outwakeup(tp); in ttydevsw_outwakeup()
130 tp->t_devsw->tsw_inwakeup(tp); in ttydevsw_inwakeup()
140 return (tp->t_devsw->tsw_ioctl(tp, cmd, data, td)); in ttydevsw_ioctl()
151 return (tp->t_devsw->tsw_cioctl(tp, unit, cmd, data, td)); in ttydevsw_cioctl()
160 return (tp->t_devsw->tsw_param(tp, t)); in ttydevsw_param()
169 return (tp->t_devsw->tsw_modem(tp, sigon, sigoff)); in ttydevsw_modem()
189 tp->t_devsw->tsw_pktnotify(tp, event); in ttydevsw_pktnotify()
198 tp->t_devsw->tsw_free(tty_softc(tp)); in ttydevsw_free()
[all …]
H A Dttyhook.h74 #define ttyhook_softc(tp) ((tp)->t_hooksoftc) argument
75 #define ttyhook_hashook(tp,hook) ((tp)->t_hook != NULL && \ argument
82 MPASS(!tty_gone(tp)); in ttyhook_rint()
84 return tp->t_hook->th_rint(tp, c, flags); in ttyhook_rint()
93 return tp->t_hook->th_rint_bypass(tp, buf, len); in ttyhook_rint_bypass()
102 tp->t_hook->th_rint_done(tp); in ttyhook_rint_done()
111 return tp->t_hook->th_rint_poll(tp); in ttyhook_rint_poll()
120 return tp->t_hook->th_getc_inject(tp, buf, len); in ttyhook_getc_inject()
129 tp->t_hook->th_getc_capture(tp, buf, len); in ttyhook_getc_capture()
138 return tp->t_hook->th_getc_poll(tp); in ttyhook_getc_poll()
[all …]
H A Dtty.h173 #define tty_lock(tp) mtx_lock((tp)->t_mtx) argument
174 #define tty_unlock(tp) mtx_unlock((tp)->t_mtx) argument
175 #define tty_lock_owned(tp) mtx_owned((tp)->t_mtx) argument
176 #define tty_assert_locked(tp) mtx_assert((tp)->t_mtx, MA_OWNED) argument
177 #define tty_getlock(tp) ((tp)->t_mtx) argument
180 #define tty_lock_assert(tp, ma) mtx_assert((tp)->t_mtx, (ma)) argument
215 #define tty_opened(tp) ((tp)->t_flags & TF_OPENED) argument
216 #define tty_gone(tp) ((tp)->t_flags & TF_GONE) argument
217 #define tty_softc(tp) ((tp)->t_devswsoftc) argument
218 #define tty_devname(tp) devtoname((tp)->t_dev) argument
[all …]
H A Dttydisc.h47 void ttydisc_open(struct tty *tp);
48 void ttydisc_close(struct tty *tp);
51 void ttydisc_optimize(struct tty *tp);
55 #define ttydisc_can_bypass(tp) ((tp)->t_flags & TF_BYPASS) argument
59 void ttydisc_rint_done(struct tty *tp);
60 size_t ttydisc_rint_poll(struct tty *tp);
72 ttydisc_read_poll(struct tty *tp) in ttydisc_read_poll() argument
75 tty_assert_locked(tp); in ttydisc_read_poll()
81 ttydisc_write_poll(struct tty *tp) in ttydisc_write_poll() argument
84 tty_assert_locked(tp); in ttydisc_write_poll()
[all …]
/f-stack/freebsd/net/
H A Dif_tuntap.c153 #define TUN_LOCK(tp) mtx_lock(&(tp)->tun_mtx) argument
154 #define TUN_UNLOCK(tp) mtx_unlock(&(tp)->tun_mtx) argument
383 TUN_LOCK(tp); in tun_busy()
393 TUN_LOCK(tp); in tun_unbusy()
623 cv_wait_unlock(&tp->tun_cv, &tp->tun_mtx); in tun_destroy()
643 free_unr(tp->tun_drv->unrhdr, TUN2IFP(tp)->if_dunit); in tun_destroy()
803 tp = malloc(sizeof(*tp), M_TUN, M_WAITOK | M_ZERO); in tun_create_device()
828 knlist_init_mtx(&tp->tun_rsel.si_note, &tp->tun_mtx); in tun_create_device()
855 wakeup(tp); in tunstart()
859 if (tp->tun_flags & TUN_ASYNC && tp->tun_sigio) { in tunstart()
[all …]
/f-stack/freebsd/netinet/tcp_stacks/
H A Drack_bbr_common.c471 bytes_out = tp->snd_max - tp->snd_una; in ctf_outstanding()
488 tp, rc_sacked, ctf_outstanding(tp)); in ctf_flight_size()
592 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks()
703 tp = tcp_close(tp); in ctf_process_rst()
711 tp->rcv_nxt, tp->snd_nxt, TH_ACK); in ctf_process_rst()
712 tp->last_ack_sent = tp->rcv_nxt; in ctf_process_rst()
736 tp = tcp_drop(tp, ECONNRESET); in ctf_challenge_ack()
741 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in ctf_challenge_ack()
743 tp->last_ack_sent = tp->rcv_nxt; in ctf_challenge_ack()
802 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in ctf_calc_rwin()
[all …]
H A Drack.c4050 tp->snd_nxt = tp->snd_max; in rack_cong_signal()
6499 if (tp->t_rttbest > tp->t_srtt + tp->t_rttvar) in tcp_rack_xmit_timer_commit()
6500 tp->t_rttbest = tp->t_srtt + tp->t_rttvar; in tcp_rack_xmit_timer_commit()
6509 tp->t_rttbest = tp->t_srtt + tp->t_rttvar; in tcp_rack_xmit_timer_commit()
8403 tp = tcp_close(tp); in rack_process_ack()
8602 tp->rcv_up = tp->rcv_nxt; in rack_process_data()
8902 tp->rcv_up = tp->rcv_nxt; in rack_do_fastnewdata()
9797 tp = tcp_close(tp); in rack_check_data_after_close()
10137 tp = tcp_close(tp); in rack_do_lastack()
12460 tp->snd_nxt = tp->iss; in rack_output()
[all …]
H A Dbbr.c6393 if (tp->t_rttbest > tp->t_srtt + tp->t_rttvar) in tcp_bbr_xmit_timer_commit()
6394 tp->t_rttbest = tp->t_srtt + tp->t_rttvar; in tcp_bbr_xmit_timer_commit()
6403 tp->t_rttbest = tp->t_srtt + tp->t_rttvar; in tcp_bbr_xmit_timer_commit()
7904 tp->snd_nxt = tp->snd_max; in bbr_process_ack()
7938 tp = tcp_close(tp); in bbr_process_ack()
8282 tp->rcv_up = tp->rcv_nxt; in bbr_process_data()
8583 tp->rcv_up = tp->rcv_nxt; in bbr_do_fastnewdata()
9492 tp = tcp_close(tp); in bbr_check_data_after_close()
9845 tp = tcp_close(tp); in bbr_do_lastack()
10348 tp->snd_nxt = tp->snd_max; in bbr_fini()
[all …]
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_thread_pool.c197 (void) ngx_thread_cond_destroy(&tp->cond, tp->log); in ngx_thread_pool_destroy()
199 (void) ngx_thread_mutex_destroy(&tp->mtx, tp->log); in ngx_thread_pool_destroy()
243 if (tp->waiting >= tp->max_queue) { in ngx_thread_task_post()
244 (void) ngx_thread_mutex_unlock(&tp->mtx, tp->log); in ngx_thread_task_post()
248 &tp->name, tp->waiting); in ngx_thread_task_post()
258 (void) ngx_thread_mutex_unlock(&tp->mtx, tp->log); in ngx_thread_task_post()
267 (void) ngx_thread_mutex_unlock(&tp->mtx, tp->log); in ngx_thread_task_post()
315 if (ngx_thread_cond_wait(&tp->cond, &tp->mtx, tp->log) in ngx_thread_pool_cycle()
327 tp->queue.last = &tp->queue.first; in ngx_thread_pool_cycle()
530 if (tp) { in ngx_thread_pool_add()
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/linux/spl/
H A Dspl-thread.c52 func = tp->tp_func; in thread_generic_wrapper()
53 args = tp->tp_args; in thread_generic_wrapper()
56 kmem_free(tp->tp_name, tp->tp_name_size); in thread_generic_wrapper()
83 thread_priv_t *tp; in __thread_create() local
92 if (tp == NULL) in __thread_create()
98 tp->tp_name = kmem_alloc(tp->tp_name_size, KM_PUSHPAGE); in __thread_create()
104 strncpy(tp->tp_name, name, tp->tp_name_size); in __thread_create()
114 tp->tp_func = func; in __thread_create()
115 tp->tp_args = args; in __thread_create()
116 tp->tp_len = len; in __thread_create()
[all …]
/f-stack/freebsd/amd64/ia32/
H A Dia32_reg.c81 struct trapframe *tp; in fill_regs32() local
83 tp = td->td_frame; in fill_regs32()
103 regs->r_cs = tp->tf_cs; in fill_regs32()
106 regs->r_ss = tp->tf_ss; in fill_regs32()
115 struct trapframe *tp; in set_regs32() local
117 tp = td->td_frame; in set_regs32()
120 tp->tf_gs = regs->r_gs; in set_regs32()
121 tp->tf_fs = regs->r_fs; in set_regs32()
122 tp->tf_es = regs->r_es; in set_regs32()
123 tp->tf_ds = regs->r_ds; in set_regs32()
[all …]
/f-stack/freebsd/libkern/
H A Dinet_pton.c83 *(tp = tmp) = 0; in inet_pton4()
90 if (saw_digit && *tp == 0) in inet_pton4()
94 *tp = new; in inet_pton4()
103 *++tp = 0; in inet_pton4()
140 endp = tp + NS_IN6ADDRSZ; in inet_pton6()
166 colonp = tp; in inet_pton6()
181 tp += NS_INADDRSZ; in inet_pton6()
198 const int n = tp - colonp; in inet_pton6()
201 if (tp == endp) in inet_pton6()
207 tp = endp; in inet_pton6()
[all …]
/f-stack/dpdk/app/test/
H A Dtest_meter.c113 struct rte_meter_trtcm_profile tp; in tm_test_trtcm_config() local
165 struct rte_meter_trtcm_rfc4115_profile tp; in tm_test_trtcm_rfc4115_config() local
265 struct rte_meter_trtcm_profile tp; in tm_test_trtcm_color_blind_check() local
272 if (rte_meter_trtcm_config(&tm, &tp) != 0) in tm_test_trtcm_color_blind_check()
276 &tm, &tp, time, TM_TEST_TRTCM_CBS_DF - 1) in tm_test_trtcm_color_blind_check()
283 if (rte_meter_trtcm_config(&tm, &tp) != 0) in tm_test_trtcm_color_blind_check()
287 &tm, &tp, time, TM_TEST_TRTCM_CBS_DF + 1) in tm_test_trtcm_color_blind_check()
293 if (rte_meter_trtcm_config(&tm, &tp) != 0) in tm_test_trtcm_color_blind_check()
297 &tm, &tp, time, TM_TEST_TRTCM_PBS_DF - 1) in tm_test_trtcm_color_blind_check()
304 if (rte_meter_trtcm_config(&tm, &tp) != 0) in tm_test_trtcm_color_blind_check()
[all …]

12345678