Lines Matching refs:tp
110 struct tcp_sock *tp = tcp_sk(sk); in send_flowc_wr() local
135 send_or_defer(sk, tp, skb, 0); in send_flowc_wr()
169 struct tcp_sock *tp; in send_tx_flowc_wr() local
172 tp = tcp_sk(sk); in send_tx_flowc_wr()
189 FLOWC_PARAM(SNDNXT, tp->snd_nxt); in send_tx_flowc_wr()
190 FLOWC_PARAM(RCVNXT, tp->rcv_nxt); in send_tx_flowc_wr()
192 FLOWC_PARAM(MSS, tp->mss_cache); in send_tx_flowc_wr()
195 if (SND_WSCALE(tp)) in send_tx_flowc_wr()
196 FLOWC_PARAM(RCV_SCALE, SND_WSCALE(tp)); in send_tx_flowc_wr()
599 struct tcp_sock *tp; in chtls_push_frames() local
607 tp = tcp_sk(sk); in chtls_push_frames()
643 flowclen16 = send_tx_flowc_wr(sk, 1, tp->snd_nxt, in chtls_push_frames()
644 tp->rcv_nxt); in chtls_push_frames()
684 tp->snd_nxt += len; in chtls_push_frames()
685 tp->lsndtime = tcp_jiffies32; in chtls_push_frames()
713 static void mark_urg(struct tcp_sock *tp, int flags, in mark_urg() argument
717 tp->snd_up = tp->write_seq; in mark_urg()
732 struct tcp_sock *tp = tcp_sk(sk); in should_push() local
746 (tp->nonagle & TCP_NAGLE_OFF); in should_push()
752 static bool corked(const struct tcp_sock *tp, int flags) in corked() argument
754 return (flags & MSG_MORE) || (tp->nonagle & TCP_NAGLE_CORK); in corked()
772 struct tcp_sock *tp = tcp_sk(sk); in chtls_tcp_push() local
774 mark_urg(tp, flags, skb); in chtls_tcp_push()
777 corked(tp, flags)) { in chtls_tcp_push()
822 struct tcp_sock *tp = tcp_sk(sk); in skb_entail() local
824 ULP_SKB_CB(skb)->seq = tp->write_seq; in skb_entail()
1011 struct tcp_sock *tp = tcp_sk(sk); in chtls_sendmsg() local
1183 tp->write_seq += copy; in chtls_sendmsg()
1190 if (corked(tp, flags) && in chtls_sendmsg()
1236 struct tcp_sock *tp; in chtls_sendpage() local
1239 tp = tcp_sk(sk); in chtls_sendpage()
1298 tp->write_seq += copy; in chtls_sendpage()
1303 if (corked(tp, flags) && in chtls_sendpage()
1342 struct tcp_sock *tp = tcp_sk(sk); in chtls_select_window() local
1343 unsigned int wnd = tp->rcv_wnd; in chtls_select_window()
1357 if (wnd > tp->rcv_wnd) { in chtls_select_window()
1358 tp->rcv_wup -= wnd - tp->rcv_wnd; in chtls_select_window()
1359 tp->rcv_wnd = wnd; in chtls_select_window()
1402 struct tcp_sock *tp; in chtls_cleanup_rbuf() local
1413 tp = tcp_sk(sk); in chtls_cleanup_rbuf()
1414 credits = tp->copied_seq - tp->rcv_wup; in chtls_cleanup_rbuf()
1422 must_send = credits + 16384 >= tp->rcv_wnd; in chtls_cleanup_rbuf()
1425 tp->rcv_wup += send_rx_credits(csk, credits); in chtls_cleanup_rbuf()
1435 struct tcp_sock *tp = tcp_sk(sk); in chtls_pt_recvmsg() local
1454 if (unlikely(tp->urg_data && in chtls_pt_recvmsg()
1455 tp->urg_seq == tp->copied_seq)) { in chtls_pt_recvmsg()
1541 if (unlikely(tp->urg_data)) { in chtls_pt_recvmsg()
1542 u32 urg_offset = tp->urg_seq - tp->copied_seq; in chtls_pt_recvmsg()
1549 tp->copied_seq++; in chtls_pt_recvmsg()
1586 if (tp->urg_data && after(tp->copied_seq, tp->urg_seq)) in chtls_pt_recvmsg()
1587 tp->urg_data = 0; in chtls_pt_recvmsg()
1592 tp->copied_seq += skb->len; in chtls_pt_recvmsg()
1596 tp->copied_seq += hws->rcvpld; in chtls_pt_recvmsg()
1621 struct tcp_sock *tp = tcp_sk(sk); in peekmsg() local
1630 peek_seq = tp->copied_seq; in peekmsg()
1633 if (unlikely(tp->urg_data && tp->urg_seq == peek_seq)) { in peekmsg()
1681 if (unlikely(peek_seq != tp->copied_seq)) { in peekmsg()
1685 peek_seq = tp->copied_seq; in peekmsg()
1697 if (unlikely(tp->urg_data)) { in peekmsg()
1698 u32 urg_offset = tp->urg_seq - peek_seq; in peekmsg()
1742 struct tcp_sock *tp = tcp_sk(sk); in chtls_recvmsg() local
1779 if (unlikely(tp->urg_data && tp->urg_seq == tp->copied_seq)) { in chtls_recvmsg()
1857 offset = tp->copied_seq - ULP_SKB_CB(skb)->seq; in chtls_recvmsg()
1862 if (unlikely(tp->urg_data)) { in chtls_recvmsg()
1863 u32 urg_offset = tp->urg_seq - tp->copied_seq; in chtls_recvmsg()
1869 tp->copied_seq++; in chtls_recvmsg()
1888 tp->copied_seq += avail; in chtls_recvmsg()
1893 if (tp->urg_data && after(tp->copied_seq, tp->urg_seq)) in chtls_recvmsg()
1894 tp->urg_data = 0; in chtls_recvmsg()