Commit 23070494 authored by Gustavo F. Padovan's avatar Gustavo F. Padovan

Bluetooth: add recv() callback to l2cap_chan_ops

This abstracts the call to sock_queue_recv_skb() into
l2cap_chan_ops->recv().
Signed-off-by: default avatarGustavo F. Padovan <padovan@profusion.mobi>
parent 80808e43
...@@ -363,6 +363,7 @@ struct l2cap_ops { ...@@ -363,6 +363,7 @@ struct l2cap_ops {
char *name; char *name;
struct l2cap_chan *(*new_connection) (void *data); struct l2cap_chan *(*new_connection) (void *data);
int (*recv) (void *data, struct sk_buff *skb);
}; };
struct l2cap_conn { struct l2cap_conn {
......
...@@ -1698,7 +1698,7 @@ static void l2cap_raw_recv(struct l2cap_conn *conn, struct sk_buff *skb) ...@@ -1698,7 +1698,7 @@ static void l2cap_raw_recv(struct l2cap_conn *conn, struct sk_buff *skb)
if (!nskb) if (!nskb)
continue; continue;
if (sock_queue_rcv_skb(sk, nskb)) if (chan->ops->recv(chan->data, nskb))
kfree_skb(nskb); kfree_skb(nskb);
} }
read_unlock(&conn->chan_lock); read_unlock(&conn->chan_lock);
...@@ -3124,7 +3124,7 @@ static int l2cap_ertm_reassembly_sdu(struct l2cap_chan *chan, struct sk_buff *sk ...@@ -3124,7 +3124,7 @@ static int l2cap_ertm_reassembly_sdu(struct l2cap_chan *chan, struct sk_buff *sk
if (chan->conn_state & L2CAP_CONN_SAR_SDU) if (chan->conn_state & L2CAP_CONN_SAR_SDU)
goto drop; goto drop;
return sock_queue_rcv_skb(chan->sk, skb); return chan->ops->recv(chan->data, skb);
case L2CAP_SDU_START: case L2CAP_SDU_START:
if (chan->conn_state & L2CAP_CONN_SAR_SDU) if (chan->conn_state & L2CAP_CONN_SAR_SDU)
...@@ -3190,7 +3190,7 @@ static int l2cap_ertm_reassembly_sdu(struct l2cap_chan *chan, struct sk_buff *sk ...@@ -3190,7 +3190,7 @@ static int l2cap_ertm_reassembly_sdu(struct l2cap_chan *chan, struct sk_buff *sk
return -ENOMEM; return -ENOMEM;
} }
err = sock_queue_rcv_skb(chan->sk, _skb); err = chan->ops->recv(chan->data, _skb);
if (err < 0) { if (err < 0) {
kfree_skb(_skb); kfree_skb(_skb);
chan->conn_state |= L2CAP_CONN_SAR_RETRY; chan->conn_state |= L2CAP_CONN_SAR_RETRY;
...@@ -3358,7 +3358,7 @@ static int l2cap_streaming_reassembly_sdu(struct l2cap_chan *chan, struct sk_buf ...@@ -3358,7 +3358,7 @@ static int l2cap_streaming_reassembly_sdu(struct l2cap_chan *chan, struct sk_buf
break; break;
} }
err = sock_queue_rcv_skb(chan->sk, skb); err = chan->ops->recv(chan->data, skb);
if (!err) if (!err)
return 0; return 0;
...@@ -3419,7 +3419,7 @@ static int l2cap_streaming_reassembly_sdu(struct l2cap_chan *chan, struct sk_buf ...@@ -3419,7 +3419,7 @@ static int l2cap_streaming_reassembly_sdu(struct l2cap_chan *chan, struct sk_buf
if (chan->partial_sdu_len == chan->sdu_len) { if (chan->partial_sdu_len == chan->sdu_len) {
_skb = skb_clone(chan->sdu, GFP_ATOMIC); _skb = skb_clone(chan->sdu, GFP_ATOMIC);
err = sock_queue_rcv_skb(chan->sk, _skb); err = chan->ops->recv(chan->data, _skb);
if (err < 0) if (err < 0)
kfree_skb(_skb); kfree_skb(_skb);
} }
...@@ -3886,7 +3886,7 @@ static inline int l2cap_data_channel(struct l2cap_conn *conn, u16 cid, struct sk ...@@ -3886,7 +3886,7 @@ static inline int l2cap_data_channel(struct l2cap_conn *conn, u16 cid, struct sk
if (chan->imtu < skb->len) if (chan->imtu < skb->len)
goto drop; goto drop;
if (!sock_queue_rcv_skb(sk, skb)) if (!chan->ops->recv(chan->data, skb))
goto done; goto done;
break; break;
...@@ -3964,7 +3964,7 @@ static inline int l2cap_conless_channel(struct l2cap_conn *conn, __le16 psm, str ...@@ -3964,7 +3964,7 @@ static inline int l2cap_conless_channel(struct l2cap_conn *conn, __le16 psm, str
if (l2cap_pi(sk)->chan->imtu < skb->len) if (l2cap_pi(sk)->chan->imtu < skb->len)
goto drop; goto drop;
if (!sock_queue_rcv_skb(sk, skb)) if (!chan->ops->recv(chan->data, skb))
goto done; goto done;
drop: drop:
...@@ -3997,7 +3997,7 @@ static inline int l2cap_att_channel(struct l2cap_conn *conn, __le16 cid, struct ...@@ -3997,7 +3997,7 @@ static inline int l2cap_att_channel(struct l2cap_conn *conn, __le16 cid, struct
if (l2cap_pi(sk)->chan->imtu < skb->len) if (l2cap_pi(sk)->chan->imtu < skb->len)
goto drop; goto drop;
if (!sock_queue_rcv_skb(sk, skb)) if (!chan->ops->recv(chan->data, skb))
goto done; goto done;
drop: drop:
......
...@@ -789,9 +789,17 @@ static struct l2cap_chan *l2cap_sock_new_connection_cb(void *data) ...@@ -789,9 +789,17 @@ static struct l2cap_chan *l2cap_sock_new_connection_cb(void *data)
return l2cap_pi(sk)->chan; return l2cap_pi(sk)->chan;
} }
static int l2cap_sock_recv_cb(void *data, struct sk_buff *skb)
{
struct sock *sk = data;
return sock_queue_rcv_skb(sk, skb);
}
static struct l2cap_ops l2cap_chan_ops = { static struct l2cap_ops l2cap_chan_ops = {
.name = "L2CAP Socket Interface", .name = "L2CAP Socket Interface",
.new_connection = l2cap_sock_new_connection_cb, .new_connection = l2cap_sock_new_connection_cb,
.recv = l2cap_sock_recv_cb,
}; };
static void l2cap_sock_destruct(struct sock *sk) static void l2cap_sock_destruct(struct sock *sk)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment