Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 256403
b: refs/heads/master
c: 26f880d
h: refs/heads/master
i:
  256401: 765ea02
  256399: 3f23c25
v: v3
  • Loading branch information
Mat Martineau authored and Gustavo F. Padovan committed Jul 7, 2011
1 parent 0488b56 commit 3b5a3d5
Show file tree
Hide file tree
Showing 2 changed files with 39 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: 8c156c322f8a300afe59259bd554db166cf88203
refs/heads/master: 26f880d221302b5d061185d8a6795bb532693bf3
62 changes: 38 additions & 24 deletions trunk/net/bluetooth/l2cap_core.c
Original file line number Diff line number Diff line change
Expand Up @@ -3227,22 +3227,26 @@ static int l2cap_ertm_reassembly_sdu(struct l2cap_chan *chan, struct sk_buff *sk
return 0;
}

static int l2cap_try_push_rx_skb(struct l2cap_chan *chan)
static void l2cap_ertm_enter_local_busy(struct l2cap_chan *chan)
{
struct sk_buff *skb;
u16 control;
int err;

while ((skb = skb_dequeue(&chan->busy_q))) {
control = bt_cb(skb)->sar << L2CAP_CTRL_SAR_SHIFT;
err = l2cap_ertm_reassembly_sdu(chan, skb, control);
if (err < 0) {
skb_queue_head(&chan->busy_q, skb);
return -EBUSY;
}
BT_DBG("chan %p, Enter local busy", chan);

chan->buffer_seq = (chan->buffer_seq + 1) % 64;
}
set_bit(CONN_LOCAL_BUSY, &chan->conn_state);

control = chan->buffer_seq << L2CAP_CTRL_REQSEQ_SHIFT;
control |= L2CAP_SUPER_RCV_NOT_READY;
l2cap_send_sframe(chan, control);

set_bit(CONN_RNR_SENT, &chan->conn_state);

__clear_ack_timer(chan);
}

static void l2cap_ertm_exit_local_busy(struct l2cap_chan *chan)
{
u16 control;

if (!test_bit(CONN_RNR_SENT, &chan->conn_state))
goto done;
Expand All @@ -3262,6 +3266,26 @@ static int l2cap_try_push_rx_skb(struct l2cap_chan *chan)
clear_bit(CONN_RNR_SENT, &chan->conn_state);

BT_DBG("chan %p, Exit local busy", chan);
}

static int l2cap_try_push_rx_skb(struct l2cap_chan *chan)
{
struct sk_buff *skb;
u16 control;
int err;

while ((skb = skb_dequeue(&chan->busy_q))) {
control = bt_cb(skb)->sar << L2CAP_CTRL_SAR_SHIFT;
err = l2cap_ertm_reassembly_sdu(chan, skb, control);
if (err < 0) {
skb_queue_head(&chan->busy_q, skb);
return -EBUSY;
}

chan->buffer_seq = (chan->buffer_seq + 1) % 64;
}

l2cap_ertm_exit_local_busy(chan);

return 0;
}
Expand Down Expand Up @@ -3315,7 +3339,7 @@ static void l2cap_busy_work(struct work_struct *work)

static int l2cap_push_rx_skb(struct l2cap_chan *chan, struct sk_buff *skb, u16 control)
{
int sctrl, err;
int err;

if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
bt_cb(skb)->sar = control >> L2CAP_CTRL_SAR_SHIFT;
Expand All @@ -3331,21 +3355,11 @@ static int l2cap_push_rx_skb(struct l2cap_chan *chan, struct sk_buff *skb, u16 c
return err;
}

/* Busy Condition */
BT_DBG("chan %p, Enter local busy", chan);
l2cap_ertm_enter_local_busy(chan);

set_bit(CONN_LOCAL_BUSY, &chan->conn_state);
bt_cb(skb)->sar = control >> L2CAP_CTRL_SAR_SHIFT;
__skb_queue_tail(&chan->busy_q, skb);

sctrl = chan->buffer_seq << L2CAP_CTRL_REQSEQ_SHIFT;
sctrl |= L2CAP_SUPER_RCV_NOT_READY;
l2cap_send_sframe(chan, sctrl);

set_bit(CONN_RNR_SENT, &chan->conn_state);

__clear_ack_timer(chan);

queue_work(_busy_wq, &chan->busy_work);

return err;
Expand Down

0 comments on commit 3b5a3d5

Please sign in to comment.