提交 593f16aa 编写于 作者: A Andrea Bittau 提交者: David S. Miller

[DCCP] CCID2: Add helper functions for changing important CCID2 state

Introduce methods which manipulate interesting congestion control
state such as pipe and rtt estimate.  This is useful for people
wishing to monitor the variables of CCID and instrument the code
[perhaps using Kprobes].  Personally, I am a fan of
encapsulation---that justifies this change =D.
Signed-off-by: NAndrea Bittau <a.bittau@cs.ucl.ac.uk>
Signed-off-by: NArnaldo Carvalho de Melo <acme@mandriva.com>
Signed-off-by: NDavid S. Miller <davem@davemloft.net>
上级 374bcf32
...@@ -199,6 +199,17 @@ static void ccid2_change_cwnd(struct ccid2_hc_tx_sock *hctx, int val) ...@@ -199,6 +199,17 @@ static void ccid2_change_cwnd(struct ccid2_hc_tx_sock *hctx, int val)
hctx->ccid2hctx_cwnd = val; hctx->ccid2hctx_cwnd = val;
} }
static void ccid2_change_srtt(struct ccid2_hc_tx_sock *hctx, long val)
{
ccid2_pr_debug("change SRTT to %ld\n", val);
hctx->ccid2hctx_srtt = val;
}
static void ccid2_change_pipe(struct ccid2_hc_tx_sock *hctx, long val)
{
hctx->ccid2hctx_pipe = val;
}
static void ccid2_start_rto_timer(struct sock *sk); static void ccid2_start_rto_timer(struct sock *sk);
static void ccid2_hc_tx_rto_expire(unsigned long data) static void ccid2_hc_tx_rto_expire(unsigned long data)
...@@ -228,7 +239,7 @@ static void ccid2_hc_tx_rto_expire(unsigned long data) ...@@ -228,7 +239,7 @@ static void ccid2_hc_tx_rto_expire(unsigned long data)
ccid2_start_rto_timer(sk); ccid2_start_rto_timer(sk);
/* adjust pipe, cwnd etc */ /* adjust pipe, cwnd etc */
hctx->ccid2hctx_pipe = 0; ccid2_change_pipe(hctx, 0);
hctx->ccid2hctx_ssthresh = hctx->ccid2hctx_cwnd >> 1; hctx->ccid2hctx_ssthresh = hctx->ccid2hctx_cwnd >> 1;
if (hctx->ccid2hctx_ssthresh < 2) if (hctx->ccid2hctx_ssthresh < 2)
hctx->ccid2hctx_ssthresh = 2; hctx->ccid2hctx_ssthresh = 2;
...@@ -274,7 +285,7 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, int len) ...@@ -274,7 +285,7 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, int len)
BUG_ON(!hctx->ccid2hctx_sendwait); BUG_ON(!hctx->ccid2hctx_sendwait);
hctx->ccid2hctx_sendwait = 0; hctx->ccid2hctx_sendwait = 0;
hctx->ccid2hctx_pipe++; ccid2_change_pipe(hctx, hctx->ccid2hctx_pipe + 1);
BUG_ON(hctx->ccid2hctx_pipe < 0); BUG_ON(hctx->ccid2hctx_pipe < 0);
/* There is an issue. What if another packet is sent between /* There is an issue. What if another packet is sent between
...@@ -470,11 +481,13 @@ static inline void ccid2_new_ack(struct sock *sk, ...@@ -470,11 +481,13 @@ static inline void ccid2_new_ack(struct sock *sk,
if (hctx->ccid2hctx_srtt == -1) { if (hctx->ccid2hctx_srtt == -1) {
ccid2_pr_debug("R: %lu Time=%lu seq=%llu\n", ccid2_pr_debug("R: %lu Time=%lu seq=%llu\n",
r, jiffies, seqp->ccid2s_seq); r, jiffies, seqp->ccid2s_seq);
hctx->ccid2hctx_srtt = r; ccid2_change_srtt(hctx, r);
hctx->ccid2hctx_rttvar = r >> 1; hctx->ccid2hctx_rttvar = r >> 1;
} else { } else {
/* RTTVAR */ /* RTTVAR */
long tmp = hctx->ccid2hctx_srtt - r; long tmp = hctx->ccid2hctx_srtt - r;
long srtt;
if (tmp < 0) if (tmp < 0)
tmp *= -1; tmp *= -1;
...@@ -484,10 +497,12 @@ static inline void ccid2_new_ack(struct sock *sk, ...@@ -484,10 +497,12 @@ static inline void ccid2_new_ack(struct sock *sk,
hctx->ccid2hctx_rttvar += tmp; hctx->ccid2hctx_rttvar += tmp;
/* SRTT */ /* SRTT */
hctx->ccid2hctx_srtt *= 7; srtt = hctx->ccid2hctx_srtt;
hctx->ccid2hctx_srtt >>= 3; srtt *= 7;
srtt >>= 3;
tmp = r >> 3; tmp = r >> 3;
hctx->ccid2hctx_srtt += tmp; srtt += tmp;
ccid2_change_srtt(hctx, srtt);
} }
s = hctx->ccid2hctx_rttvar << 2; s = hctx->ccid2hctx_rttvar << 2;
/* clock granularity is 1 when based on jiffies */ /* clock granularity is 1 when based on jiffies */
...@@ -523,7 +538,7 @@ static void ccid2_hc_tx_dec_pipe(struct sock *sk) ...@@ -523,7 +538,7 @@ static void ccid2_hc_tx_dec_pipe(struct sock *sk)
{ {
struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk);
hctx->ccid2hctx_pipe--; ccid2_change_pipe(hctx, hctx->ccid2hctx_pipe-1);
BUG_ON(hctx->ccid2hctx_pipe < 0); BUG_ON(hctx->ccid2hctx_pipe < 0);
if (hctx->ccid2hctx_pipe == 0) if (hctx->ccid2hctx_pipe == 0)
...@@ -749,7 +764,7 @@ static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk) ...@@ -749,7 +764,7 @@ static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk)
hctx->ccid2hctx_sent = 0; hctx->ccid2hctx_sent = 0;
hctx->ccid2hctx_rto = 3 * HZ; hctx->ccid2hctx_rto = 3 * HZ;
hctx->ccid2hctx_srtt = -1; ccid2_change_srtt(hctx, -1);
hctx->ccid2hctx_rttvar = -1; hctx->ccid2hctx_rttvar = -1;
hctx->ccid2hctx_lastrtt = 0; hctx->ccid2hctx_lastrtt = 0;
hctx->ccid2hctx_rpdupack = -1; hctx->ccid2hctx_rpdupack = -1;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册