Commit 93c3e8f5 authored by Andrei Emeltchenko's avatar Andrei Emeltchenko Committed by Gustavo Padovan

Bluetooth: Choose connection based on capabilities

Choose which L2CAP connection to establish by checking support
for HS and remote side supported features.
Signed-off-by: default avatarAndrei Emeltchenko <andrei.emeltchenko@intel.com>
Signed-off-by: default avatarGustavo Padovan <gustavo.padovan@collabora.co.uk>
parent 9a5e94db
...@@ -28,6 +28,7 @@ struct amp_mgr { ...@@ -28,6 +28,7 @@ struct amp_mgr {
struct list_head list; struct list_head list;
struct l2cap_conn *l2cap_conn; struct l2cap_conn *l2cap_conn;
struct l2cap_chan *a2mp_chan; struct l2cap_chan *a2mp_chan;
struct l2cap_chan *bredr_chan;
struct kref kref; struct kref kref;
__u8 ident; __u8 ident;
__u8 handle; __u8 handle;
...@@ -137,6 +138,7 @@ struct l2cap_chan *a2mp_channel_create(struct l2cap_conn *conn, ...@@ -137,6 +138,7 @@ struct l2cap_chan *a2mp_channel_create(struct l2cap_conn *conn,
struct sk_buff *skb); struct sk_buff *skb);
struct amp_mgr *amp_mgr_lookup_by_state(u8 state); struct amp_mgr *amp_mgr_lookup_by_state(u8 state);
void a2mp_send(struct amp_mgr *mgr, u8 code, u8 ident, u16 len, void *data); void a2mp_send(struct amp_mgr *mgr, u8 code, u8 ident, u16 len, void *data);
void a2mp_discover_amp(struct l2cap_chan *chan);
void a2mp_send_getinfo_rsp(struct hci_dev *hdev); void a2mp_send_getinfo_rsp(struct hci_dev *hdev);
void a2mp_send_getampassoc_rsp(struct hci_dev *hdev, u8 status); void a2mp_send_getampassoc_rsp(struct hci_dev *hdev, u8 status);
......
...@@ -767,6 +767,7 @@ int l2cap_chan_check_security(struct l2cap_chan *chan); ...@@ -767,6 +767,7 @@ int l2cap_chan_check_security(struct l2cap_chan *chan);
void l2cap_chan_set_defaults(struct l2cap_chan *chan); void l2cap_chan_set_defaults(struct l2cap_chan *chan);
int l2cap_ertm_init(struct l2cap_chan *chan); int l2cap_ertm_init(struct l2cap_chan *chan);
void l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan); void l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan);
void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan);
void l2cap_chan_del(struct l2cap_chan *chan, int err); void l2cap_chan_del(struct l2cap_chan *chan, int err);
#endif /* __L2CAP_H */ #endif /* __L2CAP_H */
...@@ -638,7 +638,7 @@ static struct l2cap_ops a2mp_chan_ops = { ...@@ -638,7 +638,7 @@ static struct l2cap_ops a2mp_chan_ops = {
.ready = l2cap_chan_no_ready, .ready = l2cap_chan_no_ready,
}; };
static struct l2cap_chan *a2mp_chan_open(struct l2cap_conn *conn) static struct l2cap_chan *a2mp_chan_open(struct l2cap_conn *conn, bool locked)
{ {
struct l2cap_chan *chan; struct l2cap_chan *chan;
int err; int err;
...@@ -673,7 +673,10 @@ static struct l2cap_chan *a2mp_chan_open(struct l2cap_conn *conn) ...@@ -673,7 +673,10 @@ static struct l2cap_chan *a2mp_chan_open(struct l2cap_conn *conn)
chan->conf_state = 0; chan->conf_state = 0;
l2cap_chan_add(conn, chan); if (locked)
__l2cap_chan_add(conn, chan);
else
l2cap_chan_add(conn, chan);
chan->remote_mps = chan->omtu; chan->remote_mps = chan->omtu;
chan->mps = chan->omtu; chan->mps = chan->omtu;
...@@ -712,7 +715,7 @@ int amp_mgr_put(struct amp_mgr *mgr) ...@@ -712,7 +715,7 @@ int amp_mgr_put(struct amp_mgr *mgr)
return kref_put(&mgr->kref, &amp_mgr_destroy); return kref_put(&mgr->kref, &amp_mgr_destroy);
} }
static struct amp_mgr *amp_mgr_create(struct l2cap_conn *conn) static struct amp_mgr *amp_mgr_create(struct l2cap_conn *conn, bool locked)
{ {
struct amp_mgr *mgr; struct amp_mgr *mgr;
struct l2cap_chan *chan; struct l2cap_chan *chan;
...@@ -725,7 +728,7 @@ static struct amp_mgr *amp_mgr_create(struct l2cap_conn *conn) ...@@ -725,7 +728,7 @@ static struct amp_mgr *amp_mgr_create(struct l2cap_conn *conn)
mgr->l2cap_conn = conn; mgr->l2cap_conn = conn;
chan = a2mp_chan_open(conn); chan = a2mp_chan_open(conn, locked);
if (!chan) { if (!chan) {
kfree(mgr); kfree(mgr);
return NULL; return NULL;
...@@ -754,7 +757,7 @@ struct l2cap_chan *a2mp_channel_create(struct l2cap_conn *conn, ...@@ -754,7 +757,7 @@ struct l2cap_chan *a2mp_channel_create(struct l2cap_conn *conn,
{ {
struct amp_mgr *mgr; struct amp_mgr *mgr;
mgr = amp_mgr_create(conn); mgr = amp_mgr_create(conn, false);
if (!mgr) { if (!mgr) {
BT_ERR("Could not create AMP manager"); BT_ERR("Could not create AMP manager");
return NULL; return NULL;
...@@ -842,3 +845,24 @@ void a2mp_send_getampassoc_rsp(struct hci_dev *hdev, u8 status) ...@@ -842,3 +845,24 @@ void a2mp_send_getampassoc_rsp(struct hci_dev *hdev, u8 status)
amp_mgr_put(mgr); amp_mgr_put(mgr);
kfree(rsp); kfree(rsp);
} }
void a2mp_discover_amp(struct l2cap_chan *chan)
{
struct l2cap_conn *conn = chan->conn;
struct amp_mgr *mgr = conn->hcon->amp_mgr;
struct a2mp_discov_req req;
BT_DBG("chan %p conn %p mgr %p", chan, conn, mgr);
if (!mgr) {
mgr = amp_mgr_create(conn, true);
if (!mgr)
return;
}
mgr->bredr_chan = chan;
req.mtu = cpu_to_le16(L2CAP_A2MP_DEFAULT_MTU);
req.ext_feat = 0;
a2mp_send(mgr, A2MP_DISCOVER_REQ, 1, sizeof(req), &req);
}
...@@ -455,7 +455,7 @@ void l2cap_chan_set_defaults(struct l2cap_chan *chan) ...@@ -455,7 +455,7 @@ void l2cap_chan_set_defaults(struct l2cap_chan *chan)
set_bit(FLAG_FORCE_ACTIVE, &chan->flags); set_bit(FLAG_FORCE_ACTIVE, &chan->flags);
} }
static void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan) void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan)
{ {
BT_DBG("conn %p, psm 0x%2.2x, dcid 0x%4.4x", conn, BT_DBG("conn %p, psm 0x%2.2x, dcid 0x%4.4x", conn,
__le16_to_cpu(chan->psm), chan->dcid); __le16_to_cpu(chan->psm), chan->dcid);
...@@ -946,6 +946,18 @@ static inline int __l2cap_no_conn_pending(struct l2cap_chan *chan) ...@@ -946,6 +946,18 @@ static inline int __l2cap_no_conn_pending(struct l2cap_chan *chan)
return !test_bit(CONF_CONNECT_PEND, &chan->conf_state); return !test_bit(CONF_CONNECT_PEND, &chan->conf_state);
} }
static bool __amp_capable(struct l2cap_chan *chan)
{
struct l2cap_conn *conn = chan->conn;
if (enable_hs &&
chan->chan_policy == BT_CHANNEL_POLICY_AMP_PREFERRED &&
conn->fixed_chan_mask & L2CAP_FC_A2MP)
return true;
else
return false;
}
static void l2cap_send_conn_req(struct l2cap_chan *chan) static void l2cap_send_conn_req(struct l2cap_chan *chan)
{ {
struct l2cap_conn *conn = chan->conn; struct l2cap_conn *conn = chan->conn;
...@@ -972,6 +984,16 @@ static void l2cap_chan_ready(struct l2cap_chan *chan) ...@@ -972,6 +984,16 @@ static void l2cap_chan_ready(struct l2cap_chan *chan)
chan->ops->ready(chan); chan->ops->ready(chan);
} }
static void l2cap_start_connection(struct l2cap_chan *chan)
{
if (__amp_capable(chan)) {
BT_DBG("chan %p AMP capable: discover AMPs", chan);
a2mp_discover_amp(chan);
} else {
l2cap_send_conn_req(chan);
}
}
static void l2cap_do_start(struct l2cap_chan *chan) static void l2cap_do_start(struct l2cap_chan *chan)
{ {
struct l2cap_conn *conn = chan->conn; struct l2cap_conn *conn = chan->conn;
...@@ -986,8 +1008,9 @@ static void l2cap_do_start(struct l2cap_chan *chan) ...@@ -986,8 +1008,9 @@ static void l2cap_do_start(struct l2cap_chan *chan)
return; return;
if (l2cap_chan_check_security(chan) && if (l2cap_chan_check_security(chan) &&
__l2cap_no_conn_pending(chan)) __l2cap_no_conn_pending(chan)) {
l2cap_send_conn_req(chan); l2cap_start_connection(chan);
}
} else { } else {
struct l2cap_info_req req; struct l2cap_info_req req;
req.type = __constant_cpu_to_le16(L2CAP_IT_FEAT_MASK); req.type = __constant_cpu_to_le16(L2CAP_IT_FEAT_MASK);
...@@ -1082,7 +1105,7 @@ static void l2cap_conn_start(struct l2cap_conn *conn) ...@@ -1082,7 +1105,7 @@ static void l2cap_conn_start(struct l2cap_conn *conn)
continue; continue;
} }
l2cap_send_conn_req(chan); l2cap_start_connection(chan);
} else if (chan->state == BT_CONNECT2) { } else if (chan->state == BT_CONNECT2) {
struct l2cap_conn_rsp rsp; struct l2cap_conn_rsp rsp;
...@@ -5456,7 +5479,7 @@ int l2cap_security_cfm(struct hci_conn *hcon, u8 status, u8 encrypt) ...@@ -5456,7 +5479,7 @@ int l2cap_security_cfm(struct hci_conn *hcon, u8 status, u8 encrypt)
if (chan->state == BT_CONNECT) { if (chan->state == BT_CONNECT) {
if (!status) { if (!status) {
l2cap_send_conn_req(chan); l2cap_start_connection(chan);
} else { } else {
__set_chan_timer(chan, L2CAP_DISC_TIMEOUT); __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
} }
......
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