mirror of
https://git.kernel.org/pub/scm/linux/kernel/git/stable/linux.git
synced 2024-08-26 19:00:25 +00:00
![Alexander Aring](/assets/img/avatar_default.png)
This patch adds a WARN_ON() check to validate the right context while
dlm_midcomms_close() is called. Even before commit 489d8e559c
("fs: dlm: add reliable connection if reconnect") in this context
dlm_lowcomms_close() flushes all ongoing transmission triggered by dlm
application stack. If we do that, it's required that no new message will
be triggered by the dlm application stack. The function
dlm_midcomms_close() is not called often so we can check if all
lockspaces are in such context.
Signed-off-by: Alexander Aring <aahringo@redhat.com>
Signed-off-by: David Teigland <teigland@redhat.com>
1495 lines
38 KiB
C
1495 lines
38 KiB
C
// SPDX-License-Identifier: GPL-2.0-only
|
|
/******************************************************************************
|
|
*******************************************************************************
|
|
**
|
|
** Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
|
|
** Copyright (C) 2004-2021 Red Hat, Inc. All rights reserved.
|
|
**
|
|
**
|
|
*******************************************************************************
|
|
******************************************************************************/
|
|
|
|
/*
|
|
* midcomms.c
|
|
*
|
|
* This is the appallingly named "mid-level" comms layer. It takes care about
|
|
* deliver an on application layer "reliable" communication above the used
|
|
* lowcomms transport layer.
|
|
*
|
|
* How it works:
|
|
*
|
|
* Each nodes keeps track of all send DLM messages in send_queue with a sequence
|
|
* number. The receive will send an DLM_ACK message back for every DLM message
|
|
* received at the other side. If a reconnect happens in lowcomms we will send
|
|
* all unacknowledged dlm messages again. The receiving side might drop any already
|
|
* received message by comparing sequence numbers.
|
|
*
|
|
* How version detection works:
|
|
*
|
|
* Due the fact that dlm has pre-configured node addresses on every side
|
|
* it is in it's nature that every side connects at starts to transmit
|
|
* dlm messages which ends in a race. However DLM_RCOM_NAMES, DLM_RCOM_STATUS
|
|
* and their replies are the first messages which are exchanges. Due backwards
|
|
* compatibility these messages are not covered by the midcomms re-transmission
|
|
* layer. These messages have their own re-transmission handling in the dlm
|
|
* application layer. The version field of every node will be set on these RCOM
|
|
* messages as soon as they arrived and the node isn't yet part of the nodes
|
|
* hash. There exists also logic to detect version mismatched if something weird
|
|
* going on or the first messages isn't an expected one.
|
|
*
|
|
* Termination:
|
|
*
|
|
* The midcomms layer does a 4 way handshake for termination on DLM protocol
|
|
* like TCP supports it with half-closed socket support. SCTP doesn't support
|
|
* half-closed socket, so we do it on DLM layer. Also socket shutdown() can be
|
|
* interrupted by .e.g. tcp reset itself. Additional there exists the othercon
|
|
* paradigm in lowcomms which cannot be easily without breaking backwards
|
|
* compatibility. A node cannot send anything to another node when a DLM_FIN
|
|
* message was send. There exists additional logic to print a warning if
|
|
* DLM wants to do it. There exists a state handling like RFC 793 but reduced
|
|
* to termination only. The event "member removal event" describes the cluster
|
|
* manager removed the node from internal lists, at this point DLM does not
|
|
* send any message to the other node. There exists two cases:
|
|
*
|
|
* 1. The cluster member was removed and we received a FIN
|
|
* OR
|
|
* 2. We received a FIN but the member was not removed yet
|
|
*
|
|
* One of these cases will do the CLOSE_WAIT to LAST_ACK change.
|
|
*
|
|
*
|
|
* +---------+
|
|
* | CLOSED |
|
|
* +---------+
|
|
* | add member/receive RCOM version
|
|
* | detection msg
|
|
* V
|
|
* +---------+
|
|
* | ESTAB |
|
|
* +---------+
|
|
* CLOSE | | rcv FIN
|
|
* ------- | | -------
|
|
* +---------+ snd FIN / \ snd ACK +---------+
|
|
* | FIN |<----------------- ------------------>| CLOSE |
|
|
* | WAIT-1 |------------------ | WAIT |
|
|
* +---------+ rcv FIN \ +---------+
|
|
* | rcv ACK of FIN ------- | CLOSE | member
|
|
* | -------------- snd ACK | ------- | removal
|
|
* V x V snd FIN V event
|
|
* +---------+ +---------+ +---------+
|
|
* |FINWAIT-2| | CLOSING | | LAST-ACK|
|
|
* +---------+ +---------+ +---------+
|
|
* | rcv ACK of FIN | rcv ACK of FIN |
|
|
* | rcv FIN -------------- | -------------- |
|
|
* | ------- x V x V
|
|
* \ snd ACK +---------+ +---------+
|
|
* ------------------------>| CLOSED | | CLOSED |
|
|
* +---------+ +---------+
|
|
*
|
|
* NOTE: any state can interrupted by midcomms_close() and state will be
|
|
* switched to CLOSED in case of fencing. There exists also some timeout
|
|
* handling when we receive the version detection RCOM messages which is
|
|
* made by observation.
|
|
*
|
|
* Future improvements:
|
|
*
|
|
* There exists some known issues/improvements of the dlm handling. Some
|
|
* of them should be done in a next major dlm version bump which makes
|
|
* it incompatible with previous versions.
|
|
*
|
|
* Unaligned memory access:
|
|
*
|
|
* There exists cases when the dlm message buffer length is not aligned
|
|
* to 8 byte. However seems nobody detected any problem with it. This
|
|
* can be fixed in the next major version bump of dlm.
|
|
*
|
|
* Version detection:
|
|
*
|
|
* The version detection and how it's done is related to backwards
|
|
* compatibility. There exists better ways to make a better handling.
|
|
* However this should be changed in the next major version bump of dlm.
|
|
*
|
|
* Tail Size checking:
|
|
*
|
|
* There exists a message tail payload in e.g. DLM_MSG however we don't
|
|
* check it against the message length yet regarding to the receive buffer
|
|
* length. That need to be validated.
|
|
*
|
|
* Fencing bad nodes:
|
|
*
|
|
* At timeout places or weird sequence number behaviours we should send
|
|
* a fencing request to the cluster manager.
|
|
*/
|
|
|
|
/* Debug switch to enable a 5 seconds sleep waiting of a termination.
|
|
* This can be useful to test fencing while termination is running.
|
|
* This requires a setup with only gfs2 as dlm user, so that the
|
|
* last umount will terminate the connection.
|
|
*
|
|
* However it became useful to test, while the 5 seconds block in umount
|
|
* just press the reset button. In a lot of dropping the termination
|
|
* process can could take several seconds.
|
|
*/
|
|
#define DLM_DEBUG_FENCE_TERMINATION 0
|
|
|
|
#include <net/tcp.h>
|
|
|
|
#include "dlm_internal.h"
|
|
#include "lockspace.h"
|
|
#include "lowcomms.h"
|
|
#include "config.h"
|
|
#include "memory.h"
|
|
#include "lock.h"
|
|
#include "util.h"
|
|
#include "midcomms.h"
|
|
|
|
/* init value for sequence numbers for testing purpose only e.g. overflows */
|
|
#define DLM_SEQ_INIT 0
|
|
/* 3 minutes wait to sync ending of dlm */
|
|
#define DLM_SHUTDOWN_TIMEOUT msecs_to_jiffies(3 * 60 * 1000)
|
|
#define DLM_VERSION_NOT_SET 0
|
|
|
|
struct midcomms_node {
|
|
int nodeid;
|
|
uint32_t version;
|
|
uint32_t seq_send;
|
|
uint32_t seq_next;
|
|
/* These queues are unbound because we cannot drop any message in dlm.
|
|
* We could send a fence signal for a specific node to the cluster
|
|
* manager if queues hits some maximum value, however this handling
|
|
* not supported yet.
|
|
*/
|
|
struct list_head send_queue;
|
|
spinlock_t send_queue_lock;
|
|
atomic_t send_queue_cnt;
|
|
#define DLM_NODE_FLAG_CLOSE 1
|
|
#define DLM_NODE_FLAG_STOP_TX 2
|
|
#define DLM_NODE_FLAG_STOP_RX 3
|
|
#define DLM_NODE_ULP_DELIVERED 4
|
|
unsigned long flags;
|
|
wait_queue_head_t shutdown_wait;
|
|
|
|
/* dlm tcp termination state */
|
|
#define DLM_CLOSED 1
|
|
#define DLM_ESTABLISHED 2
|
|
#define DLM_FIN_WAIT1 3
|
|
#define DLM_FIN_WAIT2 4
|
|
#define DLM_CLOSE_WAIT 5
|
|
#define DLM_LAST_ACK 6
|
|
#define DLM_CLOSING 7
|
|
int state;
|
|
spinlock_t state_lock;
|
|
|
|
/* counts how many lockspaces are using this node
|
|
* this refcount is necessary to determine if the
|
|
* node wants to disconnect.
|
|
*/
|
|
int users;
|
|
|
|
/* not protected by srcu, node_hash lifetime */
|
|
void *debugfs;
|
|
|
|
struct hlist_node hlist;
|
|
struct rcu_head rcu;
|
|
};
|
|
|
|
struct dlm_mhandle {
|
|
const struct dlm_header *inner_hd;
|
|
struct midcomms_node *node;
|
|
struct dlm_opts *opts;
|
|
struct dlm_msg *msg;
|
|
bool committed;
|
|
uint32_t seq;
|
|
|
|
void (*ack_rcv)(struct midcomms_node *node);
|
|
|
|
/* get_mhandle/commit srcu idx exchange */
|
|
int idx;
|
|
|
|
struct list_head list;
|
|
struct rcu_head rcu;
|
|
};
|
|
|
|
static struct hlist_head node_hash[CONN_HASH_SIZE];
|
|
static DEFINE_SPINLOCK(nodes_lock);
|
|
DEFINE_STATIC_SRCU(nodes_srcu);
|
|
|
|
/* This mutex prevents that midcomms_close() is running while
|
|
* stop() or remove(). As I experienced invalid memory access
|
|
* behaviours when DLM_DEBUG_FENCE_TERMINATION is enabled and
|
|
* resetting machines. I will end in some double deletion in nodes
|
|
* datastructure.
|
|
*/
|
|
static DEFINE_MUTEX(close_lock);
|
|
|
|
struct kmem_cache *dlm_midcomms_cache_create(void)
|
|
{
|
|
return kmem_cache_create("dlm_mhandle", sizeof(struct dlm_mhandle),
|
|
0, 0, NULL);
|
|
}
|
|
|
|
static inline const char *dlm_state_str(int state)
|
|
{
|
|
switch (state) {
|
|
case DLM_CLOSED:
|
|
return "CLOSED";
|
|
case DLM_ESTABLISHED:
|
|
return "ESTABLISHED";
|
|
case DLM_FIN_WAIT1:
|
|
return "FIN_WAIT1";
|
|
case DLM_FIN_WAIT2:
|
|
return "FIN_WAIT2";
|
|
case DLM_CLOSE_WAIT:
|
|
return "CLOSE_WAIT";
|
|
case DLM_LAST_ACK:
|
|
return "LAST_ACK";
|
|
case DLM_CLOSING:
|
|
return "CLOSING";
|
|
default:
|
|
return "UNKNOWN";
|
|
}
|
|
}
|
|
|
|
const char *dlm_midcomms_state(struct midcomms_node *node)
|
|
{
|
|
return dlm_state_str(node->state);
|
|
}
|
|
|
|
unsigned long dlm_midcomms_flags(struct midcomms_node *node)
|
|
{
|
|
return node->flags;
|
|
}
|
|
|
|
int dlm_midcomms_send_queue_cnt(struct midcomms_node *node)
|
|
{
|
|
return atomic_read(&node->send_queue_cnt);
|
|
}
|
|
|
|
uint32_t dlm_midcomms_version(struct midcomms_node *node)
|
|
{
|
|
return node->version;
|
|
}
|
|
|
|
static struct midcomms_node *__find_node(int nodeid, int r)
|
|
{
|
|
struct midcomms_node *node;
|
|
|
|
hlist_for_each_entry_rcu(node, &node_hash[r], hlist) {
|
|
if (node->nodeid == nodeid)
|
|
return node;
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
static void dlm_mhandle_release(struct rcu_head *rcu)
|
|
{
|
|
struct dlm_mhandle *mh = container_of(rcu, struct dlm_mhandle, rcu);
|
|
|
|
dlm_lowcomms_put_msg(mh->msg);
|
|
dlm_free_mhandle(mh);
|
|
}
|
|
|
|
static void dlm_mhandle_delete(struct midcomms_node *node,
|
|
struct dlm_mhandle *mh)
|
|
{
|
|
list_del_rcu(&mh->list);
|
|
atomic_dec(&node->send_queue_cnt);
|
|
call_rcu(&mh->rcu, dlm_mhandle_release);
|
|
}
|
|
|
|
static void dlm_send_queue_flush(struct midcomms_node *node)
|
|
{
|
|
struct dlm_mhandle *mh;
|
|
|
|
pr_debug("flush midcomms send queue of node %d\n", node->nodeid);
|
|
|
|
rcu_read_lock();
|
|
spin_lock(&node->send_queue_lock);
|
|
list_for_each_entry_rcu(mh, &node->send_queue, list) {
|
|
dlm_mhandle_delete(node, mh);
|
|
}
|
|
spin_unlock(&node->send_queue_lock);
|
|
rcu_read_unlock();
|
|
}
|
|
|
|
static void midcomms_node_reset(struct midcomms_node *node)
|
|
{
|
|
pr_debug("reset node %d\n", node->nodeid);
|
|
|
|
node->seq_next = DLM_SEQ_INIT;
|
|
node->seq_send = DLM_SEQ_INIT;
|
|
node->version = DLM_VERSION_NOT_SET;
|
|
node->flags = 0;
|
|
|
|
dlm_send_queue_flush(node);
|
|
node->state = DLM_CLOSED;
|
|
wake_up(&node->shutdown_wait);
|
|
}
|
|
|
|
static struct midcomms_node *nodeid2node(int nodeid, gfp_t alloc)
|
|
{
|
|
struct midcomms_node *node, *tmp;
|
|
int r = nodeid_hash(nodeid);
|
|
|
|
node = __find_node(nodeid, r);
|
|
if (node || !alloc)
|
|
return node;
|
|
|
|
node = kmalloc(sizeof(*node), alloc);
|
|
if (!node)
|
|
return NULL;
|
|
|
|
node->nodeid = nodeid;
|
|
spin_lock_init(&node->state_lock);
|
|
spin_lock_init(&node->send_queue_lock);
|
|
atomic_set(&node->send_queue_cnt, 0);
|
|
INIT_LIST_HEAD(&node->send_queue);
|
|
init_waitqueue_head(&node->shutdown_wait);
|
|
node->users = 0;
|
|
midcomms_node_reset(node);
|
|
|
|
spin_lock(&nodes_lock);
|
|
/* check again if there was somebody else
|
|
* earlier here to add the node
|
|
*/
|
|
tmp = __find_node(nodeid, r);
|
|
if (tmp) {
|
|
spin_unlock(&nodes_lock);
|
|
kfree(node);
|
|
return tmp;
|
|
}
|
|
|
|
hlist_add_head_rcu(&node->hlist, &node_hash[r]);
|
|
spin_unlock(&nodes_lock);
|
|
|
|
node->debugfs = dlm_create_debug_comms_file(nodeid, node);
|
|
return node;
|
|
}
|
|
|
|
static int dlm_send_ack(int nodeid, uint32_t seq)
|
|
{
|
|
int mb_len = sizeof(struct dlm_header);
|
|
struct dlm_header *m_header;
|
|
struct dlm_msg *msg;
|
|
char *ppc;
|
|
|
|
msg = dlm_lowcomms_new_msg(nodeid, mb_len, GFP_NOFS, &ppc,
|
|
NULL, NULL);
|
|
if (!msg)
|
|
return -ENOMEM;
|
|
|
|
m_header = (struct dlm_header *)ppc;
|
|
|
|
m_header->h_version = cpu_to_le32(DLM_HEADER_MAJOR | DLM_HEADER_MINOR);
|
|
m_header->h_nodeid = cpu_to_le32(dlm_our_nodeid());
|
|
m_header->h_length = cpu_to_le16(mb_len);
|
|
m_header->h_cmd = DLM_ACK;
|
|
m_header->u.h_seq = cpu_to_le32(seq);
|
|
|
|
dlm_lowcomms_commit_msg(msg);
|
|
dlm_lowcomms_put_msg(msg);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int dlm_send_fin(struct midcomms_node *node,
|
|
void (*ack_rcv)(struct midcomms_node *node))
|
|
{
|
|
int mb_len = sizeof(struct dlm_header);
|
|
struct dlm_header *m_header;
|
|
struct dlm_mhandle *mh;
|
|
char *ppc;
|
|
|
|
mh = dlm_midcomms_get_mhandle(node->nodeid, mb_len, GFP_NOFS, &ppc);
|
|
if (!mh)
|
|
return -ENOMEM;
|
|
|
|
mh->ack_rcv = ack_rcv;
|
|
|
|
m_header = (struct dlm_header *)ppc;
|
|
|
|
m_header->h_version = cpu_to_le32(DLM_HEADER_MAJOR | DLM_HEADER_MINOR);
|
|
m_header->h_nodeid = cpu_to_le32(dlm_our_nodeid());
|
|
m_header->h_length = cpu_to_le16(mb_len);
|
|
m_header->h_cmd = DLM_FIN;
|
|
|
|
pr_debug("sending fin msg to node %d\n", node->nodeid);
|
|
dlm_midcomms_commit_mhandle(mh);
|
|
set_bit(DLM_NODE_FLAG_STOP_TX, &node->flags);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void dlm_receive_ack(struct midcomms_node *node, uint32_t seq)
|
|
{
|
|
struct dlm_mhandle *mh;
|
|
|
|
rcu_read_lock();
|
|
list_for_each_entry_rcu(mh, &node->send_queue, list) {
|
|
if (before(mh->seq, seq)) {
|
|
if (mh->ack_rcv)
|
|
mh->ack_rcv(node);
|
|
} else {
|
|
/* send queue should be ordered */
|
|
break;
|
|
}
|
|
}
|
|
|
|
spin_lock(&node->send_queue_lock);
|
|
list_for_each_entry_rcu(mh, &node->send_queue, list) {
|
|
if (before(mh->seq, seq)) {
|
|
dlm_mhandle_delete(node, mh);
|
|
} else {
|
|
/* send queue should be ordered */
|
|
break;
|
|
}
|
|
}
|
|
spin_unlock(&node->send_queue_lock);
|
|
rcu_read_unlock();
|
|
}
|
|
|
|
static void dlm_pas_fin_ack_rcv(struct midcomms_node *node)
|
|
{
|
|
spin_lock(&node->state_lock);
|
|
pr_debug("receive passive fin ack from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
|
|
switch (node->state) {
|
|
case DLM_LAST_ACK:
|
|
/* DLM_CLOSED */
|
|
midcomms_node_reset(node);
|
|
break;
|
|
case DLM_CLOSED:
|
|
/* not valid but somehow we got what we want */
|
|
wake_up(&node->shutdown_wait);
|
|
break;
|
|
default:
|
|
spin_unlock(&node->state_lock);
|
|
log_print("%s: unexpected state: %d\n",
|
|
__func__, node->state);
|
|
WARN_ON(1);
|
|
return;
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
}
|
|
|
|
static void dlm_midcomms_receive_buffer(union dlm_packet *p,
|
|
struct midcomms_node *node,
|
|
uint32_t seq)
|
|
{
|
|
if (seq == node->seq_next) {
|
|
node->seq_next++;
|
|
|
|
switch (p->header.h_cmd) {
|
|
case DLM_FIN:
|
|
/* send ack before fin */
|
|
dlm_send_ack(node->nodeid, node->seq_next);
|
|
|
|
spin_lock(&node->state_lock);
|
|
pr_debug("receive fin msg from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
|
|
switch (node->state) {
|
|
case DLM_ESTABLISHED:
|
|
node->state = DLM_CLOSE_WAIT;
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
/* passive shutdown DLM_LAST_ACK case 1
|
|
* additional we check if the node is used by
|
|
* cluster manager events at all.
|
|
*/
|
|
if (node->users == 0) {
|
|
node->state = DLM_LAST_ACK;
|
|
pr_debug("switch node %d to state %s case 1\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
spin_unlock(&node->state_lock);
|
|
goto send_fin;
|
|
}
|
|
break;
|
|
case DLM_FIN_WAIT1:
|
|
node->state = DLM_CLOSING;
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
break;
|
|
case DLM_FIN_WAIT2:
|
|
midcomms_node_reset(node);
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
wake_up(&node->shutdown_wait);
|
|
break;
|
|
case DLM_LAST_ACK:
|
|
/* probably remove_member caught it, do nothing */
|
|
break;
|
|
default:
|
|
spin_unlock(&node->state_lock);
|
|
log_print("%s: unexpected state: %d\n",
|
|
__func__, node->state);
|
|
WARN_ON(1);
|
|
return;
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
|
|
set_bit(DLM_NODE_FLAG_STOP_RX, &node->flags);
|
|
break;
|
|
default:
|
|
WARN_ON(test_bit(DLM_NODE_FLAG_STOP_RX, &node->flags));
|
|
dlm_receive_buffer(p, node->nodeid);
|
|
set_bit(DLM_NODE_ULP_DELIVERED, &node->flags);
|
|
break;
|
|
}
|
|
} else {
|
|
/* retry to ack message which we already have by sending back
|
|
* current node->seq_next number as ack.
|
|
*/
|
|
if (seq < node->seq_next)
|
|
dlm_send_ack(node->nodeid, node->seq_next);
|
|
|
|
log_print_ratelimited("ignore dlm msg because seq mismatch, seq: %u, expected: %u, nodeid: %d",
|
|
seq, node->seq_next, node->nodeid);
|
|
}
|
|
|
|
return;
|
|
|
|
send_fin:
|
|
set_bit(DLM_NODE_FLAG_STOP_RX, &node->flags);
|
|
dlm_send_fin(node, dlm_pas_fin_ack_rcv);
|
|
}
|
|
|
|
static struct midcomms_node *
|
|
dlm_midcomms_recv_node_lookup(int nodeid, const union dlm_packet *p,
|
|
uint16_t msglen, int (*cb)(struct midcomms_node *node))
|
|
{
|
|
struct midcomms_node *node = NULL;
|
|
gfp_t allocation = 0;
|
|
int ret;
|
|
|
|
switch (p->header.h_cmd) {
|
|
case DLM_RCOM:
|
|
if (msglen < sizeof(struct dlm_rcom)) {
|
|
log_print("rcom msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
return NULL;
|
|
}
|
|
|
|
switch (p->rcom.rc_type) {
|
|
case cpu_to_le32(DLM_RCOM_NAMES):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_NAMES_REPLY):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_STATUS):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_STATUS_REPLY):
|
|
node = nodeid2node(nodeid, 0);
|
|
if (node) {
|
|
spin_lock(&node->state_lock);
|
|
if (node->state != DLM_ESTABLISHED)
|
|
pr_debug("receive begin RCOM msg from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
|
|
switch (node->state) {
|
|
case DLM_CLOSED:
|
|
node->state = DLM_ESTABLISHED;
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
break;
|
|
case DLM_ESTABLISHED:
|
|
break;
|
|
default:
|
|
/* some invalid state passive shutdown
|
|
* was failed, we try to reset and
|
|
* hope it will go on.
|
|
*/
|
|
log_print("reset node %d because shutdown stuck",
|
|
node->nodeid);
|
|
|
|
midcomms_node_reset(node);
|
|
node->state = DLM_ESTABLISHED;
|
|
break;
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
}
|
|
|
|
allocation = GFP_NOFS;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
node = nodeid2node(nodeid, allocation);
|
|
if (!node) {
|
|
switch (p->header.h_cmd) {
|
|
case DLM_OPTS:
|
|
if (msglen < sizeof(struct dlm_opts)) {
|
|
log_print("opts msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
return NULL;
|
|
}
|
|
|
|
log_print_ratelimited("received dlm opts message nextcmd %d from node %d in an invalid sequence",
|
|
p->opts.o_nextcmd, nodeid);
|
|
break;
|
|
default:
|
|
log_print_ratelimited("received dlm message cmd %d from node %d in an invalid sequence",
|
|
p->header.h_cmd, nodeid);
|
|
break;
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
ret = cb(node);
|
|
if (ret < 0)
|
|
return NULL;
|
|
|
|
return node;
|
|
}
|
|
|
|
static int dlm_midcomms_version_check_3_2(struct midcomms_node *node)
|
|
{
|
|
switch (node->version) {
|
|
case DLM_VERSION_NOT_SET:
|
|
node->version = DLM_VERSION_3_2;
|
|
log_print("version 0x%08x for node %d detected", DLM_VERSION_3_2,
|
|
node->nodeid);
|
|
break;
|
|
case DLM_VERSION_3_2:
|
|
break;
|
|
default:
|
|
log_print_ratelimited("version mismatch detected, assumed 0x%08x but node %d has 0x%08x",
|
|
DLM_VERSION_3_2, node->nodeid, node->version);
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int dlm_opts_check_msglen(union dlm_packet *p, uint16_t msglen, int nodeid)
|
|
{
|
|
int len = msglen;
|
|
|
|
/* we only trust outer header msglen because
|
|
* it's checked against receive buffer length.
|
|
*/
|
|
if (len < sizeof(struct dlm_opts))
|
|
return -1;
|
|
len -= sizeof(struct dlm_opts);
|
|
|
|
if (len < le16_to_cpu(p->opts.o_optlen))
|
|
return -1;
|
|
len -= le16_to_cpu(p->opts.o_optlen);
|
|
|
|
switch (p->opts.o_nextcmd) {
|
|
case DLM_FIN:
|
|
if (len < sizeof(struct dlm_header)) {
|
|
log_print("fin too small: %d, will skip this message from node %d",
|
|
len, nodeid);
|
|
return -1;
|
|
}
|
|
|
|
break;
|
|
case DLM_MSG:
|
|
if (len < sizeof(struct dlm_message)) {
|
|
log_print("msg too small: %d, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
return -1;
|
|
}
|
|
|
|
break;
|
|
case DLM_RCOM:
|
|
if (len < sizeof(struct dlm_rcom)) {
|
|
log_print("rcom msg too small: %d, will skip this message from node %d",
|
|
len, nodeid);
|
|
return -1;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
log_print("unsupported o_nextcmd received: %u, will skip this message from node %d",
|
|
p->opts.o_nextcmd, nodeid);
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void dlm_midcomms_receive_buffer_3_2(union dlm_packet *p, int nodeid)
|
|
{
|
|
uint16_t msglen = le16_to_cpu(p->header.h_length);
|
|
struct midcomms_node *node;
|
|
uint32_t seq;
|
|
int ret, idx;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = dlm_midcomms_recv_node_lookup(nodeid, p, msglen,
|
|
dlm_midcomms_version_check_3_2);
|
|
if (!node)
|
|
goto out;
|
|
|
|
switch (p->header.h_cmd) {
|
|
case DLM_RCOM:
|
|
/* these rcom message we use to determine version.
|
|
* they have their own retransmission handling and
|
|
* are the first messages of dlm.
|
|
*
|
|
* length already checked.
|
|
*/
|
|
switch (p->rcom.rc_type) {
|
|
case cpu_to_le32(DLM_RCOM_NAMES):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_NAMES_REPLY):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_STATUS):
|
|
fallthrough;
|
|
case cpu_to_le32(DLM_RCOM_STATUS_REPLY):
|
|
break;
|
|
default:
|
|
log_print("unsupported rcom type received: %u, will skip this message from node %d",
|
|
le32_to_cpu(p->rcom.rc_type), nodeid);
|
|
goto out;
|
|
}
|
|
|
|
WARN_ON(test_bit(DLM_NODE_FLAG_STOP_RX, &node->flags));
|
|
dlm_receive_buffer(p, nodeid);
|
|
break;
|
|
case DLM_OPTS:
|
|
seq = le32_to_cpu(p->header.u.h_seq);
|
|
|
|
ret = dlm_opts_check_msglen(p, msglen, nodeid);
|
|
if (ret < 0) {
|
|
log_print("opts msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
goto out;
|
|
}
|
|
|
|
p = (union dlm_packet *)((unsigned char *)p->opts.o_opts +
|
|
le16_to_cpu(p->opts.o_optlen));
|
|
|
|
/* recheck inner msglen just if it's not garbage */
|
|
msglen = le16_to_cpu(p->header.h_length);
|
|
switch (p->header.h_cmd) {
|
|
case DLM_RCOM:
|
|
if (msglen < sizeof(struct dlm_rcom)) {
|
|
log_print("inner rcom msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
goto out;
|
|
}
|
|
|
|
break;
|
|
case DLM_MSG:
|
|
if (msglen < sizeof(struct dlm_message)) {
|
|
log_print("inner msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
goto out;
|
|
}
|
|
|
|
break;
|
|
case DLM_FIN:
|
|
if (msglen < sizeof(struct dlm_header)) {
|
|
log_print("inner fin too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
goto out;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
log_print("unsupported inner h_cmd received: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
goto out;
|
|
}
|
|
|
|
dlm_midcomms_receive_buffer(p, node, seq);
|
|
break;
|
|
case DLM_ACK:
|
|
seq = le32_to_cpu(p->header.u.h_seq);
|
|
dlm_receive_ack(node, seq);
|
|
break;
|
|
default:
|
|
log_print("unsupported h_cmd received: %u, will skip this message from node %d",
|
|
p->header.h_cmd, nodeid);
|
|
break;
|
|
}
|
|
|
|
out:
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
}
|
|
|
|
static int dlm_midcomms_version_check_3_1(struct midcomms_node *node)
|
|
{
|
|
switch (node->version) {
|
|
case DLM_VERSION_NOT_SET:
|
|
node->version = DLM_VERSION_3_1;
|
|
log_print("version 0x%08x for node %d detected", DLM_VERSION_3_1,
|
|
node->nodeid);
|
|
break;
|
|
case DLM_VERSION_3_1:
|
|
break;
|
|
default:
|
|
log_print_ratelimited("version mismatch detected, assumed 0x%08x but node %d has 0x%08x",
|
|
DLM_VERSION_3_1, node->nodeid, node->version);
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void dlm_midcomms_receive_buffer_3_1(union dlm_packet *p, int nodeid)
|
|
{
|
|
uint16_t msglen = le16_to_cpu(p->header.h_length);
|
|
struct midcomms_node *node;
|
|
int idx;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = dlm_midcomms_recv_node_lookup(nodeid, p, msglen,
|
|
dlm_midcomms_version_check_3_1);
|
|
if (!node) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
|
|
switch (p->header.h_cmd) {
|
|
case DLM_RCOM:
|
|
/* length already checked */
|
|
break;
|
|
case DLM_MSG:
|
|
if (msglen < sizeof(struct dlm_message)) {
|
|
log_print("msg too small: %u, will skip this message from node %d",
|
|
msglen, nodeid);
|
|
return;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
log_print("unsupported h_cmd received: %u, will skip this message from node %d",
|
|
p->header.h_cmd, nodeid);
|
|
return;
|
|
}
|
|
|
|
dlm_receive_buffer(p, nodeid);
|
|
}
|
|
|
|
/*
|
|
* Called from the low-level comms layer to process a buffer of
|
|
* commands.
|
|
*/
|
|
|
|
int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int len)
|
|
{
|
|
const unsigned char *ptr = buf;
|
|
const struct dlm_header *hd;
|
|
uint16_t msglen;
|
|
int ret = 0;
|
|
|
|
while (len >= sizeof(struct dlm_header)) {
|
|
hd = (struct dlm_header *)ptr;
|
|
|
|
/* no message should be more than DLM_MAX_SOCKET_BUFSIZE or
|
|
* less than dlm_header size.
|
|
*
|
|
* Some messages does not have a 8 byte length boundary yet
|
|
* which can occur in a unaligned memory access of some dlm
|
|
* messages. However this problem need to be fixed at the
|
|
* sending side, for now it seems nobody run into architecture
|
|
* related issues yet but it slows down some processing.
|
|
* Fixing this issue should be scheduled in future by doing
|
|
* the next major version bump.
|
|
*/
|
|
msglen = le16_to_cpu(hd->h_length);
|
|
if (msglen > DLM_MAX_SOCKET_BUFSIZE ||
|
|
msglen < sizeof(struct dlm_header)) {
|
|
log_print("received invalid length header: %u from node %d, will abort message parsing",
|
|
msglen, nodeid);
|
|
return -EBADMSG;
|
|
}
|
|
|
|
/* caller will take care that leftover
|
|
* will be parsed next call with more data
|
|
*/
|
|
if (msglen > len)
|
|
break;
|
|
|
|
switch (hd->h_version) {
|
|
case cpu_to_le32(DLM_VERSION_3_1):
|
|
dlm_midcomms_receive_buffer_3_1((union dlm_packet *)ptr, nodeid);
|
|
break;
|
|
case cpu_to_le32(DLM_VERSION_3_2):
|
|
dlm_midcomms_receive_buffer_3_2((union dlm_packet *)ptr, nodeid);
|
|
break;
|
|
default:
|
|
log_print("received invalid version header: %u from node %d, will skip this message",
|
|
le32_to_cpu(hd->h_version), nodeid);
|
|
break;
|
|
}
|
|
|
|
ret += msglen;
|
|
len -= msglen;
|
|
ptr += msglen;
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
void dlm_midcomms_receive_done(int nodeid)
|
|
{
|
|
struct midcomms_node *node;
|
|
int idx;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = nodeid2node(nodeid, 0);
|
|
if (!node) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
/* old protocol, we do nothing */
|
|
switch (node->version) {
|
|
case DLM_VERSION_3_2:
|
|
break;
|
|
default:
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
/* do nothing if we didn't delivered stateful to ulp */
|
|
if (!test_and_clear_bit(DLM_NODE_ULP_DELIVERED,
|
|
&node->flags)) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
spin_lock(&node->state_lock);
|
|
/* we only ack if state is ESTABLISHED */
|
|
switch (node->state) {
|
|
case DLM_ESTABLISHED:
|
|
spin_unlock(&node->state_lock);
|
|
dlm_send_ack(node->nodeid, node->seq_next);
|
|
break;
|
|
default:
|
|
spin_unlock(&node->state_lock);
|
|
/* do nothing FIN has it's own ack send */
|
|
break;
|
|
}
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
}
|
|
|
|
void dlm_midcomms_unack_msg_resend(int nodeid)
|
|
{
|
|
struct midcomms_node *node;
|
|
struct dlm_mhandle *mh;
|
|
int idx, ret;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = nodeid2node(nodeid, 0);
|
|
if (!node) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
/* old protocol, we don't support to retransmit on failure */
|
|
switch (node->version) {
|
|
case DLM_VERSION_3_2:
|
|
break;
|
|
default:
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
rcu_read_lock();
|
|
list_for_each_entry_rcu(mh, &node->send_queue, list) {
|
|
if (!mh->committed)
|
|
continue;
|
|
|
|
ret = dlm_lowcomms_resend_msg(mh->msg);
|
|
if (!ret)
|
|
log_print_ratelimited("retransmit dlm msg, seq %u, nodeid %d",
|
|
mh->seq, node->nodeid);
|
|
}
|
|
rcu_read_unlock();
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
}
|
|
|
|
static void dlm_fill_opts_header(struct dlm_opts *opts, uint16_t inner_len,
|
|
uint32_t seq)
|
|
{
|
|
opts->o_header.h_cmd = DLM_OPTS;
|
|
opts->o_header.h_version = cpu_to_le32(DLM_HEADER_MAJOR | DLM_HEADER_MINOR);
|
|
opts->o_header.h_nodeid = cpu_to_le32(dlm_our_nodeid());
|
|
opts->o_header.h_length = cpu_to_le16(DLM_MIDCOMMS_OPT_LEN + inner_len);
|
|
opts->o_header.u.h_seq = cpu_to_le32(seq);
|
|
}
|
|
|
|
static void midcomms_new_msg_cb(void *data)
|
|
{
|
|
struct dlm_mhandle *mh = data;
|
|
|
|
atomic_inc(&mh->node->send_queue_cnt);
|
|
|
|
spin_lock(&mh->node->send_queue_lock);
|
|
list_add_tail_rcu(&mh->list, &mh->node->send_queue);
|
|
spin_unlock(&mh->node->send_queue_lock);
|
|
|
|
mh->seq = mh->node->seq_send++;
|
|
}
|
|
|
|
static struct dlm_msg *dlm_midcomms_get_msg_3_2(struct dlm_mhandle *mh, int nodeid,
|
|
int len, gfp_t allocation, char **ppc)
|
|
{
|
|
struct dlm_opts *opts;
|
|
struct dlm_msg *msg;
|
|
|
|
msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN,
|
|
allocation, ppc, midcomms_new_msg_cb, mh);
|
|
if (!msg)
|
|
return NULL;
|
|
|
|
opts = (struct dlm_opts *)*ppc;
|
|
mh->opts = opts;
|
|
|
|
/* add possible options here */
|
|
dlm_fill_opts_header(opts, len, mh->seq);
|
|
|
|
*ppc += sizeof(*opts);
|
|
mh->inner_hd = (const struct dlm_header *)*ppc;
|
|
return msg;
|
|
}
|
|
|
|
/* avoid false positive for nodes_srcu, unlock happens in
|
|
* dlm_midcomms_commit_mhandle which is a must call if success
|
|
*/
|
|
#ifndef __CHECKER__
|
|
struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len,
|
|
gfp_t allocation, char **ppc)
|
|
{
|
|
struct midcomms_node *node;
|
|
struct dlm_mhandle *mh;
|
|
struct dlm_msg *msg;
|
|
int idx;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = nodeid2node(nodeid, 0);
|
|
if (!node) {
|
|
WARN_ON_ONCE(1);
|
|
goto err;
|
|
}
|
|
|
|
/* this is a bug, however we going on and hope it will be resolved */
|
|
WARN_ON(test_bit(DLM_NODE_FLAG_STOP_TX, &node->flags));
|
|
|
|
mh = dlm_allocate_mhandle();
|
|
if (!mh)
|
|
goto err;
|
|
|
|
mh->committed = false;
|
|
mh->ack_rcv = NULL;
|
|
mh->idx = idx;
|
|
mh->node = node;
|
|
|
|
switch (node->version) {
|
|
case DLM_VERSION_3_1:
|
|
msg = dlm_lowcomms_new_msg(nodeid, len, allocation, ppc,
|
|
NULL, NULL);
|
|
if (!msg) {
|
|
dlm_free_mhandle(mh);
|
|
goto err;
|
|
}
|
|
|
|
break;
|
|
case DLM_VERSION_3_2:
|
|
msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, allocation,
|
|
ppc);
|
|
if (!msg) {
|
|
dlm_free_mhandle(mh);
|
|
goto err;
|
|
}
|
|
|
|
break;
|
|
default:
|
|
dlm_free_mhandle(mh);
|
|
WARN_ON(1);
|
|
goto err;
|
|
}
|
|
|
|
mh->msg = msg;
|
|
|
|
/* keep in mind that is a must to call
|
|
* dlm_midcomms_commit_msg() which releases
|
|
* nodes_srcu using mh->idx which is assumed
|
|
* here that the application will call it.
|
|
*/
|
|
return mh;
|
|
|
|
err:
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return NULL;
|
|
}
|
|
#endif
|
|
|
|
static void dlm_midcomms_commit_msg_3_2(struct dlm_mhandle *mh)
|
|
{
|
|
/* nexthdr chain for fast lookup */
|
|
mh->opts->o_nextcmd = mh->inner_hd->h_cmd;
|
|
mh->committed = true;
|
|
dlm_lowcomms_commit_msg(mh->msg);
|
|
}
|
|
|
|
/* avoid false positive for nodes_srcu, lock was happen in
|
|
* dlm_midcomms_get_mhandle
|
|
*/
|
|
#ifndef __CHECKER__
|
|
void dlm_midcomms_commit_mhandle(struct dlm_mhandle *mh)
|
|
{
|
|
switch (mh->node->version) {
|
|
case DLM_VERSION_3_1:
|
|
srcu_read_unlock(&nodes_srcu, mh->idx);
|
|
|
|
dlm_lowcomms_commit_msg(mh->msg);
|
|
dlm_lowcomms_put_msg(mh->msg);
|
|
/* mh is not part of rcu list in this case */
|
|
dlm_free_mhandle(mh);
|
|
break;
|
|
case DLM_VERSION_3_2:
|
|
dlm_midcomms_commit_msg_3_2(mh);
|
|
srcu_read_unlock(&nodes_srcu, mh->idx);
|
|
break;
|
|
default:
|
|
srcu_read_unlock(&nodes_srcu, mh->idx);
|
|
WARN_ON(1);
|
|
break;
|
|
}
|
|
}
|
|
#endif
|
|
|
|
int dlm_midcomms_start(void)
|
|
{
|
|
int i;
|
|
|
|
for (i = 0; i < CONN_HASH_SIZE; i++)
|
|
INIT_HLIST_HEAD(&node_hash[i]);
|
|
|
|
return dlm_lowcomms_start();
|
|
}
|
|
|
|
static void dlm_act_fin_ack_rcv(struct midcomms_node *node)
|
|
{
|
|
spin_lock(&node->state_lock);
|
|
pr_debug("receive active fin ack from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
|
|
switch (node->state) {
|
|
case DLM_FIN_WAIT1:
|
|
node->state = DLM_FIN_WAIT2;
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
break;
|
|
case DLM_CLOSING:
|
|
midcomms_node_reset(node);
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
wake_up(&node->shutdown_wait);
|
|
break;
|
|
case DLM_CLOSED:
|
|
/* not valid but somehow we got what we want */
|
|
wake_up(&node->shutdown_wait);
|
|
break;
|
|
default:
|
|
spin_unlock(&node->state_lock);
|
|
log_print("%s: unexpected state: %d\n",
|
|
__func__, node->state);
|
|
WARN_ON(1);
|
|
return;
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
}
|
|
|
|
void dlm_midcomms_add_member(int nodeid)
|
|
{
|
|
struct midcomms_node *node;
|
|
int idx;
|
|
|
|
if (nodeid == dlm_our_nodeid())
|
|
return;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = nodeid2node(nodeid, GFP_NOFS);
|
|
if (!node) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
spin_lock(&node->state_lock);
|
|
if (!node->users) {
|
|
pr_debug("receive add member from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
switch (node->state) {
|
|
case DLM_ESTABLISHED:
|
|
break;
|
|
case DLM_CLOSED:
|
|
node->state = DLM_ESTABLISHED;
|
|
pr_debug("switch node %d to state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
break;
|
|
default:
|
|
/* some invalid state passive shutdown
|
|
* was failed, we try to reset and
|
|
* hope it will go on.
|
|
*/
|
|
log_print("reset node %d because shutdown stuck",
|
|
node->nodeid);
|
|
|
|
midcomms_node_reset(node);
|
|
node->state = DLM_ESTABLISHED;
|
|
break;
|
|
}
|
|
}
|
|
|
|
node->users++;
|
|
pr_debug("node %d users inc count %d\n", nodeid, node->users);
|
|
spin_unlock(&node->state_lock);
|
|
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
}
|
|
|
|
void dlm_midcomms_remove_member(int nodeid)
|
|
{
|
|
struct midcomms_node *node;
|
|
int idx;
|
|
|
|
if (nodeid == dlm_our_nodeid())
|
|
return;
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
node = nodeid2node(nodeid, 0);
|
|
if (!node) {
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
}
|
|
|
|
spin_lock(&node->state_lock);
|
|
node->users--;
|
|
pr_debug("node %d users dec count %d\n", nodeid, node->users);
|
|
|
|
/* hitting users count to zero means the
|
|
* other side is running dlm_midcomms_stop()
|
|
* we meet us to have a clean disconnect.
|
|
*/
|
|
if (node->users == 0) {
|
|
pr_debug("receive remove member from node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
switch (node->state) {
|
|
case DLM_ESTABLISHED:
|
|
break;
|
|
case DLM_CLOSE_WAIT:
|
|
/* passive shutdown DLM_LAST_ACK case 2 */
|
|
node->state = DLM_LAST_ACK;
|
|
spin_unlock(&node->state_lock);
|
|
|
|
pr_debug("switch node %d to state %s case 2\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
goto send_fin;
|
|
case DLM_LAST_ACK:
|
|
/* probably receive fin caught it, do nothing */
|
|
break;
|
|
case DLM_CLOSED:
|
|
/* already gone, do nothing */
|
|
break;
|
|
default:
|
|
log_print("%s: unexpected state: %d\n",
|
|
__func__, node->state);
|
|
break;
|
|
}
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return;
|
|
|
|
send_fin:
|
|
set_bit(DLM_NODE_FLAG_STOP_RX, &node->flags);
|
|
dlm_send_fin(node, dlm_pas_fin_ack_rcv);
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
}
|
|
|
|
static void midcomms_node_release(struct rcu_head *rcu)
|
|
{
|
|
struct midcomms_node *node = container_of(rcu, struct midcomms_node, rcu);
|
|
|
|
WARN_ON(atomic_read(&node->send_queue_cnt));
|
|
kfree(node);
|
|
}
|
|
|
|
static void midcomms_shutdown(struct midcomms_node *node)
|
|
{
|
|
int ret;
|
|
|
|
/* old protocol, we don't wait for pending operations */
|
|
switch (node->version) {
|
|
case DLM_VERSION_3_2:
|
|
break;
|
|
default:
|
|
return;
|
|
}
|
|
|
|
spin_lock(&node->state_lock);
|
|
pr_debug("receive active shutdown for node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
switch (node->state) {
|
|
case DLM_ESTABLISHED:
|
|
node->state = DLM_FIN_WAIT1;
|
|
pr_debug("switch node %d to state %s case 2\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
break;
|
|
case DLM_CLOSED:
|
|
/* we have what we want */
|
|
spin_unlock(&node->state_lock);
|
|
return;
|
|
default:
|
|
/* busy to enter DLM_FIN_WAIT1, wait until passive
|
|
* done in shutdown_wait to enter DLM_CLOSED.
|
|
*/
|
|
break;
|
|
}
|
|
spin_unlock(&node->state_lock);
|
|
|
|
if (node->state == DLM_FIN_WAIT1) {
|
|
dlm_send_fin(node, dlm_act_fin_ack_rcv);
|
|
|
|
if (DLM_DEBUG_FENCE_TERMINATION)
|
|
msleep(5000);
|
|
}
|
|
|
|
/* wait for other side dlm + fin */
|
|
ret = wait_event_timeout(node->shutdown_wait,
|
|
node->state == DLM_CLOSED ||
|
|
test_bit(DLM_NODE_FLAG_CLOSE, &node->flags),
|
|
DLM_SHUTDOWN_TIMEOUT);
|
|
if (!ret || test_bit(DLM_NODE_FLAG_CLOSE, &node->flags)) {
|
|
pr_debug("active shutdown timed out for node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
midcomms_node_reset(node);
|
|
return;
|
|
}
|
|
|
|
pr_debug("active shutdown done for node %d with state %s\n",
|
|
node->nodeid, dlm_state_str(node->state));
|
|
}
|
|
|
|
void dlm_midcomms_shutdown(void)
|
|
{
|
|
struct midcomms_node *node;
|
|
int i, idx;
|
|
|
|
mutex_lock(&close_lock);
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
for (i = 0; i < CONN_HASH_SIZE; i++) {
|
|
hlist_for_each_entry_rcu(node, &node_hash[i], hlist) {
|
|
midcomms_shutdown(node);
|
|
|
|
dlm_delete_debug_comms_file(node->debugfs);
|
|
|
|
spin_lock(&nodes_lock);
|
|
hlist_del_rcu(&node->hlist);
|
|
spin_unlock(&nodes_lock);
|
|
|
|
call_srcu(&nodes_srcu, &node->rcu, midcomms_node_release);
|
|
}
|
|
}
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
mutex_unlock(&close_lock);
|
|
|
|
dlm_lowcomms_shutdown();
|
|
}
|
|
|
|
int dlm_midcomms_close(int nodeid)
|
|
{
|
|
struct midcomms_node *node;
|
|
int idx, ret;
|
|
|
|
if (nodeid == dlm_our_nodeid())
|
|
return 0;
|
|
|
|
dlm_stop_lockspaces_check();
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
/* Abort pending close/remove operation */
|
|
node = nodeid2node(nodeid, 0);
|
|
if (node) {
|
|
/* let shutdown waiters leave */
|
|
set_bit(DLM_NODE_FLAG_CLOSE, &node->flags);
|
|
wake_up(&node->shutdown_wait);
|
|
}
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
|
|
synchronize_srcu(&nodes_srcu);
|
|
|
|
idx = srcu_read_lock(&nodes_srcu);
|
|
mutex_lock(&close_lock);
|
|
node = nodeid2node(nodeid, 0);
|
|
if (!node) {
|
|
mutex_unlock(&close_lock);
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
return dlm_lowcomms_close(nodeid);
|
|
}
|
|
|
|
ret = dlm_lowcomms_close(nodeid);
|
|
spin_lock(&node->state_lock);
|
|
midcomms_node_reset(node);
|
|
spin_unlock(&node->state_lock);
|
|
srcu_read_unlock(&nodes_srcu, idx);
|
|
mutex_unlock(&close_lock);
|
|
|
|
return ret;
|
|
}
|
|
|
|
/* debug functionality to send raw dlm msg from user space */
|
|
struct dlm_rawmsg_data {
|
|
struct midcomms_node *node;
|
|
void *buf;
|
|
};
|
|
|
|
static void midcomms_new_rawmsg_cb(void *data)
|
|
{
|
|
struct dlm_rawmsg_data *rd = data;
|
|
struct dlm_header *h = rd->buf;
|
|
|
|
switch (h->h_version) {
|
|
case cpu_to_le32(DLM_VERSION_3_1):
|
|
break;
|
|
default:
|
|
switch (h->h_cmd) {
|
|
case DLM_OPTS:
|
|
if (!h->u.h_seq)
|
|
h->u.h_seq = cpu_to_le32(rd->node->seq_send++);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
int dlm_midcomms_rawmsg_send(struct midcomms_node *node, void *buf,
|
|
int buflen)
|
|
{
|
|
struct dlm_rawmsg_data rd;
|
|
struct dlm_msg *msg;
|
|
char *msgbuf;
|
|
|
|
rd.node = node;
|
|
rd.buf = buf;
|
|
|
|
msg = dlm_lowcomms_new_msg(node->nodeid, buflen, GFP_NOFS,
|
|
&msgbuf, midcomms_new_rawmsg_cb, &rd);
|
|
if (!msg)
|
|
return -ENOMEM;
|
|
|
|
memcpy(msgbuf, buf, buflen);
|
|
dlm_lowcomms_commit_msg(msg);
|
|
return 0;
|
|
}
|
|
|