diff options
Diffstat (limited to 'net/lapb/lapb_timer.c')
| -rw-r--r-- | net/lapb/lapb_timer.c | 30 | 
1 files changed, 26 insertions, 4 deletions
| diff --git a/net/lapb/lapb_timer.c b/net/lapb/lapb_timer.c index baa247fe4ed0..0230b272b7d1 100644 --- a/net/lapb/lapb_timer.c +++ b/net/lapb/lapb_timer.c @@ -40,6 +40,7 @@ void lapb_start_t1timer(struct lapb_cb *lapb)  	lapb->t1timer.function = lapb_t1timer_expiry;  	lapb->t1timer.expires  = jiffies + lapb->t1; +	lapb->t1timer_stop = false;  	add_timer(&lapb->t1timer);  } @@ -50,16 +51,19 @@ void lapb_start_t2timer(struct lapb_cb *lapb)  	lapb->t2timer.function = lapb_t2timer_expiry;  	lapb->t2timer.expires  = jiffies + lapb->t2; +	lapb->t2timer_stop = false;  	add_timer(&lapb->t2timer);  }  void lapb_stop_t1timer(struct lapb_cb *lapb)  { +	lapb->t1timer_stop = true;  	del_timer(&lapb->t1timer);  }  void lapb_stop_t2timer(struct lapb_cb *lapb)  { +	lapb->t2timer_stop = true;  	del_timer(&lapb->t2timer);  } @@ -72,16 +76,31 @@ static void lapb_t2timer_expiry(struct timer_list *t)  {  	struct lapb_cb *lapb = from_timer(lapb, t, t2timer); +	spin_lock_bh(&lapb->lock); +	if (timer_pending(&lapb->t2timer)) /* A new timer has been set up */ +		goto out; +	if (lapb->t2timer_stop) /* The timer has been stopped */ +		goto out; +  	if (lapb->condition & LAPB_ACK_PENDING_CONDITION) {  		lapb->condition &= ~LAPB_ACK_PENDING_CONDITION;  		lapb_timeout_response(lapb);  	} + +out: +	spin_unlock_bh(&lapb->lock);  }  static void lapb_t1timer_expiry(struct timer_list *t)  {  	struct lapb_cb *lapb = from_timer(lapb, t, t1timer); +	spin_lock_bh(&lapb->lock); +	if (timer_pending(&lapb->t1timer)) /* A new timer has been set up */ +		goto out; +	if (lapb->t1timer_stop) /* The timer has been stopped */ +		goto out; +  	switch (lapb->state) {  		/* @@ -108,7 +127,7 @@ static void lapb_t1timer_expiry(struct timer_list *t)  				lapb->state = LAPB_STATE_0;  				lapb_disconnect_indication(lapb, LAPB_TIMEDOUT);  				lapb_dbg(0, "(%p) S1 -> S0\n", lapb->dev); -				return; +				goto out;  			} else {  				lapb->n2count++;  				if (lapb->mode & LAPB_EXTENDED) { @@ -132,7 +151,7 @@ static void lapb_t1timer_expiry(struct timer_list *t)  				lapb->state = LAPB_STATE_0;  				lapb_disconnect_confirmation(lapb, LAPB_TIMEDOUT);  				lapb_dbg(0, "(%p) S2 -> S0\n", lapb->dev); -				return; +				goto out;  			} else {  				lapb->n2count++;  				lapb_dbg(1, "(%p) S2 TX DISC(1)\n", lapb->dev); @@ -150,7 +169,7 @@ static void lapb_t1timer_expiry(struct timer_list *t)  				lapb_stop_t2timer(lapb);  				lapb_disconnect_indication(lapb, LAPB_TIMEDOUT);  				lapb_dbg(0, "(%p) S3 -> S0\n", lapb->dev); -				return; +				goto out;  			} else {  				lapb->n2count++;  				lapb_requeue_frames(lapb); @@ -167,7 +186,7 @@ static void lapb_t1timer_expiry(struct timer_list *t)  				lapb->state = LAPB_STATE_0;  				lapb_disconnect_indication(lapb, LAPB_TIMEDOUT);  				lapb_dbg(0, "(%p) S4 -> S0\n", lapb->dev); -				return; +				goto out;  			} else {  				lapb->n2count++;  				lapb_transmit_frmr(lapb); @@ -176,4 +195,7 @@ static void lapb_t1timer_expiry(struct timer_list *t)  	}  	lapb_start_t1timer(lapb); + +out: +	spin_unlock_bh(&lapb->lock);  } | 
