Hi Luiz,
>>>>>>>>> This adds the initial code for Enhanced Credit Based Mode which
>>>>>>>>> introduces a new socket mode called L2CAP_MODE_EXT_FLOWCTL, which for
>>>>>>>>> the most part work the same as L2CAP_MODE_LE_FLOWCTL but uses different
>>>>>>>>> PDUs to setup the connections and also works over BR/EDR.
>>>>>>>>>
>>>>>>>>> Signed-off-by: Luiz Augusto von Dentz <luiz.von.dentz@xxxxxxxxx>
>>>>>>>>> ---
>>>>>>>>> include/net/bluetooth/l2cap.h | 4 +
>>>>>>>>> net/bluetooth/l2cap_core.c | 510 +++++++++++++++++++++++++++++++++-
>>>>>>>>> net/bluetooth/l2cap_sock.c | 39 +--
>>>>>>>>> 3 files changed, 521 insertions(+), 32 deletions(-)
>>>>>>>>>
>>>>>>>>> diff --git a/include/net/bluetooth/l2cap.h b/include/net/bluetooth/l2cap.h
>>>>>>>>> index b9ea88cfd2d2..11ae4c93354b 100644
>>>>>>>>> --- a/include/net/bluetooth/l2cap.h
>>>>>>>>> +++ b/include/net/bluetooth/l2cap.h
>>>>>>>>> @@ -295,6 +295,8 @@ struct l2cap_conn_rsp {
>>>>>>>>> #define L2CAP_CR_LE_ENCRYPTION 0x0008
>>>>>>>>> #define L2CAP_CR_LE_INVALID_SCID 0x0009
>>>>>>>>> #define L2CAP_CR_LE_SCID_IN_USE 0X000A
>>>>>>>>> +#define L2CAP_CR_LE_UNACCEPT_PARAMS 0X000B
>>>>>>>>> +#define L2CAP_CR_LE_INVALID_PARAMS 0X000C
>>>>>>>>>
>>>>>>>>> /* connect/create channel status */
>>>>>>>>> #define L2CAP_CS_NO_INFO 0x0000
>>>>>>>>> @@ -964,6 +966,7 @@ void l2cap_cleanup_sockets(void);
>>>>>>>>> bool l2cap_is_socket(struct socket *sock);
>>>>>>>>>
>>>>>>>>> void __l2cap_le_connect_rsp_defer(struct l2cap_chan *chan);
>>>>>>>>> +void __l2cap_ecred_conn_rsp_defer(struct l2cap_chan *chan);
>>>>>>>>> void __l2cap_connect_rsp_defer(struct l2cap_chan *chan);
>>>>>>>>>
>>>>>>>>> int l2cap_add_psm(struct l2cap_chan *chan, bdaddr_t *src, __le16 psm);
>>>>>>>>> @@ -973,6 +976,7 @@ struct l2cap_chan *l2cap_chan_create(void);
>>>>>>>>> void l2cap_chan_close(struct l2cap_chan *chan, int reason);
>>>>>>>>> int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
>>>>>>>>> bdaddr_t *dst, u8 dst_type);
>>>>>>>>> +int l2cap_chan_reconfigure(struct l2cap_chan *chan, __u16 mtu);
>>>>>>>>> int l2cap_chan_send(struct l2cap_chan *chan, struct msghdr *msg, size_t len);
>>>>>>>>> void l2cap_chan_busy(struct l2cap_chan *chan, int busy);
>>>>>>>>> int l2cap_chan_check_security(struct l2cap_chan *chan, bool initiator);
>>>>>>>>> diff --git a/net/bluetooth/l2cap_core.c b/net/bluetooth/l2cap_core.c
>>>>>>>>> index 195459a1e53e..a528526cffac 100644
>>>>>>>>> --- a/net/bluetooth/l2cap_core.c
>>>>>>>>> +++ b/net/bluetooth/l2cap_core.c
>>>>>>>>> @@ -532,6 +532,17 @@ static void l2cap_le_flowctl_init(struct l2cap_chan *chan, u16 tx_credits)
>>>>>>>>> skb_queue_head_init(&chan->tx_q);
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> +static void l2cap_ecred_init(struct l2cap_chan *chan, u16 tx_credits)
>>>>>>>>> +{
>>>>>>>>> + l2cap_le_flowctl_init(chan, tx_credits);
>>>>>>>>> +
>>>>>>>>> + /* L2CAP implementations shall support a minimum MPS of 64 octets */
>>>>>>>>> + if (chan->mps < L2CAP_ECRED_MIN_MPS) {
>>>>>>>>> + chan->mps = L2CAP_ECRED_MIN_MPS;
>>>>>>>>> + chan->rx_credits = (chan->imtu / chan->mps) + 1;
>>>>>>>>> + }
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> 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,
>>>>>>>>> @@ -638,6 +649,7 @@ void l2cap_chan_del(struct l2cap_chan *chan, int err)
>>>>>>>>> break;
>>>>>>>>>
>>>>>>>>> case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> skb_queue_purge(&chan->tx_q);
>>>>>>>>> break;
>>>>>>>>>
>>>>>>>>> @@ -1260,6 +1272,17 @@ static void l2cap_move_done(struct l2cap_chan *chan)
>>>>>>>>> }
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> +static bool l2cap_mode_ready(struct l2cap_chan *chan)
>>>>>>>>> +{
>>>>>>>>> + switch (chan->mode) {
>>>>>>>>> + case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> + return chan->tx_credits ? true : false;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + return true;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> static void l2cap_chan_ready(struct l2cap_chan *chan)
>>>>>>>>> {
>>>>>>>>> /* The channel may have already been flagged as connected in
>>>>>>>>> @@ -1273,7 +1296,7 @@ static void l2cap_chan_ready(struct l2cap_chan *chan)
>>>>>>>>> chan->conf_state = 0;
>>>>>>>>> __clear_chan_timer(chan);
>>>>>>>>>
>>>>>>>>> - if (chan->mode == L2CAP_MODE_LE_FLOWCTL && !chan->tx_credits)
>>>>>>>>> + if (!l2cap_mode_ready(chan))
>>>>>>>>> chan->ops->suspend(chan);
>>>>>>>>
>>>>>>>> switch (chan->mode) {
>>>>>>>> case ..
>>>>>>>> case ..
>>>>>>>> if (!chan->tx_credits)
>>>>>>>> chan->ops->suspend(chan);
>>>>>>>> break;
>>>>>>>> }
>>>>>>>>
>>>>>>>>>
>>>>>>>>> chan->state = BT_CONNECTED;
>>>>>>>>> @@ -1306,6 +1329,31 @@ static void l2cap_le_connect(struct l2cap_chan *chan)
>>>>>>>>> sizeof(req), &req);
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> +static void l2cap_ecred_connect(struct l2cap_chan *chan)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_conn *conn = chan->conn;
>>>>>>>>> + struct {
>>>>>>>>> + struct l2cap_ecred_conn_req req;
>>>>>>>>> + __le16 scid;
>>>>>>>>> + } __packed pdu;
>>>>>>>>> +
>>>>>>>>> + if (test_and_set_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
>>>>>>>>> + return;
>>>>>>>>> +
>>>>>>>>> + l2cap_ecred_init(chan, 0);
>>>>>>>>> +
>>>>>>>>> + pdu.req.psm = chan->psm;
>>>>>>>>> + pdu.req.mtu = cpu_to_le16(chan->imtu);
>>>>>>>>> + pdu.req.mps = cpu_to_le16(chan->mps);
>>>>>>>>> + pdu.req.credits = cpu_to_le16(chan->rx_credits);
>>>>>>>>> + pdu.scid = cpu_to_le16(chan->scid);
>>>>>>>>> +
>>>>>>>>> + chan->ident = l2cap_get_ident(conn);
>>>>>>>>> +
>>>>>>>>> + l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_CONN_REQ,
>>>>>>>>> + sizeof(pdu), &pdu);
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> static void l2cap_le_start(struct l2cap_chan *chan)
>>>>>>>>> {
>>>>>>>>> struct l2cap_conn *conn = chan->conn;
>>>>>>>>> @@ -1318,8 +1366,12 @@ static void l2cap_le_start(struct l2cap_chan *chan)
>>>>>>>>> return;
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> - if (chan->state == BT_CONNECT)
>>>>>>>>> - l2cap_le_connect(chan);
>>>>>>>>> + if (chan->state == BT_CONNECT) {
>>>>>>>>> + if (chan->mode == L2CAP_MODE_EXT_FLOWCTL)
>>>>>>>>> + l2cap_ecred_connect(chan);
>>>>>>>>> + else
>>>>>>>>> + l2cap_le_connect(chan);
>>>>>>>>> + }
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> static void l2cap_start_connection(struct l2cap_chan *chan)
>>>>>>>>> @@ -2505,6 +2557,7 @@ int l2cap_chan_send(struct l2cap_chan *chan, struct msghdr *msg, size_t len)
>>>>>>>>>
>>>>>>>>> switch (chan->mode) {
>>>>>>>>> case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> /* Check outgoing MTU */
>>>>>>>>> if (len > chan->omtu)
>>>>>>>>> return -EMSGSIZE;
>>>>>>>>> @@ -3773,6 +3826,42 @@ void __l2cap_le_connect_rsp_defer(struct l2cap_chan *chan)
>>>>>>>>> &rsp);
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> +void __l2cap_ecred_conn_rsp_defer(struct l2cap_chan *chan)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_ecred_conn_rsp rsp;
>>>>>>>>> + struct l2cap_conn *conn = chan->conn;
>>>>>>>>> + u16 ident = chan->ident;
>>>>>>>>> + int i = 0;
>>>>>>>>> +
>>>>>>>>> + if (!ident) {
>>>>>>>>> + return;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>
>>>>>>>> No { } here.
>>>>>>>>
>>>>>>>>> + BT_DBG("chan %p ident %d", chan, ident);
>>>>>>>>> +
>>>>>>>>> + rsp.mtu = cpu_to_le16(chan->imtu);
>>>>>>>>> + rsp.mps = cpu_to_le16(chan->mps);
>>>>>>>>> + rsp.credits = cpu_to_le16(chan->rx_credits);
>>>>>>>>> + rsp.result = cpu_to_le16(L2CAP_CR_LE_SUCCESS);
>>>>>>>>> +
>>>>>>>>> + mutex_lock(&conn->chan_lock);
>>>>>>>>> +
>>>>>>>>> + list_for_each_entry(chan, &conn->chan_l, list) {
>>>>>>>>> + if (chan->ident != ident)
>>>>>>>>> + continue;
>>>>>>>>> +
>>>>>>>>> + /* Reset ident so only one response is sent */
>>>>>>>>> + chan->ident = 0;
>>>>>>>>> +
>>>>>>>>> + /* Include all channels pending with the same ident */
>>>>>>>>> + rsp.dcid[i++] = cpu_to_le16(chan->scid);
>>>>>>>>
>>>>>>>> This doesn’t work. The sizeof(rsp) has no dcid in there. You are overflowing into conn struct here.
>>>>>>>>
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + mutex_unlock(&conn->chan_lock);
>>>>>>>>> +
>>>>>>>>> + l2cap_send_cmd(conn, ident, L2CAP_ECRED_CONN_RSP, sizeof(rsp), &rsp);
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> void __l2cap_connect_rsp_defer(struct l2cap_chan *chan)
>>>>>>>>> {
>>>>>>>>> struct l2cap_conn_rsp rsp;
>>>>>>>>> @@ -5714,6 +5803,347 @@ static inline int l2cap_le_credits(struct l2cap_conn *conn,
>>>>>>>>> return 0;
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> +static inline int l2cap_ecred_conn_req(struct l2cap_conn *conn,
>>>>>>>>> + struct l2cap_cmd_hdr *cmd, u16 cmd_len,
>>>>>>>>> + u8 *data)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_ecred_conn_req *req = (void *) data;
>>>>>>>>> + struct {
>>>>>>>>> + struct l2cap_ecred_conn_rsp rsp;
>>>>>>>>> + __le16 dcid[5];
>>>>>>>>> + } __packed pdu;
>>>>>>>>> + struct l2cap_chan *chan, *pchan;
>>>>>>>>> + u16 credits, mtu, mps;
>>>>>>>>> + __le16 psm;
>>>>>>>>> + u8 result, len = 0;
>>>>>>>>> + int i;
>>>>>>>>> + bool defer = false;
>>>>>>>>> +
>>>>>>>>> + if (cmd_len < sizeof(*req))
>>>>>>>>> + return -EPROTO;
>>>>>>>>> +
>>>>>>>>> + mtu = __le16_to_cpu(req->mtu);
>>>>>>>>> + mps = __le16_to_cpu(req->mps);
>>>>>>>>> +
>>>>>>>>> + if (mtu < L2CAP_ECRED_MIN_MTU || mps < L2CAP_ECRED_MIN_MPS) {
>>>>>>>>> + result = L2CAP_CR_LE_UNACCEPT_PARAMS;
>>>>>>>>> + goto response;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + psm = req->psm;
>>>>>>>>> + credits = 0;
>>>>>>>>> +
>>>>>>>>> + BT_DBG("psm 0x%2.2x mtu %u mps %u", __le16_to_cpu(psm), mtu, mps);
>>>>>>>>> +
>>>>>>>>> + memset(&pdu, 0, sizeof(pdu));
>>>>>>>>> +
>>>>>>>>> + /* Check if we have socket listening on psm */
>>>>>>>>> + pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
>>>>>>>>> + &conn->hcon->dst, LE_LINK);
>>>>>>>>> + if (!pchan) {
>>>>>>>>> + result = L2CAP_CR_LE_BAD_PSM;
>>>>>>>>> + goto response;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + mutex_lock(&conn->chan_lock);
>>>>>>>>> + l2cap_chan_lock(pchan);
>>>>>>>>> +
>>>>>>>>> + if (!smp_sufficient_security(conn->hcon, pchan->sec_level,
>>>>>>>>> + SMP_ALLOW_STK)) {
>>>>>>>>> + result = L2CAP_CR_LE_AUTHENTICATION;
>>>>>>>>> + goto unlock;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + result = L2CAP_CR_LE_SUCCESS;
>>>>>>>>> +
>>>>>>>>> + for (i = 0, cmd_len -= sizeof(req); cmd_len >= sizeof(u16);
>>>>>>>>> + i++, cmd_len -= sizeof(u16)) {
>>>>>>>>
>>>>>>>> Can we simplify the loop statement or switch to while statement?
>>>>>>>>
>>>>>>>>> + u16 scid = __le16_to_cpu(req->scid[i]);
>>>>>>>>> +
>>>>>>>>> + BT_DBG("scid[%d] 0x%4.4x", i, scid);
>>>>>>>>> +
>>>>>>>>> + pdu.dcid[i] = 0x0000;
>>>>>>>>> + len += sizeof(*pdu.dcid);
>>>>>>>>> +
>>>>>>>>> + /* Check for valid dynamic CID range */
>>>>>>>>> + if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_LE_DYN_END) {
>>>>>>>>> + result = L2CAP_CR_LE_INVALID_SCID;
>>>>>>>>> + continue;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + /* Check if we already have channel with that dcid */
>>>>>>>>> + if (__l2cap_get_chan_by_dcid(conn, scid)) {
>>>>>>>>> + result = L2CAP_CR_LE_SCID_IN_USE;
>>>>>>>>> + continue;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + chan = pchan->ops->new_connection(pchan);
>>>>>>>>> + if (!chan) {
>>>>>>>>> + result = L2CAP_CR_LE_NO_MEM;
>>>>>>>>> + continue;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + bacpy(&chan->src, &conn->hcon->src);
>>>>>>>>> + bacpy(&chan->dst, &conn->hcon->dst);
>>>>>>>>> + chan->src_type = bdaddr_src_type(conn->hcon);
>>>>>>>>> + chan->dst_type = bdaddr_dst_type(conn->hcon);
>>>>>>>>> + chan->psm = psm;
>>>>>>>>> + chan->dcid = scid;
>>>>>>>>> + chan->omtu = mtu;
>>>>>>>>> + chan->remote_mps = mps;
>>>>>>>>> +
>>>>>>>>> + __l2cap_chan_add(conn, chan);
>>>>>>>>> +
>>>>>>>>> + l2cap_ecred_init(chan, __le16_to_cpu(req->credits));
>>>>>>>>> +
>>>>>>>>> + /* Init response */
>>>>>>>>> + if (!pdu.rsp.credits) {
>>>>>>>>> + pdu.rsp.mtu = cpu_to_le16(chan->imtu);
>>>>>>>>> + pdu.rsp.mps = cpu_to_le16(chan->mps);
>>>>>>>>> + pdu.rsp.credits = cpu_to_le16(chan->rx_credits);
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + pdu.dcid[i] = cpu_to_le16(chan->scid);
>>>>>>>>> +
>>>>>>>>> + __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
>>>>>>>>> +
>>>>>>>>> + chan->ident = cmd->ident;
>>>>>>>>> +
>>>>>>>>> + if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
>>>>>>>>> + l2cap_state_change(chan, BT_CONNECT2);
>>>>>>>>> + defer = true;
>>>>>>>>> + chan->ops->defer(chan);
>>>>>>>>> + } else {
>>>>>>>>> + l2cap_chan_ready(chan);
>>>>>>>>> + }
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> +unlock:
>>>>>>>>> + l2cap_chan_unlock(pchan);
>>>>>>>>> + mutex_unlock(&conn->chan_lock);
>>>>>>>>> + l2cap_chan_put(pchan);
>>>>>>>>> +
>>>>>>>>> +response:
>>>>>>>>> + pdu.rsp.result = cpu_to_le16(result);
>>>>>>>>> +
>>>>>>>>> + if (defer)
>>>>>>>>> + return 0;
>>>>>>>>> +
>>>>>>>>> + l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_CONN_RSP,
>>>>>>>>> + sizeof(pdu.rsp) + len, &pdu);
>>>>>>>>> +
>>>>>>>>> + return 0;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> +static inline int l2cap_ecred_conn_rsp(struct l2cap_conn *conn,
>>>>>>>>> + struct l2cap_cmd_hdr *cmd, u16 cmd_len,
>>>>>>>>> + u8 *data)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_ecred_conn_rsp *rsp = (void *) data;
>>>>>>>>> + struct hci_conn *hcon = conn->hcon;
>>>>>>>>> + u16 mtu, mps, credits, result;
>>>>>>>>> + struct l2cap_chan *chan;
>>>>>>>>> + int err = 0, sec_level;
>>>>>>>>> + int i = 0;
>>>>>>>>> +
>>>>>>>>> + if (cmd_len < sizeof(*rsp))
>>>>>>>>> + return -EPROTO;
>>>>>>>>> +
>>>>>>>>> + mtu = __le16_to_cpu(rsp->mtu);
>>>>>>>>> + mps = __le16_to_cpu(rsp->mps);
>>>>>>>>> + credits = __le16_to_cpu(rsp->credits);
>>>>>>>>> + result = __le16_to_cpu(rsp->result);
>>>>>>>>> +
>>>>>>>>> + BT_DBG("mtu %u mps %u credits %u result 0x%4.4x", mtu, mps, credits,
>>>>>>>>> + result);
>>>>>>>>> +
>>>>>>>>> + mutex_lock(&conn->chan_lock);
>>>>>>>>> +
>>>>>>>>> + cmd_len -= sizeof(*rsp);
>>>>>>>>> +
>>>>>>>>> + list_for_each_entry(chan, &conn->chan_l, list) {
>>>>>>>>> + u16 dcid;
>>>>>>>>> +
>>>>>>>>> + if (chan->ident != cmd->ident ||
>>>>>>>>> + chan->mode != L2CAP_MODE_EXT_FLOWCTL ||
>>>>>>>>> + chan->state == BT_CONNECTED)
>>>>>>>>> + continue;
>>>>>>>>> +
>>>>>>>>> + l2cap_chan_lock(chan);
>>>>>>>>> +
>>>>>>>>> + /* Check that there is a dcid for each pending channel */
>>>>>>>>> + if (cmd_len < sizeof(dcid)) {
>>>>>>>>> + l2cap_chan_del(chan, ECONNREFUSED);
>>>>>>>>> + l2cap_chan_unlock(chan);
>>>>>>>>> + continue;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + dcid = __le16_to_cpu(rsp->dcid[i++]);
>>>>>>>>> + cmd_len -= sizeof(u16);
>>>>>>>>> +
>>>>>>>>> + BT_DBG("dcid[%d] 0x%4.4x", i, dcid);
>>>>>>>>> +
>>>>>>>>> + /* Check if dcid is already in use */
>>>>>>>>> + if (dcid && __l2cap_get_chan_by_dcid(conn, dcid)) {
>>>>>>>>> + /* If a device receives a
>>>>>>>>> + * L2CAP_CREDIT_BASED_CONNECTION_RSP packet with an
>>>>>>>>> + * already-assigned Destination CID, then both the
>>>>>>>>> + * original channel and the new channel shall be
>>>>>>>>> + * immediately discarded and not used.
>>>>>>>>> + */
>>>>>>>>> + l2cap_chan_del(chan, ECONNREFUSED);
>>>>>>>>> + l2cap_chan_unlock(chan);
>>>>>>>>> + chan = __l2cap_get_chan_by_dcid(conn, dcid);
>>>>>>>>> + l2cap_chan_lock(chan);
>>>>>>>>> + l2cap_chan_del(chan, ECONNRESET);
>>>>>>>>> + l2cap_chan_unlock(chan);
>>>>>>>>> + continue;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + switch (result) {
>>>>>>>>> + case L2CAP_CR_LE_AUTHENTICATION:
>>>>>>>>> + case L2CAP_CR_LE_ENCRYPTION:
>>>>>>>>> + /* If we already have MITM protection we can't do
>>>>>>>>> + * anything.
>>>>>>>>> + */
>>>>>>>>> + if (hcon->sec_level > BT_SECURITY_MEDIUM) {
>>>>>>>>> + l2cap_chan_del(chan, ECONNREFUSED);
>>>>>>>>> + break;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + sec_level = hcon->sec_level + 1;
>>>>>>>>> + if (chan->sec_level < sec_level)
>>>>>>>>> + chan->sec_level = sec_level;
>>>>>>>>> +
>>>>>>>>> + /* We'll need to send a new Connect Request */
>>>>>>>>> + clear_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags);
>>>>>>>>> +
>>>>>>>>> + smp_conn_security(hcon, chan->sec_level);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> + case L2CAP_CR_LE_BAD_PSM:
>>>>>>>>> + l2cap_chan_del(chan, ECONNREFUSED);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> + default:
>>>>>>>>> + /* If dcid was not set it means channels was refused */
>>>>>>>>> + if (!dcid) {
>>>>>>>>> + l2cap_chan_del(chan, ECONNREFUSED);
>>>>>>>>> + break;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + chan->ident = 0;
>>>>>>>>> + chan->dcid = dcid;
>>>>>>>>> + chan->omtu = mtu;
>>>>>>>>> + chan->remote_mps = mps;
>>>>>>>>> + chan->tx_credits = credits;
>>>>>>>>> + l2cap_chan_ready(chan);
>>>>>>>>> + break;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + l2cap_chan_unlock(chan);
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + mutex_unlock(&conn->chan_lock);
>>>>>>>>> +
>>>>>>>>> + return err;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> +static inline int l2cap_ecred_reconf_req(struct l2cap_conn *conn,
>>>>>>>>> + struct l2cap_cmd_hdr *cmd, u16 cmd_len,
>>>>>>>>> + u8 *data)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_ecred_reconf_req *req = (void *) data;
>>>>>>>>> + struct l2cap_ecred_reconf_rsp rsp;
>>>>>>>>> + u16 mtu, mps, result;
>>>>>>>>> + struct l2cap_chan *chan;
>>>>>>>>> + int i;
>>>>>>>>> +
>>>>>>>>> + if (cmd_len < sizeof(*req)) {
>>>>>>>>> + result = L2CAP_CR_LE_INVALID_PARAMS;
>>>>>>>>> + goto respond;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + mtu = __le16_to_cpu(req->mtu);
>>>>>>>>> + mps = __le16_to_cpu(req->mps);
>>>>>>>>> +
>>>>>>>>> + BT_DBG("mtu %u mps %u", mtu, mps);
>>>>>>>>> +
>>>>>>>>> + if (mtu < L2CAP_ECRED_MIN_MTU) {
>>>>>>>>> + result = L2CAP_RECONF_INVALID_MTU;
>>>>>>>>> + goto respond;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + if (mps < L2CAP_ECRED_MIN_MPS) {
>>>>>>>>> + result = L2CAP_RECONF_INVALID_MPS;
>>>>>>>>> + goto respond;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + result = L2CAP_RECONF_SUCCESS;
>>>>>>>>> +
>>>>>>>>> + for (i = 0, cmd_len -= sizeof(*req); cmd_len < sizeof(u16);
>>>>>>>>> + i++, cmd_len -= sizeof(u16)) {
>>>>>>>>
>>>>>>>> Same comment as above.
>>>>>>>>
>>>>>>>>> + u16 scid;
>>>>>>>>> +
>>>>>>>>> + scid = __le16_to_cpu(req->scid[i]);
>>>>>>>>> + if (!scid)
>>>>>>>>> + return -EPROTO;
>>>>>>>>> +
>>>>>>>>> + chan = __l2cap_get_chan_by_dcid(conn, scid);
>>>>>>>>> + if (!chan)
>>>>>>>>> + continue;
>>>>>>>>> +
>>>>>>>>> + /* If the MTU value is decreased for any of the included
>>>>>>>>> + * channels, then the receiver shall disconnect all
>>>>>>>>> + * included channels.
>>>>>>>>> + */
>>>>>>>>> + if (chan->omtu > mtu) {
>>>>>>>>> + BT_ERR("chan %p decreased MTU %u -> %u", chan,
>>>>>>>>> + chan->omtu, mtu);
>>>>>>>>> + result = L2CAP_RECONF_INVALID_MTU;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + chan->omtu = mtu;
>>>>>>>>> + chan->remote_mps = mps;
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> +respond:
>>>>>>>>> + rsp.result = cpu_to_le16(result);
>>>>>>>>> +
>>>>>>>>> + l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_RECONF_RSP, sizeof(rsp),
>>>>>>>>> + &rsp);
>>>>>>>>> +
>>>>>>>>> + return 0;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> +static inline int l2cap_ecred_reconf_rsp(struct l2cap_conn *conn,
>>>>>>>>> + struct l2cap_cmd_hdr *cmd, u16 cmd_len,
>>>>>>>>> + u8 *data)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_chan *chan;
>>>>>>>>> + struct l2cap_ecred_conn_rsp *rsp = (void *) data;
>>>>>>>>> + u16 result;
>>>>>>>>> +
>>>>>>>>> + if (cmd_len < sizeof(*rsp))
>>>>>>>>> + return -EPROTO;
>>>>>>>>> +
>>>>>>>>> + result = __le16_to_cpu(rsp->result);
>>>>>>>>> +
>>>>>>>>> + BT_DBG("result 0x%4.4x", rsp->result);
>>>>>>>>> +
>>>>>>>>> + if (!result)
>>>>>>>>> + return 0;
>>>>>>>>> +
>>>>>>>>> + list_for_each_entry(chan, &conn->chan_l, list) {
>>>>>>>>> + if (chan->ident != cmd->ident)
>>>>>>>>> + continue;
>>>>>>>>> +
>>>>>>>>> + l2cap_chan_del(chan, ECONNRESET);
>>>>>>>>> + }
>>>>>>>>> +
>>>>>>>>> + return 0;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> static inline int l2cap_le_command_rej(struct l2cap_conn *conn,
>>>>>>>>> struct l2cap_cmd_hdr *cmd, u16 cmd_len,
>>>>>>>>> u8 *data)
>>>>>>>>> @@ -5769,6 +6199,22 @@ static inline int l2cap_le_sig_cmd(struct l2cap_conn *conn,
>>>>>>>>> err = l2cap_le_credits(conn, cmd, cmd_len, data);
>>>>>>>>> break;
>>>>>>>>>
>>>>>>>>> + case L2CAP_ECRED_CONN_REQ:
>>>>>>>>> + err = l2cap_ecred_conn_req(conn, cmd, cmd_len, data);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> + case L2CAP_ECRED_CONN_RSP:
>>>>>>>>> + err = l2cap_ecred_conn_rsp(conn, cmd, cmd_len, data);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> + case L2CAP_ECRED_RECONF_REQ:
>>>>>>>>> + err = l2cap_ecred_reconf_req(conn, cmd, cmd_len, data);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> + case L2CAP_ECRED_RECONF_RSP:
>>>>>>>>> + err = l2cap_ecred_reconf_rsp(conn, cmd, cmd_len, data);
>>>>>>>>> + break;
>>>>>>>>> +
>>>>>>>>> case L2CAP_DISCONN_REQ:
>>>>>>>>> err = l2cap_disconnect_req(conn, cmd, cmd_len, data);
>>>>>>>>> break;
>>>>>>>>> @@ -6814,11 +7260,13 @@ static void l2cap_chan_le_send_credits(struct l2cap_chan *chan)
>>>>>>>>> struct l2cap_le_credits pkt;
>>>>>>>>> u16 return_credits;
>>>>>>>>>
>>>>>>>>> - return_credits = ((chan->imtu / chan->mps) + 1) - chan->rx_credits;
>>>>>>>>> + return_credits = (chan->imtu / chan->mps) + 1;
>>>>>>>>>
>>>>>>>>> - if (!return_credits)
>>>>>>>>> + if (chan->rx_credits >= return_credits)
>>>>>>>>> return;
>>>>>>>>>
>>>>>>>>> + return_credits -= chan->rx_credits;
>>>>>>>>> +
>>>>>>>>> BT_DBG("chan %p returning %u credits to sender", chan, return_credits);
>>>>>>>>>
>>>>>>>>> chan->rx_credits += return_credits;
>>>>>>>>> @@ -6831,7 +7279,7 @@ static void l2cap_chan_le_send_credits(struct l2cap_chan *chan)
>>>>>>>>> l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CREDITS, sizeof(pkt), &pkt);
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> -static int l2cap_le_recv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> +static int l2cap_ecred_recv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> {
>>>>>>>>> int err;
>>>>>>>>>
>>>>>>>>> @@ -6846,7 +7294,7 @@ static int l2cap_le_recv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> return err;
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> -static int l2cap_le_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> +static int l2cap_ecred_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> {
>>>>>>>>> int err;
>>>>>>>>>
>>>>>>>>> @@ -6894,7 +7342,7 @@ static int l2cap_le_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> if (skb->len == sdu_len)
>>>>>>>>> - return l2cap_le_recv(chan, skb);
>>>>>>>>> + return l2cap_ecred_recv(chan, skb);
>>>>>>>>>
>>>>>>>>> chan->sdu = skb;
>>>>>>>>> chan->sdu_len = sdu_len;
>>>>>>>>> @@ -6926,7 +7374,7 @@ static int l2cap_le_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
>>>>>>>>> skb = NULL;
>>>>>>>>>
>>>>>>>>> if (chan->sdu->len == chan->sdu_len) {
>>>>>>>>> - err = l2cap_le_recv(chan, chan->sdu);
>>>>>>>>> + err = l2cap_ecred_recv(chan, chan->sdu);
>>>>>>>>> if (!err) {
>>>>>>>>> chan->sdu = NULL;
>>>>>>>>> chan->sdu_last_frag = NULL;
>>>>>>>>> @@ -6987,7 +7435,8 @@ static void l2cap_data_channel(struct l2cap_conn *conn, u16 cid,
>>>>>>>>>
>>>>>>>>> switch (chan->mode) {
>>>>>>>>> case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> - if (l2cap_le_data_rcv(chan, skb) < 0)
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> + if (l2cap_ecred_data_rcv(chan, skb) < 0)
>>>>>>>>> goto drop;
>>>>>>>>>
>>>>>>>>> goto done;
>>>>>>>>> @@ -7214,8 +7663,8 @@ int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
>>>>>>>>> struct hci_dev *hdev;
>>>>>>>>> int err;
>>>>>>>>>
>>>>>>>>> - BT_DBG("%pMR -> %pMR (type %u) psm 0x%2.2x", &chan->src, dst,
>>>>>>>>> - dst_type, __le16_to_cpu(psm));
>>>>>>>>> + BT_DBG("%pMR -> %pMR (type %u) psm 0x%4.4x mode 0x%2.2x", &chan->src,
>>>>>>>>> + dst, dst_type, __le16_to_cpu(psm), chan->mode);
>>>>>>>>>
>>>>>>>>> hdev = hci_get_route(dst, &chan->src, chan->src_type);
>>>>>>>>> if (!hdev)
>>>>>>>>> @@ -7244,6 +7693,8 @@ int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
>>>>>>>>> break;
>>>>>>>>> case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> break;
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> + break;
>>>>>>>>
>>>>>>>> No need to do another break. Just put it under LE_FLOWCTL.
>>>>>>>>
>>>>>>>>> case L2CAP_MODE_ERTM:
>>>>>>>>> case L2CAP_MODE_STREAMING:
>>>>>>>>> if (!disable_ertm)
>>>>>>>>> @@ -7368,6 +7819,38 @@ int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
>>>>>>>>> }
>>>>>>>>> EXPORT_SYMBOL_GPL(l2cap_chan_connect);
>>>>>>>>>
>>>>>>>>> +static void l2cap_ecred_reconfigure(struct l2cap_chan *chan)
>>>>>>>>> +{
>>>>>>>>> + struct l2cap_conn *conn = chan->conn;
>>>>>>>>> + struct {
>>>>>>>>> + struct l2cap_ecred_reconf_req req;
>>>>>>>>> + __le16 scid;
>>>>>>>>> + } pdu;
>>>>>>>>> +
>>>>>>>>> + pdu.req.mtu = cpu_to_le16(chan->imtu);
>>>>>>>>> + pdu.req.mps = cpu_to_le16(chan->mps);
>>>>>>>>> + pdu.scid = cpu_to_le16(chan->scid);
>>>>>>>>> +
>>>>>>>>> + chan->ident = l2cap_get_ident(conn);
>>>>>>>>> +
>>>>>>>>> + l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_RECONF_REQ,
>>>>>>>>> + sizeof(pdu), &pdu);
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> +int l2cap_chan_reconfigure(struct l2cap_chan *chan, __u16 mtu)
>>>>>>>>> +{
>>>>>>>>> + if (chan->imtu > mtu)
>>>>>>>>> + return -EINVAL;
>>>>>>>>> +
>>>>>>>>> + BT_DBG("chan %p mtu 0x%4.4x", chan, mtu);
>>>>>>>>> +
>>>>>>>>> + chan->imtu = mtu;
>>>>>>>>> +
>>>>>>>>> + l2cap_ecred_reconfigure(chan);
>>>>>>>>> +
>>>>>>>>> + return 0;
>>>>>>>>> +}
>>>>>>>>> +
>>>>>>>>> /* ---- L2CAP interface with lower layer (HCI) ---- */
>>>>>>>>>
>>>>>>>>> int l2cap_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr)
>>>>>>>>> @@ -7579,7 +8062,8 @@ static void l2cap_security_cfm(struct hci_conn *hcon, u8 status, u8 encrypt)
>>>>>>>>> else
>>>>>>>>> __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
>>>>>>>>> } else if (chan->state == BT_CONNECT2 &&
>>>>>>>>> - chan->mode != L2CAP_MODE_LE_FLOWCTL) {
>>>>>>>>> + !(chan->mode == L2CAP_MODE_EXT_FLOWCTL ||
>>>>>>>>> + chan->mode == L2CAP_MODE_LE_FLOWCTL)) {
>>>>>>>>
>>>>>>>> Please double check that this line is correctly aligned after the (.
>>>>>>>>
>>>>>>>>> struct l2cap_conn_rsp rsp;
>>>>>>>>> __u16 res, stat;
>>>>>>>>>
>>>>>>>>> diff --git a/net/bluetooth/l2cap_sock.c b/net/bluetooth/l2cap_sock.c
>>>>>>>>> index a7be8b59b3c2..12c557f7f40f 100644
>>>>>>>>> --- a/net/bluetooth/l2cap_sock.c
>>>>>>>>> +++ b/net/bluetooth/l2cap_sock.c
>>>>>>>>> @@ -232,7 +232,7 @@ static int l2cap_sock_connect(struct socket *sock, struct sockaddr *addr,
>>>>>>>>> return -EINVAL;
>>>>>>>>> }
>>>>>>>>>
>>>>>>>>> - if (chan->psm && bdaddr_type_is_le(chan->src_type))
>>>>>>>>> + if (chan->psm && bdaddr_type_is_le(chan->src_type) && !chan->mode)
>>>>>>>>> chan->mode = L2CAP_MODE_LE_FLOWCTL;
>>>>>>>>>
>>>>>>>>> err = l2cap_chan_connect(chan, la.l2_psm, __le16_to_cpu(la.l2_cid),
>>>>>>>>> @@ -273,6 +273,7 @@ static int l2cap_sock_listen(struct socket *sock, int backlog)
>>>>>>>>> switch (chan->mode) {
>>>>>>>>> case L2CAP_MODE_BASIC:
>>>>>>>>> case L2CAP_MODE_LE_FLOWCTL:
>>>>>>>>> + case L2CAP_MODE_EXT_FLOWCTL:
>>>>>>>>> break;
>>>>>>>>> case L2CAP_MODE_ERTM:
>>>>>>>>> case L2CAP_MODE_STREAMING:
>>>>>>>>> @@ -408,16 +409,6 @@ static int l2cap_sock_getsockopt_old(struct socket *sock, int optname,
>>>>>>>>>
>>>>>>>>> switch (optname) {
>>>>>>>>> case L2CAP_OPTIONS:
>>>>>>>>> - /* LE sockets should use BT_SNDMTU/BT_RCVMTU, but since
>>>>>>>>> - * legacy ATT code depends on getsockopt for
>>>>>>>>> - * L2CAP_OPTIONS we need to let this pass.
>>>>>>>>> - */
>>>>>>>>> - if (bdaddr_type_is_le(chan->src_type) &&
>>>>>>>>> - chan->scid != L2CAP_CID_ATT) {
>>>>>>>>> - err = -EINVAL;
>>>>>>>>> - break;
>>>>>>>>> - }
>>>>>>>>> -
>>>>>>>>
>>>>>>>> Should this be a separate patch. How do we keep this legacy behavior.
>>>>>>>
>>>>>>> I kind have forgotten to fix this one, I guess we will need a new
>>>>>>> option in order to read the mode without using the old L2CAP_OPTIONS
>>>>>>> then, or do you have anything against introducing yet another option?
>>>>>>
>>>>>> so what is the problem here? Is this because L2CAP by itself can not tell if enhanced credit mode is supported by the peer?
>>>>>
>>>>> Yep, afaik there is no means to detect the support transparently,
>>>>> otherwise could always prefer to use EXT_FLOWCTL instead of
>>>>> LE_FLOWCTL, it seems at the point we introduced LE_FLOWCTL option we
>>>>> had always assumed there would not be any mode one could use when the
>>>>> address type is LE.
>>>>>
>>>>>> Do you actually want to create a new mode socket options with defined values by us to allow selected the mode of operation?
>>>>>
>>>>> I woud assume that is the only safe option here, though what I did was
>>>>> to enable L2CAP_OPTIONS to work with LE addresses which I assume is
>>>>> safe as previously it would cause an error no one would be using it.
>>>>
>>>> that is what I was afraid of. So can we use BT_SNDMTU and BT_RCVMTU and then only a mode property is missing? Or do we have other options that we want to configure.
>>>
>>> Not sure I follow, do you prefer chaning an existing option to add a
>>> new field? I though having an option to set the mode would be better
>>> but perhaps you want to combine it something else, well maybe some
>>> sort of QOS interface, the problem is that the field are quite
>>> different depending on the mode so Im afraid that would take a lot
>>> more time to define.
>>
>> Let me ask this differently. What options do we want to be able to configure if we deprecate L2CAP_OPTIONS?
>
> Coming back to this perhaps we could infer the mode if in case there
> are multiple connection being made, the only question is if the spec
> actually allow connection with the lagacy command if the remote side
> is listen on PSM that is for ECRED mode like EATT, if it does require
> maybe we can use BT_DEFER_SETUP to trigger it but I don't really like
> reusing BT_DEFER_SETUP like that since it was introduced for a very
> different purpose it may confuse people.
you still haven’t answered my question. What kind of options do we want the socket user to configure?
>> Anyhow, maybe we first introduce a debugfs option that says attempt_ecred_mode_first and only when the attempt fails fall back to credit based flow control mode.
>
> I was thinking in something like the following so we only use the new
> mode if it is enabled, well provided we can remove it later:
>
> https://gist.github.com/Vudentz/35ca4a39b58e64e8ecbde3ff6ada2d61
That looks fine to me.
>> Btw. do we have at least a supported features bit in L2CAP hinting that ecred mode is supported over BR/EDR. It would be good to have some way of knowing it for BR/EDR ahead of time.
>
> I don't remember it being added, but yes it would make a lot of sense
> to have it when using over BR/EDR.
If not, then we should file an erratum for it.
>>>> For the multi-connect case, I was thinking that we use something similar to DEFER_SETUP. If we set a DEFER_SETUP on an outgoing socket, then you can call connect() on a socket and succeeds. However no POLLIN | POLLOUT would be signaled. When calling a connect() without that option set, then all sockets become ready at the same time on success.
>>>
>>> As initiator I don't think we have a good match in the socket API as
>>> it only return one fd at time, so currently it still doing the
>>> connection one by one, what I though we could do is to delay a little
>>> to group the request in a single L2CAP request, thought that creates
>>> an extra latency for initiating the connection and can be racy.
>>> Another option would be to allow bind to bind to multiple sockets at
>>> once, so when you issue the connect in one socket it would connect all
>>> socket bound.
>>
>> Let me try to explain this in pseudo code.
>>
>> fd1 = socket();
>> setsockopt(fd1, BT_DEFER_SETUP);
>> connect(fd1);
>> 0 = poll(fd1);
>>
>> fd2 = socket();
>> setsockopt(fd2, BT_DEFER_SETUP);
>> connect(fd2);
>> 0 = poll(fd2);
>>
>> fd3 = socket();
>> connect(fd3);
>> POLLOUT = poll(fd1);
>> POLLOUT = poll(fd2);
>> POLLOUT = poll(fd3);
>>
>> Essentially all the connect() call with BT_DEFER_SETUP will succeed, but POLLOUT will not signal. So you have the fd, but you can not write to it. When we have the connect() without BT_DEFER_SETUP set, then L2CAP will connect all channels at the same time and assign them to the given sockets. And now all fds become POLLOUT.
>
> Should work, btw couldn't we just use bind for the first 2 sockets?
> That imo would make things a little cleaner since we only do connect
> when it is really ready to connect and we don't have to even consider
> poll until then, that said we would need to group these sockets either
> way so we need to do this per processs, actually the order would be:
>
> fd# = socket()
> bind(fd#)
> setsockopt(fd#, BT_DEFER_SETUP)
>
> Since bind sets the address then on setsockopt we can check if there
> is anything else pending to be connected for the same address and then
> just proceed.
With bind() you set the local address. With connect() you select the remote address. I don’t see how bind() only would get us there.
And the poll() part is not a problem btw. We should be doing asynchronous write/send anyway. It is just that we have been a bit lazy with some of the protocol implementation and execute write/send right away without checking with poll if the socket is actually writable. If we fix that then this will be all dead simple. It is no different than an asynchronous connect() anyway. There you have to wait for poll() as well. I really doubt we are using blocking connect() calls. And if we do, we need to fix that.
Regards
Marcel
