Loading net/smc/smc_tx.c +3 −1 Original line number Diff line number Diff line Loading @@ -248,8 +248,10 @@ static int smc_tx_rdma_write(struct smc_connection *conn, int peer_rmbe_offset, peer_rmbe_offset; rdma_wr.rkey = lgr->rtokens[conn->rtoken_idx][SMC_SINGLE_LINK].rkey; rc = ib_post_send(link->roce_qp, &rdma_wr.wr, &failed_wr); if (rc) if (rc) { conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1; smc_lgr_terminate(lgr); } return rc; } Loading net/smc/smc_wr.c +7 −1 Original line number Diff line number Diff line Loading @@ -248,8 +248,14 @@ int smc_wr_tx_send(struct smc_link *link, struct smc_wr_tx_pend_priv *priv) pend = container_of(priv, struct smc_wr_tx_pend, priv); rc = ib_post_send(link->roce_qp, &link->wr_tx_ibs[pend->idx], &failed_wr); if (rc) if (rc) { struct smc_link_group *lgr = container_of(link, struct smc_link_group, lnk[SMC_SINGLE_LINK]); smc_wr_tx_put_slot(link, priv); smc_lgr_terminate(lgr); } return rc; } Loading Loading
net/smc/smc_tx.c +3 −1 Original line number Diff line number Diff line Loading @@ -248,8 +248,10 @@ static int smc_tx_rdma_write(struct smc_connection *conn, int peer_rmbe_offset, peer_rmbe_offset; rdma_wr.rkey = lgr->rtokens[conn->rtoken_idx][SMC_SINGLE_LINK].rkey; rc = ib_post_send(link->roce_qp, &rdma_wr.wr, &failed_wr); if (rc) if (rc) { conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1; smc_lgr_terminate(lgr); } return rc; } Loading
net/smc/smc_wr.c +7 −1 Original line number Diff line number Diff line Loading @@ -248,8 +248,14 @@ int smc_wr_tx_send(struct smc_link *link, struct smc_wr_tx_pend_priv *priv) pend = container_of(priv, struct smc_wr_tx_pend, priv); rc = ib_post_send(link->roce_qp, &link->wr_tx_ibs[pend->idx], &failed_wr); if (rc) if (rc) { struct smc_link_group *lgr = container_of(link, struct smc_link_group, lnk[SMC_SINGLE_LINK]); smc_wr_tx_put_slot(link, priv); smc_lgr_terminate(lgr); } return rc; } Loading