/linux-4.1.27/net/ipv4/ |
H A D | tcp_westwood.c | 36 u32 snd_una; /* used for evaluating the number of acked bytes */ member in struct:westwood 72 w->snd_una = tcp_sk(sk)->snd_una; tcp_westwood_init() 120 /* Initialize w->snd_una with the first acked sequence number in order westwood_update_window() 121 * to fix mismatch between tp->snd_una and w->snd_una for the first westwood_update_window() 125 w->snd_una = tcp_sk(sk)->snd_una; westwood_update_window() 168 w->bk += tp->snd_una - w->snd_una; westwood_fast_bw() 169 w->snd_una = tp->snd_una; westwood_fast_bw() 183 w->cumul_ack = tp->snd_una - w->snd_una; westwood_acked_count() 186 * tp->snd_una. westwood_acked_count() 204 w->snd_una = tp->snd_una; westwood_acked_count()
|
H A D | tcp_diag.c | 30 r->idiag_wqueue = tp->write_seq - tp->snd_una; tcp_diag_get_info()
|
H A D | tcp_probe.c | 68 u32 snd_una; member in struct:tcp_log 150 p->snd_una = tp->snd_una; jtcp_rcv_established() 197 &p->src, &p->dst, p->length, p->snd_nxt, p->snd_una, tcpprobe_sprint()
|
H A D | tcp_dctcp.c | 93 ca->prior_snd_una = tp->snd_una; dctcp_init() 190 u32 acked_bytes = tp->snd_una - ca->prior_snd_una; dctcp_update_alpha() 192 /* If ack did not advance snd_una, count dupack as MSS size. dctcp_update_alpha() 199 ca->prior_snd_una = tp->snd_una; dctcp_update_alpha() 206 if (!before(tp->snd_una, ca->next_seq)) { dctcp_update_alpha()
|
H A D | tcp_input.c | 116 #define FLAG_SACK_RENEGING 0x2000 /* snd_una advanced to a sacked seq */ 730 if (after(tp->snd_una, tp->rtt_seq)) { tcp_rtt_estimator() 978 * snd_nxt wrap -> snd_una region will then become "well defined", i.e., 983 * again, D-SACK block must not to go across snd_una (for the same reason as 1006 * start_seq == snd_una is non-sensical (see comments above) tcp_is_sackblock_valid() 1008 if (after(start_seq, tp->snd_una)) tcp_is_sackblock_valid() 1014 /* ...Then it's D-SACK, and must reside below snd_una completely */ tcp_is_sackblock_valid() 1015 if (after(end_seq, tp->snd_una)) tcp_is_sackblock_valid() 1061 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) tcp_for_write_queue() 1211 if (!after(end_seq, tp->snd_una)) tcp_sacktag_one() 1402 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) tcp_shift_skb_data() 1478 /* tcp_sacktag_one() won't SACK-tag ranges below snd_una */ tcp_shift_skb_data() 1479 if (!after(TCP_SKB_CB(skb)->seq + len, tp->snd_una)) tcp_shift_skb_data() 1698 if ((TCP_SKB_CB(ack_skb)->ack_seq != tp->snd_una) && tcp_sacktag_write_queue() 1699 !after(sp[used_sacks].end_seq, tp->snd_una)) tcp_sacktag_write_queue() 1913 tp->undo_marker = tp->snd_una; tcp_init_undo() 1932 !after(tp->high_seq, tp->snd_una) || tcp_enter_loss() 2437 if (tp->snd_una == tp->high_seq && tcp_is_reno(tp)) { tcp_try_undo_recovery() 2699 bool recovered = !before(tp->snd_una, tp->high_seq); tcp_process_loss() 2820 } else if (!before(tp->snd_una, tp->high_seq)) { tcp_fastretrans_alert() 2825 if (tp->snd_una != tp->high_seq) { tcp_fastretrans_alert() 2883 tp->snd_una == tp->mtu_probe.probe_seq_start) { tcp_fastretrans_alert() 3023 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)); tcp_tso_acked() 3026 if (tcp_trim_head(sk, skb, tp->snd_una - TCP_SKB_CB(skb)->seq)) tcp_tso_acked() 3049 between(shinfo->tskey, prior_snd_una, tcp_sk(sk)->snd_una - 1)) tcp_ack_tstamp() 3083 if (after(scb->end_seq, tp->snd_una)) { tcp_clean_rtx_queue() 3085 !after(tp->snd_una, scb->seq)) tcp_clean_rtx_queue() 3147 if (likely(between(tp->snd_up, prior_snd_una, tp->snd_una))) tcp_clean_rtx_queue() 3148 tp->snd_up = tp->snd_una; tcp_clean_rtx_queue() 3167 !after(tp->mtu_probe.probe_seq_end, tp->snd_una))) { tcp_clean_rtx_queue() 3273 * The function assumes that snd_una<=ack<=snd_next. 3279 return after(ack, tp->snd_una) || tcp_may_update_window() 3284 /* If we update tp->snd_una, also update tp->bytes_acked */ tcp_snd_una_update() 3287 u32 delta = ack - tp->snd_una; tcp_snd_una_update() 3292 tp->snd_una = ack; tcp_snd_una_update() 3469 u32 prior_snd_una = tp->snd_una; tcp_ack() 3609 SOCK_DEBUG(sk, "Ack %u after %u:%u\n", ack, tp->snd_una, tp->snd_nxt); tcp_ack() 3623 SOCK_DEBUG(sk, "Ack %u before %u:%u\n", ack, tp->snd_una, tp->snd_nxt); tcp_ack() 3875 ack == tp->snd_una && tcp_disordered_ack() 4473 TCP_SKB_CB(skb)->ack_seq = tcp_sk(sk)->snd_una - 1; tcp_send_rcvq() 5319 if (TCP_SKB_CB(skb)->ack_seq != tp->snd_una) { tcp_rcv_established() 5490 if (!after(TCP_SKB_CB(skb)->ack_seq, tp->snd_una) || tcp_rcv_synsent_state_process() 5812 tp->snd_una = TCP_SKB_CB(skb)->ack_seq; tcp_rcv_state_process() 5864 if (tp->snd_una != tp->write_seq) tcp_rcv_state_process() 5907 if (tp->snd_una == tp->write_seq) { tcp_rcv_state_process() 5914 if (tp->snd_una == tp->write_seq) { tcp_rcv_state_process()
|
H A D | tcp_yeah.c | 101 * of snd_una and snd_nxt at the beginning of the current RTT. More tcp_yeah_cong_avoid() 110 * Unfortunately, v_vegas.beg_snd_una is not exactly equal to snd_una, tcp_yeah_cong_avoid()
|
H A D | tcp_ipv4.c | 369 __u32 seq, snd_una; tcp_v4_err() local 409 /* XXX (TFO) - tp->snd_una should be ISN (tcp_create_openreq_child() */ tcp_v4_err() 411 snd_una = fastopen ? tcp_rsk(fastopen)->snt_isn : tp->snd_una; tcp_v4_err() 413 !between(seq, snd_una, tp->snd_nxt)) { tcp_v4_err() 455 if (seq != tp->snd_una || !icsk->icsk_retransmits || tcp_v4_err() 2228 tp->write_seq - tp->snd_una, get_tcp4_sock()
|
H A D | tcp_output.c | 416 return tp->snd_una != tp->snd_up; tcp_urg_mode() 985 /* The urg_mode check is necessary during a below snd_una win probe */ tcp_transmit_skb() 1482 if (!before(tp->snd_una, tp->max_packets_seq) || tcp_cwnd_validate() 1507 return after(tp->snd_sml, tp->snd_una) && tcp_minshall_check() 2583 if (before(TCP_SKB_CB(skb)->seq, tp->snd_una)) { __tcp_retransmit_skb() 2584 if (before(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) __tcp_retransmit_skb() 2586 if (tcp_trim_head(sk, skb, tp->snd_una - TCP_SKB_CB(skb)->seq)) __tcp_retransmit_skb() 2601 TCP_SKB_CB(skb)->seq != tp->snd_una) __tcp_retransmit_skb() 2735 tp->retransmit_high = tp->snd_una; tcp_xmit_retransmit_queue() 2744 last_lost = tp->snd_una; tcp_xmit_retransmit_queue() 3104 tp->snd_una = tp->write_seq; tcp_connect_init() 3403 tcp_init_nondata_skb(skb, tp->snd_una - !urgent, TCPHDR_ACK); tcp_xmit_probe_skb() 3453 if (between(tp->snd_up, tp->snd_una + 1, tp->snd_una + 0xFFFF)) tcp_write_wakeup()
|
H A D | tcp_timer.c | 397 tp->snd_una, tp->snd_nxt); tcp_retransmit_timer() 405 tp->snd_una, tp->snd_nxt); tcp_retransmit_timer()
|
H A D | tcp_minisocks.c | 454 newtp->snd_sml = newtp->snd_una = tcp_create_openreq_child()
|
H A D | tcp.c | 586 answ = tp->write_seq - tp->snd_una; tcp_ioctl()
|
/linux-4.1.27/include/linux/ |
H A D | tcp.h | 158 * sum(delta(snd_una)), or how many bytes 163 u32 snd_una; /* First byte we want an ack for */ member in struct:tcp_sock 284 u32 undo_marker; /* snd_una upon a new recovery episode. */
|
/linux-4.1.27/drivers/scsi/cxgbi/ |
H A D | libcxgbi.c | 802 csk->write_seq = csk->snd_nxt = csk->snd_una = snd_isn; cxgbi_sock_established() 963 csk->snd_una = snd_nxt - 1; cxgbi_sock_rcv_close_conn_rpl() 988 unsigned int snd_una, int seq_chk) cxgbi_sock_rcv_wr_ack() 991 "csk 0x%p,%u,0x%lx,%u, cr %u,%u+%u, snd_una %u,%d.\n", cxgbi_sock_rcv_wr_ack() 993 csk->wr_cred, csk->wr_una_cred, snd_una, seq_chk); cxgbi_sock_rcv_wr_ack() 1028 if (unlikely(before(snd_una, csk->snd_una))) { cxgbi_sock_rcv_wr_ack() 1029 pr_warn("csk 0x%p,%u,0x%lx,%u, snd_una %u/%u.", cxgbi_sock_rcv_wr_ack() 1030 csk, csk->state, csk->flags, csk->tid, snd_una, cxgbi_sock_rcv_wr_ack() 1031 csk->snd_una); cxgbi_sock_rcv_wr_ack() 1035 if (csk->snd_una != snd_una) { cxgbi_sock_rcv_wr_ack() 1036 csk->snd_una = snd_una; cxgbi_sock_rcv_wr_ack() 1129 if (csk->write_seq - csk->snd_una >= cdev->snd_win) { cxgbi_sock_send_pdus() 1133 csk->snd_una, cdev->snd_win); cxgbi_sock_send_pdus() 987 cxgbi_sock_rcv_wr_ack(struct cxgbi_sock *csk, unsigned int credits, unsigned int snd_una, int seq_chk) cxgbi_sock_rcv_wr_ack() argument
|
H A D | libcxgbi.h | 235 u32 snd_una; member in struct:cxgbi_sock
|
/linux-4.1.27/drivers/infiniband/hw/nes/ |
H A D | nes_context.h | 61 __le32 snd_una; member in struct:nes_qp_context
|
H A D | nes_cm.c | 2963 nesqp->nesqp_context->snd_una = cpu_to_le32(cm_node->tcp_cntxt.loc_seq_num); nes_cm_init_tsa_conn()
|
/linux-4.1.27/net/ipv6/ |
H A D | tcp_ipv6.c | 332 __u32 seq, snd_una; tcp_v6_err() local 368 /* XXX (TFO) - tp->snd_una should be ISN (tcp_create_openreq_child() */ tcp_v6_err() 370 snd_una = fastopen ? tcp_rsk(fastopen)->snt_isn : tp->snd_una; tcp_v6_err() 372 !between(seq, snd_una, tp->snd_nxt)) { tcp_v6_err() 1717 tp->write_seq-tp->snd_una, get_tcp6_sock()
|
/linux-4.1.27/net/rds/ |
H A D | tcp.c | 91 return tcp_sk(tc->t_sock->sk)->snd_una; rds_tcp_snd_una()
|
/linux-4.1.27/drivers/net/ethernet/chelsio/cxgb4/ |
H A D | t4_msg.h | 1000 __be32 snd_una; member in struct:cpl_fw4_ack
|
/linux-4.1.27/drivers/block/drbd/ |
H A D | drbd_debugfs.c | 397 answ = tp->write_seq - tp->snd_una; in_flight_summary_show()
|
/linux-4.1.27/drivers/scsi/cxgbi/cxgb3i/ |
H A D | cxgb3i.c | 844 * Process an acknowledgment of WR completion. Advance snd_una and send the 856 cxgbi_sock_rcv_wr_ack(csk, ntohs(hdr->credits), ntohl(hdr->snd_una), 1); do_wr_ack()
|
/linux-4.1.27/include/net/ |
H A D | tcp.h | 1019 return tp->snd_una + tp->snd_wnd; tcp_wnd_end() 1512 return tp->snd_una; tcp_highest_sack_seq()
|
/linux-4.1.27/drivers/net/ethernet/chelsio/cxgb3/ |
H A D | t3_cpl.h | 875 __be32 snd_una; member in struct:cpl_wr_ack
|
/linux-4.1.27/drivers/scsi/cxgbi/cxgb4i/ |
H A D | cxgb4i.c | 1262 cxgbi_sock_rcv_wr_ack(csk, rpl->credits, ntohl(rpl->snd_una), do_fw4_ack()
|
/linux-4.1.27/drivers/net/ethernet/broadcom/ |
H A D | cnic_defs.h | 946 u32 snd_una; member in struct:tstorm_tcp_tcp_ag_context_section 1751 u32 snd_una; member in struct:xstorm_tcp_tcp_ag_context_section
|
/linux-4.1.27/net/core/ |
H A D | sock.c | 868 sk->sk_tskey = tcp_sk(sk)->snd_una; sock_setsockopt()
|