Commit 610db66f authored by Ursula Braun's avatar Ursula Braun Committed by David S. Miller

net/smc: do not reuse a linkgroup with setup problems

Once a linkgroup is created successfully, it stays alive for a
certain time to service more connections potentially created.
If one of the initialization steps for a new linkgroup fails,
the linkgroup should not be reused by other connections following.
Signed-off-by: default avatarUrsula Braun <ubraun@linux.vnet.ibm.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent b4772b3a
...@@ -377,6 +377,15 @@ static void smc_link_save_peer_info(struct smc_link *link, ...@@ -377,6 +377,15 @@ static void smc_link_save_peer_info(struct smc_link *link,
link->peer_mtu = clc->qp_mtu; link->peer_mtu = clc->qp_mtu;
} }
static void smc_lgr_forget(struct smc_link_group *lgr)
{
spin_lock_bh(&smc_lgr_list.lock);
/* do not use this link group for new connections */
if (!list_empty(&lgr->list))
list_del_init(&lgr->list);
spin_unlock_bh(&smc_lgr_list.lock);
}
/* setup for RDMA connection of client */ /* setup for RDMA connection of client */
static int smc_connect_rdma(struct smc_sock *smc) static int smc_connect_rdma(struct smc_sock *smc)
{ {
...@@ -513,6 +522,8 @@ static int smc_connect_rdma(struct smc_sock *smc) ...@@ -513,6 +522,8 @@ static int smc_connect_rdma(struct smc_sock *smc)
return rc ? rc : local_contact; return rc ? rc : local_contact;
decline_rdma_unlock: decline_rdma_unlock:
if (local_contact == SMC_FIRST_CONTACT)
smc_lgr_forget(smc->conn.lgr);
mutex_unlock(&smc_create_lgr_pending); mutex_unlock(&smc_create_lgr_pending);
smc_conn_free(&smc->conn); smc_conn_free(&smc->conn);
decline_rdma: decline_rdma:
...@@ -526,6 +537,8 @@ static int smc_connect_rdma(struct smc_sock *smc) ...@@ -526,6 +537,8 @@ static int smc_connect_rdma(struct smc_sock *smc)
goto out_connected; goto out_connected;
out_err_unlock: out_err_unlock:
if (local_contact == SMC_FIRST_CONTACT)
smc_lgr_forget(smc->conn.lgr);
mutex_unlock(&smc_create_lgr_pending); mutex_unlock(&smc_create_lgr_pending);
smc_conn_free(&smc->conn); smc_conn_free(&smc->conn);
out_err: out_err:
...@@ -906,6 +919,8 @@ static void smc_listen_work(struct work_struct *work) ...@@ -906,6 +919,8 @@ static void smc_listen_work(struct work_struct *work)
return; return;
decline_rdma_unlock: decline_rdma_unlock:
if (local_contact == SMC_FIRST_CONTACT)
smc_lgr_forget(new_smc->conn.lgr);
mutex_unlock(&smc_create_lgr_pending); mutex_unlock(&smc_create_lgr_pending);
decline_rdma: decline_rdma:
/* RDMA setup failed, switch back to TCP */ /* RDMA setup failed, switch back to TCP */
...@@ -918,6 +933,8 @@ static void smc_listen_work(struct work_struct *work) ...@@ -918,6 +933,8 @@ static void smc_listen_work(struct work_struct *work)
goto out_connected; goto out_connected;
out_err_unlock: out_err_unlock:
if (local_contact == SMC_FIRST_CONTACT)
smc_lgr_forget(new_smc->conn.lgr);
mutex_unlock(&smc_create_lgr_pending); mutex_unlock(&smc_create_lgr_pending);
out_err: out_err:
newsmcsk->sk_state = SMC_CLOSED; newsmcsk->sk_state = SMC_CLOSED;
......
...@@ -128,6 +128,8 @@ static void smc_lgr_free_work(struct work_struct *work) ...@@ -128,6 +128,8 @@ static void smc_lgr_free_work(struct work_struct *work)
bool conns; bool conns;
spin_lock_bh(&smc_lgr_list.lock); spin_lock_bh(&smc_lgr_list.lock);
if (list_empty(&lgr->list))
goto free;
read_lock_bh(&lgr->conns_lock); read_lock_bh(&lgr->conns_lock);
conns = RB_EMPTY_ROOT(&lgr->conns_all); conns = RB_EMPTY_ROOT(&lgr->conns_all);
read_unlock_bh(&lgr->conns_lock); read_unlock_bh(&lgr->conns_lock);
...@@ -136,6 +138,7 @@ static void smc_lgr_free_work(struct work_struct *work) ...@@ -136,6 +138,7 @@ static void smc_lgr_free_work(struct work_struct *work)
return; return;
} }
list_del_init(&lgr->list); /* remove from smc_lgr_list */ list_del_init(&lgr->list); /* remove from smc_lgr_list */
free:
spin_unlock_bh(&smc_lgr_list.lock); spin_unlock_bh(&smc_lgr_list.lock);
smc_lgr_free(lgr); smc_lgr_free(lgr);
} }
......
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