From mboxrd@z Thu Jan 1 00:00:00 1970 From: Alexander Aring Date: Mon, 19 Oct 2020 14:59:13 -0400 Subject: [Cluster-devel] [PATCH dlm/next 6/9] fs: dlm: move connect callback in node creation In-Reply-To: <20201019185916.707827-1-aahringo@redhat.com> References: <20201019185916.707827-1-aahringo@redhat.com> Message-ID: <20201019185916.707827-7-aahringo@redhat.com> List-Id: To: cluster-devel.redhat.com MIME-Version: 1.0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit This patch moves the assignment for the connect callback to the node creation instead of assign some dummy functionality. The assignment which connect functionality will be used will be detected according to the configfs setting. Signed-off-by: Alexander Aring --- fs/dlm/lowcomms.c | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/fs/dlm/lowcomms.c b/fs/dlm/lowcomms.c index 70a216a20dbb9..e8657ae023654 100644 --- a/fs/dlm/lowcomms.c +++ b/fs/dlm/lowcomms.c @@ -142,6 +142,8 @@ DEFINE_STATIC_SRCU(connections_srcu); static void process_recv_sockets(struct work_struct *work); static void process_send_sockets(struct work_struct *work); +static void sctp_connect_to_sock(struct connection *con); +static void tcp_connect_to_sock(struct connection *con); /* This is deliberately very simple because most clusters have simple sequential nodeids, so we should be able to go straight to a connection @@ -206,11 +208,15 @@ static struct connection *nodeid2con(int nodeid, gfp_t alloc) if (con->nodeid) { struct connection *zerocon = __find_con(0); - con->connect_action = zerocon->connect_action; if (!con->rx_action) con->rx_action = zerocon->rx_action; } + if (dlm_config.ci_protocol == 0) + con->connect_action = tcp_connect_to_sock; + else + con->connect_action = sctp_connect_to_sock; + r = nodeid_hash(nodeid); spin_lock(&connections_lock); @@ -1009,7 +1015,6 @@ static void sctp_connect_to_sock(struct connection *con) sock_set_mark(sock->sk, mark); con->rx_action = receive_from_sock; - con->connect_action = sctp_connect_to_sock; add_sock(sock, con); /* Bind to all addresses. */ @@ -1107,7 +1112,6 @@ static void tcp_connect_to_sock(struct connection *con) } con->rx_action = receive_from_sock; - con->connect_action = tcp_connect_to_sock; con->shutdown_action = dlm_tcp_shutdown; add_sock(sock, con); @@ -1195,7 +1199,6 @@ static struct socket *tcp_create_listen_sock(struct connection *con, sock->sk->sk_user_data = con; save_listen_callbacks(sock); con->rx_action = accept_from_sock; - con->connect_action = tcp_connect_to_sock; write_unlock_bh(&sock->sk->sk_callback_lock); /* Bind to our port */ @@ -1278,7 +1281,6 @@ static int sctp_listen_for_all(void) con->sock = sock; con->sock->sk->sk_data_ready = lowcomms_data_ready; con->rx_action = accept_from_sock; - con->connect_action = sctp_connect_to_sock; write_unlock_bh(&sock->sk->sk_callback_lock); -- 2.26.2