net/smc: remove close abort worker

With the introduction of the link group termination worker there is
no longer a need to postpone smc_close_active_abort() to a worker.
To protect socket destruction due to normal and abnormal socket
closing, the socket refcount is increased.

Signed-off-by: Ursula Braun <ubraun@linux.ibm.com>
Signed-off-by: Karsten Graul <kgraul@linux.ibm.com>
Signed-off-by: Jakub Kicinski <jakub.kicinski@netronome.com>

diff --git a/net/smc/af_smc.c b/net/smc/af_smc.c
index 5b932583e4076feacb786d315bc4d6181fd9a17b..91ea098fabd9a28c2e3c81ad2cdd2a7b0772df9d 100644 (file)
--- a/net/smc/af_smc.c
+++ b/net/smc/af_smc.c
@@ -167,6 +167,7 @@ static int smc_release(struct socket *sock)
        if (!sk)
                goto out;
 
+       sock_hold(sk); /* sock_put below */
        smc = smc_sk(sk);
 
        /* cleanup for a dangling non-blocking connect */
@@ -189,6 +190,7 @@ static int smc_release(struct socket *sock)
        sock->sk = NULL;
        release_sock(sk);
 
+       sock_put(sk); /* sock_hold above */
        sock_put(sk); /* final sock_put */
 out:
        return rc;
@@ -970,12 +972,14 @@ void smc_close_non_accepted(struct sock *sk)
 {
        struct smc_sock *smc = smc_sk(sk);
 
+       sock_hold(sk); /* sock_put below */
        lock_sock(sk);
        if (!sk->sk_lingertime)
                /* wait for peer closing */
                sk->sk_lingertime = SMC_MAX_STREAM_WAIT_TIMEOUT;
        __smc_release(smc);
        release_sock(sk);
+       sock_put(sk); /* sock_hold above */
        sock_put(sk); /* final sock_put */
 }
 

diff --git a/net/smc/smc_close.c b/net/smc/smc_close.c
index 2bbcd45a421e75e27814ffcfde2af55b2385501f..d34e5adce2eb314196ea36a9414ec63600e67db1 100644 (file)
--- a/net/smc/smc_close.c
+++ b/net/smc/smc_close.c
@@ -113,9 +113,10 @@ int smc_close_abort(struct smc_connection *conn)
 /* terminate smc socket abnormally - active abort
  * link group is terminated, i.e. RDMA communication no longer possible
  */
-static void smc_close_active_abort(struct smc_sock *smc)
+void smc_close_active_abort(struct smc_sock *smc)
 {
        struct sock *sk = &smc->sk;
+       bool release_clcsock = false;
 
        if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) {
                sk->sk_err = ECONNABORTED;
@@ -137,11 +138,14 @@ static void smc_close_active_abort(struct smc_sock *smc)
                cancel_delayed_work_sync(&smc->conn.tx_work);
                lock_sock(sk);
                sk->sk_state = SMC_CLOSED;
+               sock_put(sk); /* postponed passive closing */
                break;
        case SMC_PEERCLOSEWAIT1:
        case SMC_PEERCLOSEWAIT2:
        case SMC_PEERFINCLOSEWAIT:
                sk->sk_state = SMC_CLOSED;
+               smc_conn_free(&smc->conn);
+               release_clcsock = true;
                sock_put(sk); /* passive closing */
                break;
        case SMC_PROCESSABORT:
@@ -156,6 +160,12 @@ static void smc_close_active_abort(struct smc_sock *smc)
 
        sock_set_flag(sk, SOCK_DEAD);
        sk->sk_state_change(sk);
+
+       if (release_clcsock) {
+               release_sock(sk);
+               smc_clcsock_release(smc);
+               lock_sock(sk);
+       }
 }
 
 static inline bool smc_close_sent_any_close(struct smc_connection *conn)
@@ -328,12 +338,6 @@ static void smc_close_passive_work(struct work_struct *work)
        lock_sock(sk);
        old_state = sk->sk_state;
 
-       if (conn->killed) {
-               /* abnormal termination */
-               smc_close_active_abort(smc);
-               goto wakeup;
-       }
-
        rxflags = &conn->local_rx_ctrl.conn_state_flags;
        if (rxflags->peer_conn_abort) {
                /* peer has not received all data */

diff --git a/net/smc/smc_close.h b/net/smc/smc_close.h
index 084c4f37aa963577edcb21191cb45833d6df2557..634fea2b7c95b1bbbae77653c4b0373fa9428413 100644 (file)
--- a/net/smc/smc_close.h
+++ b/net/smc/smc_close.h
@@ -25,5 +25,6 @@ int smc_close_shutdown_write(struct smc_sock *smc);
 void smc_close_init(struct smc_sock *smc);
 void smc_clcsock_release(struct smc_sock *smc);
 int smc_close_abort(struct smc_connection *conn);
+void smc_close_active_abort(struct smc_sock *smc);
 
 #endif /* SMC_CLOSE_H */

diff --git a/net/smc/smc_core.c b/net/smc/smc_core.c
index 46d4b944c4c436d940197901e7883aba84ca0018..ed02eac636da1a9685b37c112eeb3d0ba470d44b 100644 (file)
--- a/net/smc/smc_core.c
+++ b/net/smc/smc_core.c
@@ -519,9 +519,7 @@ static void smc_conn_kill(struct smc_connection *conn)
        smc_sk_wake_ups(smc);
        smc_lgr_unregister_conn(conn);
        smc->sk.sk_err = ECONNABORTED;
-       sock_hold(&smc->sk); /* sock_put in close work */
-       if (!schedule_work(&conn->close_work))
-               sock_put(&smc->sk);
+       smc_close_active_abort(smc);
 }
 
 /* terminate link group */
@@ -544,9 +542,11 @@ static void __smc_lgr_terminate(struct smc_link_group *lgr)
                read_unlock_bh(&lgr->conns_lock);
                conn = rb_entry(node, struct smc_connection, alert_node);
                smc = container_of(conn, struct smc_sock, conn);
+               sock_hold(&smc->sk); /* sock_put below */
                lock_sock(&smc->sk);
                smc_conn_kill(conn);
                release_sock(&smc->sk);
+               sock_put(&smc->sk); /* sock_hold above */
                read_lock_bh(&lgr->conns_lock);
                node = rb_first(&lgr->conns_all);
        }