OSDN Git Service

net/smc: tell peers about abnormal link group termination
authorUrsula Braun <ubraun@linux.ibm.com>
Mon, 21 Oct 2019 14:13:12 +0000 (16:13 +0200)
committerJakub Kicinski <jakub.kicinski@netronome.com>
Tue, 22 Oct 2019 18:23:43 +0000 (11:23 -0700)
There are lots of link group termination scenarios. Most of them
still allow to inform the peer of the terminating sockets about aborting.
This patch tries to call smc_close_abort() for terminating sockets.

And the internal TCP socket is reset with tcp_abort().

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>
net/smc/smc_close.c
net/smc/smc_close.h
net/smc/smc_core.c

index 1d706c5..2bbcd45 100644 (file)
@@ -13,6 +13,7 @@
 #include <linux/sched/signal.h>
 
 #include <net/sock.h>
+#include <net/tcp.h>
 
 #include "smc.h"
 #include "smc_tx.h"
@@ -102,7 +103,7 @@ static int smc_close_final(struct smc_connection *conn)
        return smc_cdc_get_slot_and_msg_send(conn);
 }
 
-static int smc_close_abort(struct smc_connection *conn)
+int smc_close_abort(struct smc_connection *conn)
 {
        conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1;
 
@@ -118,10 +119,8 @@ static void smc_close_active_abort(struct smc_sock *smc)
 
        if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) {
                sk->sk_err = ECONNABORTED;
-               if (smc->clcsock && smc->clcsock->sk) {
-                       smc->clcsock->sk->sk_err = ECONNABORTED;
-                       smc->clcsock->sk->sk_state_change(smc->clcsock->sk);
-               }
+               if (smc->clcsock && smc->clcsock->sk)
+                       tcp_abort(smc->clcsock->sk, ECONNABORTED);
        }
        switch (sk->sk_state) {
        case SMC_ACTIVE:
index e0e3b5d..084c4f3 100644 (file)
@@ -24,5 +24,6 @@ int smc_close_active(struct smc_sock *smc);
 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);
 
 #endif /* SMC_CLOSE_H */
index e7e9dbc..494288f 100644 (file)
@@ -513,8 +513,8 @@ static void __smc_lgr_terminate(struct smc_link_group *lgr)
                smc = container_of(conn, struct smc_sock, conn);
                lock_sock(&smc->sk);
                sock_hold(&smc->sk); /* sock_put in close work */
+               smc_close_abort(conn);
                conn->killed = 1;
-               conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1;
                smc_lgr_unregister_conn(conn);
                conn->lgr = NULL;
                if (!schedule_work(&conn->close_work))