1 // SPDX-License-Identifier: GPL-2.0-only
5 **  Copyright (C) Sistina Software, Inc.  1997-2003  All rights reserved.
6 **  Copyright (C) 2004-2005 Red Hat, Inc.  All rights reserved.
25  * We use the upper 16 bits of the hash value to select the directory node.
26  * Low bits are used for distribution of rsb's among hash buckets on each node.
28  * To give the exact range wanted (0 to num_nodes-1), we apply a modulus of
33 int dlm_hash2nodeid(struct dlm_ls *ls, uint32_t hash)  in dlm_hash2nodeid()  argument
37 	if (ls->ls_num_nodes == 1)  in dlm_hash2nodeid()
40 		node = (hash >> 16) % ls->ls_total_weight;  in dlm_hash2nodeid()
41 		return ls->ls_node_array[node];  in dlm_hash2nodeid()
47 	return r->res_dir_nodeid;  in dlm_dir_nodeid()
50 void dlm_recover_dir_nodeid(struct dlm_ls *ls)  in dlm_recover_dir_nodeid()  argument
54 	down_read(&ls->ls_root_sem);  in dlm_recover_dir_nodeid()
55 	list_for_each_entry(r, &ls->ls_root_list, res_root_list) {  in dlm_recover_dir_nodeid()
56 		r->res_dir_nodeid = dlm_hash2nodeid(ls, r->res_hash);  in dlm_recover_dir_nodeid()
58 	up_read(&ls->ls_root_sem);  in dlm_recover_dir_nodeid()
61 int dlm_recover_directory(struct dlm_ls *ls, uint64_t seq)  in dlm_recover_directory()  argument
65 	int error = -ENOMEM, last_len, nodeid, result;  in dlm_recover_directory()
69 	log_rinfo(ls, "dlm_recover_directory");  in dlm_recover_directory()
71 	if (dlm_no_directory(ls))  in dlm_recover_directory()
78 	list_for_each_entry(memb, &ls->ls_nodes, list) {  in dlm_recover_directory()
79 		if (memb->nodeid == dlm_our_nodeid())  in dlm_recover_directory()
87 			if (dlm_recovery_stopped(ls)) {  in dlm_recover_directory()
88 				error = -EINTR;  in dlm_recover_directory()
92 			error = dlm_rcom_names(ls, memb->nodeid,  in dlm_recover_directory()
103 			b = ls->ls_recover_buf->rc_buf;  in dlm_recover_directory()
104 			left = le16_to_cpu(ls->ls_recover_buf->rc_header.h_length);  in dlm_recover_directory()
105 			left -= sizeof(struct dlm_rcom);  in dlm_recover_directory()
110 				error = -EINVAL;  in dlm_recover_directory()
117 				left -= sizeof(__be16);  in dlm_recover_directory()
134 				error = dlm_master_lookup(ls, memb->nodeid,  in dlm_recover_directory()
139 					log_error(ls, "recover_dir lookup %d",  in dlm_recover_directory()
146 				 * memb->nodeid which says it is the master.  in dlm_recover_directory()
150 				    nodeid != memb->nodeid) {  in dlm_recover_directory()
152 					log_error(ls, "recover_dir lookup %d "  in dlm_recover_directory()
154 						  result, nodeid, memb->nodeid,  in dlm_recover_directory()
162 				 * master nodeid matches memb->nodeid. */  in dlm_recover_directory()
165 				    nodeid == memb->nodeid) {  in dlm_recover_directory()
170 				 * added with memb->nodeid as the master. */  in dlm_recover_directory()
179 				left -= namelen;  in dlm_recover_directory()
189 	dlm_set_recover_status(ls, DLM_RS_DIR);  in dlm_recover_directory()
191 	log_rinfo(ls, "dlm_recover_directory %u in %u new",  in dlm_recover_directory()
199 static struct dlm_rsb *find_rsb_root(struct dlm_ls *ls, const char *name,  in find_rsb_root()  argument
207 	bucket = hash & (ls->ls_rsbtbl_size - 1);  in find_rsb_root()
209 	spin_lock(&ls->ls_rsbtbl[bucket].lock);  in find_rsb_root()
210 	rv = dlm_search_rsb_tree(&ls->ls_rsbtbl[bucket].keep, name, len, &r);  in find_rsb_root()
212 		rv = dlm_search_rsb_tree(&ls->ls_rsbtbl[bucket].toss,  in find_rsb_root()
214 	spin_unlock(&ls->ls_rsbtbl[bucket].lock);  in find_rsb_root()
219 	down_read(&ls->ls_root_sem);  in find_rsb_root()
220 	list_for_each_entry(r, &ls->ls_root_list, res_root_list) {  in find_rsb_root()
221 		if (len == r->res_length && !memcmp(name, r->res_name, len)) {  in find_rsb_root()
222 			up_read(&ls->ls_root_sem);  in find_rsb_root()
223 			log_debug(ls, "find_rsb_root revert to root_list %s",  in find_rsb_root()
224 				  r->res_name);  in find_rsb_root()
228 	up_read(&ls->ls_root_sem);  in find_rsb_root()
236 void dlm_copy_master_names(struct dlm_ls *ls, const char *inbuf, int inlen,  in dlm_copy_master_names()  argument
244 	down_read(&ls->ls_root_sem);  in dlm_copy_master_names()
247 		r = find_rsb_root(ls, inbuf, inlen);  in dlm_copy_master_names()
249 			log_error(ls, "copy_master_names from %d start %d %.*s",  in dlm_copy_master_names()
253 		list = r->res_root_list.next;  in dlm_copy_master_names()
255 		list = ls->ls_root_list.next;  in dlm_copy_master_names()
258 	for (offset = 0; list != &ls->ls_root_list; list = list->next) {  in dlm_copy_master_names()
260 		if (r->res_nodeid)  in dlm_copy_master_names()
271 		 * name (r->res_length) +  in dlm_copy_master_names()
272 		 * end-of-block record 0x0000 (uint16_t)  in dlm_copy_master_names()
275 		if (offset + sizeof(uint16_t)*2 + r->res_length > outlen) {  in dlm_copy_master_names()
276 			/* Write end-of-block record */  in dlm_copy_master_names()
280 			ls->ls_recover_dir_sent_msg++;  in dlm_copy_master_names()
284 		be_namelen = cpu_to_be16(r->res_length);  in dlm_copy_master_names()
287 		memcpy(outbuf + offset, r->res_name, r->res_length);  in dlm_copy_master_names()
288 		offset += r->res_length;  in dlm_copy_master_names()
289 		ls->ls_recover_dir_sent_res++;  in dlm_copy_master_names()
297 	if ((list == &ls->ls_root_list) &&  in dlm_copy_master_names()
302 		ls->ls_recover_dir_sent_msg++;  in dlm_copy_master_names()
305 	up_read(&ls->ls_root_sem);  in dlm_copy_master_names()