Skip to content

Commit 77e6077

Browse files
author
Paolo Abeni
committed
Merge branch 'two-fixes-for-smc'
Wen Gu says: ==================== two fixes for SMC This patch set contains two bugfixes, to fix SMC warning and panic issues in race conditions. ==================== Link: https://patch.msgid.link/20241127133014.100509-1-guwen@linux.alibaba.com Signed-off-by: Paolo Abeni <pabeni@redhat.com>
2 parents 6a2fa13 + 2c7f14e commit 77e6077

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

net/smc/af_smc.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -383,6 +383,7 @@ void smc_sk_init(struct net *net, struct sock *sk, int protocol)
383383
smc->limit_smc_hs = net->smc.limit_smc_hs;
384384
smc->use_fallback = false; /* assume rdma capability first */
385385
smc->fallback_rsn = 0;
386+
smc_close_init(smc);
386387
}
387388

388389
static struct sock *smc_sock_alloc(struct net *net, struct socket *sock,
@@ -1299,7 +1300,6 @@ static int smc_connect_rdma(struct smc_sock *smc,
12991300
goto connect_abort;
13001301
}
13011302

1302-
smc_close_init(smc);
13031303
smc_rx_init(smc);
13041304

13051305
if (ini->first_contact_local) {
@@ -1435,7 +1435,6 @@ static int smc_connect_ism(struct smc_sock *smc,
14351435
goto connect_abort;
14361436
}
14371437
}
1438-
smc_close_init(smc);
14391438
smc_rx_init(smc);
14401439
smc_tx_init(smc);
14411440

@@ -1901,6 +1900,7 @@ static void smc_listen_out(struct smc_sock *new_smc)
19011900
if (tcp_sk(new_smc->clcsock->sk)->syn_smc)
19021901
atomic_dec(&lsmc->queued_smc_hs);
19031902

1903+
release_sock(newsmcsk); /* lock in smc_listen_work() */
19041904
if (lsmc->sk.sk_state == SMC_LISTEN) {
19051905
lock_sock_nested(&lsmc->sk, SINGLE_DEPTH_NESTING);
19061906
smc_accept_enqueue(&lsmc->sk, newsmcsk);
@@ -2422,6 +2422,7 @@ static void smc_listen_work(struct work_struct *work)
24222422
u8 accept_version;
24232423
int rc = 0;
24242424

2425+
lock_sock(&new_smc->sk); /* release in smc_listen_out() */
24252426
if (new_smc->listen_smc->sk.sk_state != SMC_LISTEN)
24262427
return smc_listen_out_err(new_smc);
24272428

@@ -2479,7 +2480,6 @@ static void smc_listen_work(struct work_struct *work)
24792480
goto out_decl;
24802481

24812482
mutex_lock(&smc_server_lgr_pending);
2482-
smc_close_init(new_smc);
24832483
smc_rx_init(new_smc);
24842484
smc_tx_init(new_smc);
24852485

0 commit comments

Comments
 (0)