// SPDX-License-Identifier: GPL-2.0-or-later /* * dlmdomain.c * * defines domain join / leave apis * * Copyright (C) 2004 Oracle. All rights reserved. */ #include <linux/module.h> #include <linux/types.h> #include <linux/slab.h> #include <linux/highmem.h> #include <linux/init.h> #include <linux/spinlock.h> #include <linux/delay.h> #include <linux/err.h> #include <linux/debugfs.h> #include <linux/sched/signal.h> #include "../cluster/heartbeat.h" #include "../cluster/nodemanager.h" #include "../cluster/tcp.h" #include "dlmapi.h" #include "dlmcommon.h" #include "dlmdomain.h" #include "dlmdebug.h" #define MLOG_MASK_PREFIX … #include "../cluster/masklog.h" /* * ocfs2 node maps are array of long int, which limits to send them freely * across the wire due to endianness issues. To workaround this, we convert * long ints to byte arrays. Following 3 routines are helper functions to * set/test/copy bits within those array of bytes */ static inline void byte_set_bit(u8 nr, u8 map[]) { … } static inline int byte_test_bit(u8 nr, u8 map[]) { … } static inline void byte_copymap(u8 dmap[], unsigned long smap[], unsigned int sz) { … } static void dlm_free_pagevec(void **vec, int pages) { … } static void **dlm_alloc_pagevec(int pages) { … } /* * * spinlock lock ordering: if multiple locks are needed, obey this ordering: * dlm_domain_lock * struct dlm_ctxt->spinlock * struct dlm_lock_resource->spinlock * struct dlm_ctxt->master_lock * struct dlm_ctxt->ast_lock * dlm_master_list_entry->spinlock * dlm_lock->spinlock * */ DEFINE_SPINLOCK(…); LIST_HEAD(…); static DECLARE_WAIT_QUEUE_HEAD(dlm_domain_events); /* * The supported protocol version for DLM communication. Running domains * will have a negotiated version with the same major number and a minor * number equal or smaller. The dlm_ctxt->dlm_locking_proto field should * be used to determine what a running domain is actually using. * * New in version 1.1: * - Message DLM_QUERY_REGION added to support global heartbeat * - Message DLM_QUERY_NODEINFO added to allow online node removes * New in version 1.2: * - Message DLM_BEGIN_EXIT_DOMAIN_MSG added to mark start of exit domain * New in version 1.3: * - Message DLM_DEREF_LOCKRES_DONE added to inform non-master that the * refmap is cleared */ static const struct dlm_protocol_version dlm_protocol = …; #define DLM_DOMAIN_BACKOFF_MS … static int dlm_query_join_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data); static int dlm_assert_joined_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data); static int dlm_cancel_join_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data); static int dlm_query_region_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data); static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data); static int dlm_protocol_compare(struct dlm_protocol_version *existing, struct dlm_protocol_version *request); static void dlm_unregister_domain_handlers(struct dlm_ctxt *dlm); void __dlm_unhash_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) { … } void __dlm_insert_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) { … } struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm, const char *name, unsigned int len, unsigned int hash) { … } /* intended to be called by functions which do not care about lock * resources which are being purged (most net _handler functions). * this will return NULL for any lock resource which is found but * currently in the process of dropping its mastery reference. * use __dlm_lookup_lockres_full when you need the lock resource * regardless (e.g. dlm_get_lock_resource) */ struct dlm_lock_resource * __dlm_lookup_lockres(struct dlm_ctxt *dlm, const char *name, unsigned int len, unsigned int hash) { … } struct dlm_lock_resource * dlm_lookup_lockres(struct dlm_ctxt *dlm, const char *name, unsigned int len) { … } static struct dlm_ctxt * __dlm_lookup_domain_full(const char *domain, int len) { … } /* For null terminated domain strings ONLY */ static struct dlm_ctxt * __dlm_lookup_domain(const char *domain) { … } /* returns true on one of two conditions: * 1) the domain does not exist * 2) the domain exists and it's state is "joined" */ static int dlm_wait_on_domain_helper(const char *domain) { … } static void dlm_free_ctxt_mem(struct dlm_ctxt *dlm) { … } /* A little strange - this function will be called while holding * dlm_domain_lock and is expected to be holding it on the way out. We * will however drop and reacquire it multiple times */ static void dlm_ctxt_release(struct kref *kref) { … } void dlm_put(struct dlm_ctxt *dlm) { … } static void __dlm_get(struct dlm_ctxt *dlm) { … } /* given a questionable reference to a dlm object, gets a reference if * it can find it in the list, otherwise returns NULL in which case * you shouldn't trust your pointer. */ struct dlm_ctxt *dlm_grab(struct dlm_ctxt *dlm) { … } int dlm_domain_fully_joined(struct dlm_ctxt *dlm) { … } static void dlm_destroy_dlm_worker(struct dlm_ctxt *dlm) { … } static void dlm_complete_dlm_shutdown(struct dlm_ctxt *dlm) { … } static int dlm_migrate_all_locks(struct dlm_ctxt *dlm) { … } static int dlm_no_joining_node(struct dlm_ctxt *dlm) { … } static int dlm_begin_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static void dlm_mark_domain_leaving(struct dlm_ctxt *dlm) { … } static void __dlm_print_nodes(struct dlm_ctxt *dlm) { … } static int dlm_exit_domain_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_send_one_domain_exit(struct dlm_ctxt *dlm, u32 msg_type, unsigned int node) { … } static void dlm_begin_exit_domain(struct dlm_ctxt *dlm) { … } static void dlm_leave_domain(struct dlm_ctxt *dlm) { … } void dlm_unregister_domain(struct dlm_ctxt *dlm) { … } EXPORT_SYMBOL_GPL(…); static int dlm_query_join_proto_check(char *proto_type, int node, struct dlm_protocol_version *ours, struct dlm_protocol_version *request) { … } /* * struct dlm_query_join_packet is made up of four one-byte fields. They * are effectively in big-endian order already. However, little-endian * machines swap them before putting the packet on the wire (because * query_join's response is a status, and that status is treated as a u32 * on the wire). Thus, a big-endian and little-endian machines will treat * this structure differently. * * The solution is to have little-endian machines swap the structure when * converting from the structure to the u32 representation. This will * result in the structure having the correct format on the wire no matter * the host endian format. */ static void dlm_query_join_packet_to_wire(struct dlm_query_join_packet *packet, u32 *wire) { … } static void dlm_query_join_wire_to_packet(u32 wire, struct dlm_query_join_packet *packet) { … } static int dlm_query_join_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_assert_joined_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_match_regions(struct dlm_ctxt *dlm, struct dlm_query_region *qr, char *local, int locallen) { … } static int dlm_send_regions(struct dlm_ctxt *dlm, unsigned long *node_map) { … } static int dlm_query_region_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_match_nodes(struct dlm_ctxt *dlm, struct dlm_query_nodeinfo *qn) { … } static int dlm_send_nodeinfo(struct dlm_ctxt *dlm, unsigned long *node_map) { … } static int dlm_query_nodeinfo_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_cancel_join_handler(struct o2net_msg *msg, u32 len, void *data, void **ret_data) { … } static int dlm_send_one_join_cancel(struct dlm_ctxt *dlm, unsigned int node) { … } /* map_size should be in bytes. */ static int dlm_send_join_cancels(struct dlm_ctxt *dlm, unsigned long *node_map, unsigned int map_size) { … } static int dlm_request_join(struct dlm_ctxt *dlm, int node, enum dlm_query_join_response_code *response) { … } static int dlm_send_one_join_assert(struct dlm_ctxt *dlm, unsigned int node) { … } static void dlm_send_join_asserts(struct dlm_ctxt *dlm, unsigned long *node_map) { … } struct domain_join_ctxt { … }; static int dlm_should_restart_join(struct dlm_ctxt *dlm, struct domain_join_ctxt *ctxt, enum dlm_query_join_response_code response) { … } static int dlm_try_to_join_domain(struct dlm_ctxt *dlm) { … } static void dlm_unregister_domain_handlers(struct dlm_ctxt *dlm) { … } static int dlm_register_domain_handlers(struct dlm_ctxt *dlm) { … } static int dlm_join_domain(struct dlm_ctxt *dlm) { … } static struct dlm_ctxt *dlm_alloc_ctxt(const char *domain, u32 key) { … } /* * Compare a requested locking protocol version against the current one. * * If the major numbers are different, they are incompatible. * If the current minor is greater than the request, they are incompatible. * If the current minor is less than or equal to the request, they are * compatible, and the requester should run at the current minor version. */ static int dlm_protocol_compare(struct dlm_protocol_version *existing, struct dlm_protocol_version *request) { … } /* * dlm_register_domain: one-time setup per "domain". * * The filesystem passes in the requested locking version via proto. * If registration was successful, proto will contain the negotiated * locking protocol. */ struct dlm_ctxt * dlm_register_domain(const char *domain, u32 key, struct dlm_protocol_version *fs_proto) { … } EXPORT_SYMBOL_GPL(…); static LIST_HEAD(dlm_join_handlers); static void dlm_unregister_net_handlers(void) { … } static int dlm_register_net_handlers(void) { … } /* Domain eviction callback handling. * * The file system requires notification of node death *before* the * dlm completes it's recovery work, otherwise it may be able to * acquire locks on resources requiring recovery. Since the dlm can * evict a node from it's domain *before* heartbeat fires, a similar * mechanism is required. */ /* Eviction is not expected to happen often, so a per-domain lock is * not necessary. Eviction callbacks are allowed to sleep for short * periods of time. */ static DECLARE_RWSEM(dlm_callback_sem); void dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm, int node_num) { … } void dlm_setup_eviction_cb(struct dlm_eviction_cb *cb, dlm_eviction_func *f, void *data) { … } EXPORT_SYMBOL_GPL(…); void dlm_register_eviction_cb(struct dlm_ctxt *dlm, struct dlm_eviction_cb *cb) { … } EXPORT_SYMBOL_GPL(…); void dlm_unregister_eviction_cb(struct dlm_eviction_cb *cb) { … } EXPORT_SYMBOL_GPL(…); static int __init dlm_init(void) { … } static void __exit dlm_exit (void) { … } MODULE_AUTHOR(…) …; MODULE_LICENSE(…) …; MODULE_DESCRIPTION(…) …; module_init(…) …; module_exit(dlm_exit);
Codebase Browser
linux