ocfs2/dlm/dlmconvert.c

41 static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm,
46 static enum dlm_status dlm_send_remote_convert_request(struct dlm_ctxt *dlm,
59 enum dlm_status dlmconvert_master(struct dlm_ctxt *dlm,
72 	status = __dlmconvert_master(dlm, res, lock, flags, type,
83 		dlm_queue_ast(dlm, lock);
85 		dlm_lockres_release_ast(dlm, res);
88 		dlm_kick_thread(dlm, res);
102 static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm,
192 	if (lock->ml.node == dlm->node_num)
249 enum dlm_status dlmconvert_remote(struct dlm_ctxt *dlm,
316 	status = dlm_send_remote_convert_request(dlm, res, lock, flags, type);
331 				dlm->name, res->lockname.len, res->lockname.name);
353 static enum dlm_status dlm_send_remote_convert_request(struct dlm_ctxt *dlm,
367 	convert.node_idx = dlm->node_num;
384 	tmpret = o2net_send_message_vec(DLM_CONVERT_LOCK_MSG, dlm->key,
402 		     "node %u\n", tmpret, DLM_CONVERT_LOCK_MSG, dlm->key,
408 			dlm_wait_for_node_death(dlm, res->owner,
432 	struct dlm_ctxt *dlm = data;
442 	if (!dlm_grab(dlm)) {
447 	mlog_bug_on_msg(!dlm_domain_fully_joined(dlm),
448 			"Domain %s not fully joined!\n", dlm->name);
469 	res = dlm_lookup_lockres(dlm, cnv->name, cnv->namelen);
520 		status = __dlmconvert_master(dlm, res, lock, flags,
542 		dlm_queue_ast(dlm, lock);
544 		dlm_lockres_release_ast(dlm, res);
547 		dlm_kick_thread(dlm, res);
552 	dlm_put(dlm);