[Cluster-devel] [PATCHv4 dlm/next 16/20] fs: dlm: add per node receive flush
Alexander Aring
aahringo at redhat.com
Mon Jan 11 18:03:06 UTC 2021
This patch will add a functionality to flush pending dlm messages from
the receiving workqueue. Upcoming patches will use it to make sure that
nothing can be received e.g. after a node gets removed from the nodes
hash. Receiving messages will occur into a node lookup which might
create an node for the hash again.
Signed-off-by: Alexander Aring <aahringo at redhat.com>
---
fs/dlm/lowcomms.c | 9 +++++++++
fs/dlm/lowcomms.h | 1 +
2 files changed, 10 insertions(+)
diff --git a/fs/dlm/lowcomms.c b/fs/dlm/lowcomms.c
index 9a3899ad1765..0e4cbabc680f 100644
--- a/fs/dlm/lowcomms.c
+++ b/fs/dlm/lowcomms.c
@@ -1607,6 +1607,15 @@ static void clean_one_writequeue(struct connection *con)
spin_unlock_bh(&con->writequeue_lock);
}
+void dlm_lowcomms_rx_flush(int nodeid)
+{
+ struct connection *con;
+
+ con = nodeid2con(nodeid, 0);
+ if (con)
+ flush_work(&con->rwork);
+}
+
/* Called from recovery when it knows that a node has
left the cluster */
int dlm_lowcomms_close(int nodeid)
diff --git a/fs/dlm/lowcomms.h b/fs/dlm/lowcomms.h
index 8286531f9a9e..c4c789a68cf6 100644
--- a/fs/dlm/lowcomms.h
+++ b/fs/dlm/lowcomms.h
@@ -39,6 +39,7 @@ int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len);
void dlm_lowcomms_put_buffer(void *mh);
void dlm_lowcomms_get_buffer(void *mh);
void dlm_lowcomms_resend_buffer(void *mh);
+void dlm_lowcomms_rx_flush(int nodeid);
#endif /* __LOWCOMMS_DOT_H__ */
--
2.26.2
More information about the Cluster-devel
mailing list