Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 111527
b: refs/heads/master
c: 20bbd0f
h: refs/heads/master
i:
  111525: 156da02
  111523: dde09b7
  111519: 37e66c7
v: v3
  • Loading branch information
Gerrit Renker committed Sep 4, 2008
1 parent 09468cd commit 52916a9
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 25 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 1435562d7e0412e4885b661843f69859013f9d25
refs/heads/master: 20bbd0f75ee4b72c1dafc8e5fb6ad39ba506a75c
28 changes: 4 additions & 24 deletions trunk/net/dccp/ccids/ccid2.c
Original file line number Diff line number Diff line change
Expand Up @@ -110,8 +110,6 @@ static void ccid2_change_l_ack_ratio(struct sock *sk, u32 val)
dp->dccps_l_ack_ratio = val;
}

static void ccid2_start_rto_timer(struct sock *sk);

static void ccid2_hc_tx_rto_expire(unsigned long data)
{
struct sock *sk = (struct sock *)data;
Expand Down Expand Up @@ -150,23 +148,13 @@ static void ccid2_hc_tx_rto_expire(unsigned long data)
/* if we were blocked before, we may now send cwnd=1 packet */
if (sender_was_blocked)
tasklet_schedule(&dccp_sk(sk)->dccps_xmitlet);
ccid2_start_rto_timer(sk);
/* restart backed-off timer */
sk_reset_timer(sk, &hctx->rtotimer, jiffies + hctx->rto);
out:
bh_unlock_sock(sk);
sock_put(sk);
}

static void ccid2_start_rto_timer(struct sock *sk)
{
struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk);

ccid2_pr_debug("setting RTO timeout=%ld\n", hctx->rto);

BUG_ON(timer_pending(&hctx->rtotimer));
sk_reset_timer(sk, &hctx->rtotimer,
jiffies + hctx->rto);
}

static void ccid2_hc_tx_packet_sent(struct sock *sk, unsigned int len)
{
struct dccp_sock *dp = dccp_sk(sk);
Expand Down Expand Up @@ -245,7 +233,7 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, unsigned int len)

/* setup RTO timer */
if (!timer_pending(&hctx->rtotimer))
ccid2_start_rto_timer(sk);
sk_reset_timer(sk, &hctx->rtotimer, jiffies + hctx->rto);

#ifdef CONFIG_IP_DCCP_CCID2_DEBUG
do {
Expand All @@ -262,14 +250,6 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, unsigned int len)
#endif
}

static void ccid2_hc_tx_kill_rto_timer(struct sock *sk)
{
struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk);

sk_stop_timer(sk, &hctx->rtotimer);
ccid2_pr_debug("deleted RTO timer\n");
}

/**
* ccid2_rtt_estimator - Sample RTT and compute RTO using RFC2988 algorithm
* This code is almost identical with TCP's tcp_rtt_estimator(), since
Expand Down Expand Up @@ -645,7 +625,7 @@ static void ccid2_hc_tx_exit(struct sock *sk)
struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk);
int i;

ccid2_hc_tx_kill_rto_timer(sk);
sk_stop_timer(sk, &hctx->rtotimer);

for (i = 0; i < hctx->seqbufc; i++)
kfree(hctx->seqbuf[i]);
Expand Down

0 comments on commit 52916a9

Please sign in to comment.