提交 2de979bd 编写于 作者: S Stephen Hemminger 提交者: David S. Miller

[TCP]: whitespace cleanup

Add whitespace around keywords.
Signed-off-by: NStephen Hemminger <shemminger@linux-foundation.org>
Signed-off-by: NDavid S. Miller <davem@davemloft.net>
上级 132adf54
...@@ -144,7 +144,7 @@ static void hybla_cong_avoid(struct sock *sk, u32 ack, u32 rtt, ...@@ -144,7 +144,7 @@ static void hybla_cong_avoid(struct sock *sk, u32 ack, u32 rtt,
ca->snd_cwnd_cents += odd; ca->snd_cwnd_cents += odd;
/* check when fractions goes >=128 and increase cwnd by 1. */ /* check when fractions goes >=128 and increase cwnd by 1. */
while(ca->snd_cwnd_cents >= 128) { while (ca->snd_cwnd_cents >= 128) {
tp->snd_cwnd++; tp->snd_cwnd++;
ca->snd_cwnd_cents -= 128; ca->snd_cwnd_cents -= 128;
tp->snd_cwnd_cnt = 0; tp->snd_cwnd_cnt = 0;
......
...@@ -578,7 +578,7 @@ static void tcp_rtt_estimator(struct sock *sk, const __u32 mrtt) ...@@ -578,7 +578,7 @@ static void tcp_rtt_estimator(struct sock *sk, const __u32 mrtt)
* does not matter how to _calculate_ it. Seems, it was trap * does not matter how to _calculate_ it. Seems, it was trap
* that VJ failed to avoid. 8) * that VJ failed to avoid. 8)
*/ */
if(m == 0) if (m == 0)
m = 1; m = 1;
if (tp->srtt != 0) { if (tp->srtt != 0) {
m -= (tp->srtt >> 3); /* m is now error in rtt est */ m -= (tp->srtt >> 3); /* m is now error in rtt est */
...@@ -1758,12 +1758,11 @@ static void tcp_mark_head_lost(struct sock *sk, struct tcp_sock *tp, ...@@ -1758,12 +1758,11 @@ static void tcp_mark_head_lost(struct sock *sk, struct tcp_sock *tp,
/* clear xmit_retransmit_queue hints /* clear xmit_retransmit_queue hints
* if this is beyond hint */ * if this is beyond hint */
if(tp->retransmit_skb_hint != NULL && if (tp->retransmit_skb_hint != NULL &&
before(TCP_SKB_CB(skb)->seq, before(TCP_SKB_CB(skb)->seq,
TCP_SKB_CB(tp->retransmit_skb_hint)->seq)) { TCP_SKB_CB(tp->retransmit_skb_hint)->seq))
tp->retransmit_skb_hint = NULL; tp->retransmit_skb_hint = NULL;
}
} }
} }
tcp_sync_left_out(tp); tcp_sync_left_out(tp);
...@@ -2441,7 +2440,7 @@ static int tcp_clean_rtx_queue(struct sock *sk, __s32 *seq_rtt_p) ...@@ -2441,7 +2440,7 @@ static int tcp_clean_rtx_queue(struct sock *sk, __s32 *seq_rtt_p)
if (sacked) { if (sacked) {
if (sacked & TCPCB_RETRANS) { if (sacked & TCPCB_RETRANS) {
if(sacked & TCPCB_SACKED_RETRANS) if (sacked & TCPCB_SACKED_RETRANS)
tp->retrans_out -= tcp_skb_pcount(skb); tp->retrans_out -= tcp_skb_pcount(skb);
acked |= FLAG_RETRANS_DATA_ACKED; acked |= FLAG_RETRANS_DATA_ACKED;
seq_rtt = -1; seq_rtt = -1;
...@@ -2840,7 +2839,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2840,7 +2839,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
ptr = (unsigned char *)(th + 1); ptr = (unsigned char *)(th + 1);
opt_rx->saw_tstamp = 0; opt_rx->saw_tstamp = 0;
while(length>0) { while (length > 0) {
int opcode=*ptr++; int opcode=*ptr++;
int opsize; int opsize;
...@@ -2856,9 +2855,9 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2856,9 +2855,9 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
return; return;
if (opsize > length) if (opsize > length)
return; /* don't parse partial options */ return; /* don't parse partial options */
switch(opcode) { switch (opcode) {
case TCPOPT_MSS: case TCPOPT_MSS:
if(opsize==TCPOLEN_MSS && th->syn && !estab) { if (opsize==TCPOLEN_MSS && th->syn && !estab) {
u16 in_mss = ntohs(get_unaligned((__be16 *)ptr)); u16 in_mss = ntohs(get_unaligned((__be16 *)ptr));
if (in_mss) { if (in_mss) {
if (opt_rx->user_mss && opt_rx->user_mss < in_mss) if (opt_rx->user_mss && opt_rx->user_mss < in_mss)
...@@ -2868,12 +2867,12 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2868,12 +2867,12 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
} }
break; break;
case TCPOPT_WINDOW: case TCPOPT_WINDOW:
if(opsize==TCPOLEN_WINDOW && th->syn && !estab) if (opsize==TCPOLEN_WINDOW && th->syn && !estab)
if (sysctl_tcp_window_scaling) { if (sysctl_tcp_window_scaling) {
__u8 snd_wscale = *(__u8 *) ptr; __u8 snd_wscale = *(__u8 *) ptr;
opt_rx->wscale_ok = 1; opt_rx->wscale_ok = 1;
if (snd_wscale > 14) { if (snd_wscale > 14) {
if(net_ratelimit()) if (net_ratelimit())
printk(KERN_INFO "tcp_parse_options: Illegal window " printk(KERN_INFO "tcp_parse_options: Illegal window "
"scaling value %d >14 received.\n", "scaling value %d >14 received.\n",
snd_wscale); snd_wscale);
...@@ -2883,7 +2882,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2883,7 +2882,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
} }
break; break;
case TCPOPT_TIMESTAMP: case TCPOPT_TIMESTAMP:
if(opsize==TCPOLEN_TIMESTAMP) { if (opsize==TCPOLEN_TIMESTAMP) {
if ((estab && opt_rx->tstamp_ok) || if ((estab && opt_rx->tstamp_ok) ||
(!estab && sysctl_tcp_timestamps)) { (!estab && sysctl_tcp_timestamps)) {
opt_rx->saw_tstamp = 1; opt_rx->saw_tstamp = 1;
...@@ -2893,7 +2892,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2893,7 +2892,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
} }
break; break;
case TCPOPT_SACK_PERM: case TCPOPT_SACK_PERM:
if(opsize==TCPOLEN_SACK_PERM && th->syn && !estab) { if (opsize==TCPOLEN_SACK_PERM && th->syn && !estab) {
if (sysctl_tcp_sack) { if (sysctl_tcp_sack) {
opt_rx->sack_ok = 1; opt_rx->sack_ok = 1;
tcp_sack_reset(opt_rx); tcp_sack_reset(opt_rx);
...@@ -2902,7 +2901,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx, ...@@ -2902,7 +2901,7 @@ void tcp_parse_options(struct sk_buff *skb, struct tcp_options_received *opt_rx,
break; break;
case TCPOPT_SACK: case TCPOPT_SACK:
if((opsize >= (TCPOLEN_SACK_BASE + TCPOLEN_SACK_PERBLOCK)) && if ((opsize >= (TCPOLEN_SACK_BASE + TCPOLEN_SACK_PERBLOCK)) &&
!((opsize - TCPOLEN_SACK_BASE) % TCPOLEN_SACK_PERBLOCK) && !((opsize - TCPOLEN_SACK_BASE) % TCPOLEN_SACK_PERBLOCK) &&
opt_rx->sack_ok) { opt_rx->sack_ok) {
TCP_SKB_CB(skb)->sacked = (ptr - 2) - (unsigned char *)th; TCP_SKB_CB(skb)->sacked = (ptr - 2) - (unsigned char *)th;
...@@ -2964,7 +2963,7 @@ static inline void tcp_replace_ts_recent(struct tcp_sock *tp, u32 seq) ...@@ -2964,7 +2963,7 @@ static inline void tcp_replace_ts_recent(struct tcp_sock *tp, u32 seq)
* Not only, also it occurs for expired timestamps. * Not only, also it occurs for expired timestamps.
*/ */
if((s32)(tp->rx_opt.rcv_tsval - tp->rx_opt.ts_recent) >= 0 || if ((s32)(tp->rx_opt.rcv_tsval - tp->rx_opt.ts_recent) >= 0 ||
get_seconds() >= tp->rx_opt.ts_recent_stamp + TCP_PAWS_24DAYS) get_seconds() >= tp->rx_opt.ts_recent_stamp + TCP_PAWS_24DAYS)
tcp_store_ts_recent(tp); tcp_store_ts_recent(tp);
} }
...@@ -3223,7 +3222,7 @@ static void tcp_sack_maybe_coalesce(struct tcp_sock *tp) ...@@ -3223,7 +3222,7 @@ static void tcp_sack_maybe_coalesce(struct tcp_sock *tp)
*/ */
tp->rx_opt.num_sacks--; tp->rx_opt.num_sacks--;
tp->rx_opt.eff_sacks = min(tp->rx_opt.num_sacks + tp->rx_opt.dsack, 4 - tp->rx_opt.tstamp_ok); tp->rx_opt.eff_sacks = min(tp->rx_opt.num_sacks + tp->rx_opt.dsack, 4 - tp->rx_opt.tstamp_ok);
for(i=this_sack; i < tp->rx_opt.num_sacks; i++) for (i=this_sack; i < tp->rx_opt.num_sacks; i++)
sp[i] = sp[i+1]; sp[i] = sp[i+1];
continue; continue;
} }
...@@ -3276,7 +3275,7 @@ static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq) ...@@ -3276,7 +3275,7 @@ static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq)
tp->rx_opt.num_sacks--; tp->rx_opt.num_sacks--;
sp--; sp--;
} }
for(; this_sack > 0; this_sack--, sp--) for (; this_sack > 0; this_sack--, sp--)
*sp = *(sp-1); *sp = *(sp-1);
new_sack: new_sack:
...@@ -3302,7 +3301,7 @@ static void tcp_sack_remove(struct tcp_sock *tp) ...@@ -3302,7 +3301,7 @@ static void tcp_sack_remove(struct tcp_sock *tp)
return; return;
} }
for(this_sack = 0; this_sack < num_sacks; ) { for (this_sack = 0; this_sack < num_sacks; ) {
/* Check if the start of the sack is covered by RCV.NXT. */ /* Check if the start of the sack is covered by RCV.NXT. */
if (!before(tp->rcv_nxt, sp->start_seq)) { if (!before(tp->rcv_nxt, sp->start_seq)) {
int i; int i;
...@@ -3358,7 +3357,7 @@ static void tcp_ofo_queue(struct sock *sk) ...@@ -3358,7 +3357,7 @@ static void tcp_ofo_queue(struct sock *sk)
__skb_unlink(skb, &tp->out_of_order_queue); __skb_unlink(skb, &tp->out_of_order_queue);
__skb_queue_tail(&sk->sk_receive_queue, skb); __skb_queue_tail(&sk->sk_receive_queue, skb);
tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq;
if(skb->h.th->fin) if (skb->h.th->fin)
tcp_fin(skb, sk, skb->h.th); tcp_fin(skb, sk, skb->h.th);
} }
} }
...@@ -3424,9 +3423,9 @@ queue_and_out: ...@@ -3424,9 +3423,9 @@ queue_and_out:
__skb_queue_tail(&sk->sk_receive_queue, skb); __skb_queue_tail(&sk->sk_receive_queue, skb);
} }
tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq;
if(skb->len) if (skb->len)
tcp_event_data_recv(sk, tp, skb); tcp_event_data_recv(sk, tp, skb);
if(th->fin) if (th->fin)
tcp_fin(skb, sk, th); tcp_fin(skb, sk, th);
if (!skb_queue_empty(&tp->out_of_order_queue)) { if (!skb_queue_empty(&tp->out_of_order_queue)) {
...@@ -4323,7 +4322,7 @@ slow_path: ...@@ -4323,7 +4322,7 @@ slow_path:
goto discard; goto discard;
} }
if(th->rst) { if (th->rst) {
tcp_reset(sk); tcp_reset(sk);
goto discard; goto discard;
} }
...@@ -4338,7 +4337,7 @@ slow_path: ...@@ -4338,7 +4337,7 @@ slow_path:
} }
step5: step5:
if(th->ack) if (th->ack)
tcp_ack(sk, skb, FLAG_SLOWPATH); tcp_ack(sk, skb, FLAG_SLOWPATH);
tcp_rcv_rtt_measure_ts(sk, skb); tcp_rcv_rtt_measure_ts(sk, skb);
...@@ -4626,13 +4625,13 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb, ...@@ -4626,13 +4625,13 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb,
goto discard; goto discard;
case TCP_LISTEN: case TCP_LISTEN:
if(th->ack) if (th->ack)
return 1; return 1;
if(th->rst) if (th->rst)
goto discard; goto discard;
if(th->syn) { if (th->syn) {
if (icsk->icsk_af_ops->conn_request(sk, skb) < 0) if (icsk->icsk_af_ops->conn_request(sk, skb) < 0)
return 1; return 1;
...@@ -4688,7 +4687,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb, ...@@ -4688,7 +4687,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb,
} }
/* step 2: check RST bit */ /* step 2: check RST bit */
if(th->rst) { if (th->rst) {
tcp_reset(sk); tcp_reset(sk);
goto discard; goto discard;
} }
...@@ -4711,7 +4710,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb, ...@@ -4711,7 +4710,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb,
if (th->ack) { if (th->ack) {
int acceptable = tcp_ack(sk, skb, FLAG_SLOWPATH); int acceptable = tcp_ack(sk, skb, FLAG_SLOWPATH);
switch(sk->sk_state) { switch (sk->sk_state) {
case TCP_SYN_RECV: case TCP_SYN_RECV:
if (acceptable) { if (acceptable) {
tp->copied_seq = tp->rcv_nxt; tp->copied_seq = tp->rcv_nxt;
......
...@@ -246,7 +246,7 @@ kill: ...@@ -246,7 +246,7 @@ kill:
if (paws_reject) if (paws_reject)
NET_INC_STATS_BH(LINUX_MIB_PAWSESTABREJECTED); NET_INC_STATS_BH(LINUX_MIB_PAWSESTABREJECTED);
if(!th->rst) { if (!th->rst) {
/* In this case we must reset the TIMEWAIT timer. /* In this case we must reset the TIMEWAIT timer.
* *
* If it is ACKless SYN it may be both old duplicate * If it is ACKless SYN it may be both old duplicate
...@@ -324,7 +324,7 @@ void tcp_time_wait(struct sock *sk, int state, int timeo) ...@@ -324,7 +324,7 @@ void tcp_time_wait(struct sock *sk, int state, int timeo)
if (tcp_alloc_md5sig_pool() == NULL) if (tcp_alloc_md5sig_pool() == NULL)
BUG(); BUG();
} }
} while(0); } while (0);
#endif #endif
/* Linkage updates. */ /* Linkage updates. */
...@@ -438,7 +438,7 @@ struct sock *tcp_create_openreq_child(struct sock *sk, struct request_sock *req, ...@@ -438,7 +438,7 @@ struct sock *tcp_create_openreq_child(struct sock *sk, struct request_sock *req,
keepalive_time_when(newtp)); keepalive_time_when(newtp));
newtp->rx_opt.tstamp_ok = ireq->tstamp_ok; newtp->rx_opt.tstamp_ok = ireq->tstamp_ok;
if((newtp->rx_opt.sack_ok = ireq->sack_ok) != 0) { if ((newtp->rx_opt.sack_ok = ireq->sack_ok) != 0) {
if (sysctl_tcp_fack) if (sysctl_tcp_fack)
newtp->rx_opt.sack_ok |= 2; newtp->rx_opt.sack_ok |= 2;
} }
......
...@@ -236,7 +236,7 @@ static u16 tcp_select_window(struct sock *sk) ...@@ -236,7 +236,7 @@ static u16 tcp_select_window(struct sock *sk)
u32 new_win = __tcp_select_window(sk); u32 new_win = __tcp_select_window(sk);
/* Never shrink the offered window */ /* Never shrink the offered window */
if(new_win < cur_win) { if (new_win < cur_win) {
/* Danger Will Robinson! /* Danger Will Robinson!
* Don't update rcv_wup/rcv_wnd here or else * Don't update rcv_wup/rcv_wnd here or else
* we will not be able to advertise a zero * we will not be able to advertise a zero
...@@ -287,10 +287,12 @@ static void tcp_build_and_update_options(__be32 *ptr, struct tcp_sock *tp, ...@@ -287,10 +287,12 @@ static void tcp_build_and_update_options(__be32 *ptr, struct tcp_sock *tp,
(TCPOPT_SACK << 8) | (TCPOPT_SACK << 8) |
(TCPOLEN_SACK_BASE + (tp->rx_opt.eff_sacks * (TCPOLEN_SACK_BASE + (tp->rx_opt.eff_sacks *
TCPOLEN_SACK_PERBLOCK))); TCPOLEN_SACK_PERBLOCK)));
for(this_sack = 0; this_sack < tp->rx_opt.eff_sacks; this_sack++) {
for (this_sack = 0; this_sack < tp->rx_opt.eff_sacks; this_sack++) {
*ptr++ = htonl(sp[this_sack].start_seq); *ptr++ = htonl(sp[this_sack].start_seq);
*ptr++ = htonl(sp[this_sack].end_seq); *ptr++ = htonl(sp[this_sack].end_seq);
} }
if (tp->rx_opt.dsack) { if (tp->rx_opt.dsack) {
tp->rx_opt.dsack = 0; tp->rx_opt.dsack = 0;
tp->rx_opt.eff_sacks--; tp->rx_opt.eff_sacks--;
...@@ -335,7 +337,7 @@ static void tcp_syn_build_options(__be32 *ptr, int mss, int ts, int sack, ...@@ -335,7 +337,7 @@ static void tcp_syn_build_options(__be32 *ptr, int mss, int ts, int sack,
*/ */
*ptr++ = htonl((TCPOPT_MSS << 24) | (TCPOLEN_MSS << 16) | mss); *ptr++ = htonl((TCPOPT_MSS << 24) | (TCPOLEN_MSS << 16) | mss);
if (ts) { if (ts) {
if(sack) if (sack)
*ptr++ = htonl((TCPOPT_SACK_PERM << 24) | *ptr++ = htonl((TCPOPT_SACK_PERM << 24) |
(TCPOLEN_SACK_PERM << 16) | (TCPOLEN_SACK_PERM << 16) |
(TCPOPT_TIMESTAMP << 8) | (TCPOPT_TIMESTAMP << 8) |
...@@ -347,7 +349,7 @@ static void tcp_syn_build_options(__be32 *ptr, int mss, int ts, int sack, ...@@ -347,7 +349,7 @@ static void tcp_syn_build_options(__be32 *ptr, int mss, int ts, int sack,
TCPOLEN_TIMESTAMP); TCPOLEN_TIMESTAMP);
*ptr++ = htonl(tstamp); /* TSVAL */ *ptr++ = htonl(tstamp); /* TSVAL */
*ptr++ = htonl(ts_recent); /* TSECR */ *ptr++ = htonl(ts_recent); /* TSECR */
} else if(sack) } else if (sack)
*ptr++ = htonl((TCPOPT_NOP << 24) | *ptr++ = htonl((TCPOPT_NOP << 24) |
(TCPOPT_NOP << 16) | (TCPOPT_NOP << 16) |
(TCPOPT_SACK_PERM << 8) | (TCPOPT_SACK_PERM << 8) |
...@@ -428,7 +430,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it, ...@@ -428,7 +430,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
sysctl_flags = 0; sysctl_flags = 0;
if (unlikely(tcb->flags & TCPCB_FLAG_SYN)) { if (unlikely(tcb->flags & TCPCB_FLAG_SYN)) {
tcp_header_size = sizeof(struct tcphdr) + TCPOLEN_MSS; tcp_header_size = sizeof(struct tcphdr) + TCPOLEN_MSS;
if(sysctl_tcp_timestamps) { if (sysctl_tcp_timestamps) {
tcp_header_size += TCPOLEN_TSTAMP_ALIGNED; tcp_header_size += TCPOLEN_TSTAMP_ALIGNED;
sysctl_flags |= SYSCTL_FLAG_TSTAMPS; sysctl_flags |= SYSCTL_FLAG_TSTAMPS;
} }
...@@ -1618,7 +1620,7 @@ static void tcp_retrans_try_collapse(struct sock *sk, struct sk_buff *skb, int m ...@@ -1618,7 +1620,7 @@ static void tcp_retrans_try_collapse(struct sock *sk, struct sk_buff *skb, int m
u16 flags = TCP_SKB_CB(skb)->flags; u16 flags = TCP_SKB_CB(skb)->flags;
/* Also punt if next skb has been SACK'd. */ /* Also punt if next skb has been SACK'd. */
if(TCP_SKB_CB(next_skb)->sacked & TCPCB_SACKED_ACKED) if (TCP_SKB_CB(next_skb)->sacked & TCPCB_SACKED_ACKED)
return; return;
/* Next skb is out of window. */ /* Next skb is out of window. */
...@@ -1778,13 +1780,13 @@ int tcp_retransmit_skb(struct sock *sk, struct sk_buff *skb) ...@@ -1778,13 +1780,13 @@ int tcp_retransmit_skb(struct sock *sk, struct sk_buff *skb)
} }
/* Collapse two adjacent packets if worthwhile and we can. */ /* Collapse two adjacent packets if worthwhile and we can. */
if(!(TCP_SKB_CB(skb)->flags & TCPCB_FLAG_SYN) && if (!(TCP_SKB_CB(skb)->flags & TCPCB_FLAG_SYN) &&
(skb->len < (cur_mss >> 1)) && (skb->len < (cur_mss >> 1)) &&
(tcp_write_queue_next(sk, skb) != tcp_send_head(sk)) && (tcp_write_queue_next(sk, skb) != tcp_send_head(sk)) &&
(!tcp_skb_is_last(sk, skb)) && (!tcp_skb_is_last(sk, skb)) &&
(skb_shinfo(skb)->nr_frags == 0 && skb_shinfo(tcp_write_queue_next(sk, skb))->nr_frags == 0) && (skb_shinfo(skb)->nr_frags == 0 && skb_shinfo(tcp_write_queue_next(sk, skb))->nr_frags == 0) &&
(tcp_skb_pcount(skb) == 1 && tcp_skb_pcount(tcp_write_queue_next(sk, skb)) == 1) && (tcp_skb_pcount(skb) == 1 && tcp_skb_pcount(tcp_write_queue_next(sk, skb)) == 1) &&
(sysctl_tcp_retrans_collapse != 0)) (sysctl_tcp_retrans_collapse != 0))
tcp_retrans_try_collapse(sk, skb, cur_mss); tcp_retrans_try_collapse(sk, skb, cur_mss);
if (inet_csk(sk)->icsk_af_ops->rebuild_header(sk)) if (inet_csk(sk)->icsk_af_ops->rebuild_header(sk))
...@@ -1794,9 +1796,9 @@ int tcp_retransmit_skb(struct sock *sk, struct sk_buff *skb) ...@@ -1794,9 +1796,9 @@ int tcp_retransmit_skb(struct sock *sk, struct sk_buff *skb)
* retransmit when old data is attached. So strip it off * retransmit when old data is attached. So strip it off
* since it is cheap to do so and saves bytes on the network. * since it is cheap to do so and saves bytes on the network.
*/ */
if(skb->len > 0 && if (skb->len > 0 &&
(TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN) && (TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN) &&
tp->snd_una == (TCP_SKB_CB(skb)->end_seq - 1)) { tp->snd_una == (TCP_SKB_CB(skb)->end_seq - 1)) {
if (!pskb_trim(skb, 0)) { if (!pskb_trim(skb, 0)) {
TCP_SKB_CB(skb)->seq = TCP_SKB_CB(skb)->end_seq - 1; TCP_SKB_CB(skb)->seq = TCP_SKB_CB(skb)->end_seq - 1;
skb_shinfo(skb)->gso_segs = 1; skb_shinfo(skb)->gso_segs = 1;
......
...@@ -226,7 +226,7 @@ static void tcp_westwood_event(struct sock *sk, enum tcp_ca_event event) ...@@ -226,7 +226,7 @@ static void tcp_westwood_event(struct sock *sk, enum tcp_ca_event event)
struct tcp_sock *tp = tcp_sk(sk); struct tcp_sock *tp = tcp_sk(sk);
struct westwood *w = inet_csk_ca(sk); struct westwood *w = inet_csk_ca(sk);
switch(event) { switch (event) {
case CA_EVENT_FAST_ACK: case CA_EVENT_FAST_ACK:
westwood_fast_bw(sk); westwood_fast_bw(sk);
break; break;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册