fs/ocfs2/stack_user.c

206 static int ocfs2_live_connection_attach(struct ocfs2_cluster_connection *conn,
212 	c->oc_conn = conn;
680 static int user_dlm_lock(struct ocfs2_cluster_connection *conn,
691 	return dlm_lock(conn->cc_lockspace, mode, &lksb->lksb_fsdlm,
697 static int user_dlm_unlock(struct ocfs2_cluster_connection *conn,
701 	return dlm_unlock(conn->cc_lockspace, lksb->lksb_fsdlm.sb_lkid,
729 static int user_plock(struct ocfs2_cluster_connection *conn,
744 		return dlm_posix_cancel(conn->cc_lockspace, ino, file, fl);
746 		return dlm_posix_get(conn->cc_lockspace, ino, file, fl);
748 		return dlm_posix_unlock(conn->cc_lockspace, ino, file, fl);
750 		return dlm_posix_lock(conn->cc_lockspace, ino, file, cmd, fl);
802 	struct ocfs2_cluster_connection *conn = arg;
803 	struct ocfs2_live_connection *lc = conn->cc_private;
807 static int sync_unlock(struct ocfs2_cluster_connection *conn,
811 	struct ocfs2_live_connection *lc = conn->cc_private;
813 	error = dlm_unlock(conn->cc_lockspace, lksb->sb_lkid, 0, lksb, conn);
830 static int sync_lock(struct ocfs2_cluster_connection *conn,
835 	struct ocfs2_live_connection *lc = conn->cc_private;
837 	error = dlm_lock(conn->cc_lockspace, mode, lksb, flags,
839 			0, sync_wait_cb, conn, NULL);
859 static int version_lock(struct ocfs2_cluster_connection *conn, int mode,
862 	struct ocfs2_live_connection *lc = conn->cc_private;
863 	return sync_lock(conn, mode, flags,
867 static int version_unlock(struct ocfs2_cluster_connection *conn)
869 	struct ocfs2_live_connection *lc = conn->cc_private;
870 	return sync_unlock(conn, &lc->oc_version_lksb, VERSION_LOCK);
884 static int get_protocol_version(struct ocfs2_cluster_connection *conn)
887 	struct ocfs2_live_connection *lc = conn->cc_private;
896 	ret = version_lock(conn, DLM_LOCK_EX,
899 		conn->cc_version.pv_major = running_proto.pv_major;
900 		conn->cc_version.pv_minor = running_proto.pv_minor;
902 		version_lock(conn, DLM_LOCK_PR, DLM_LKF_CONVERT|DLM_LKF_VALBLK);
904 		ret = version_lock(conn, DLM_LOCK_PR, DLM_LKF_VALBLK);
915 		conn->cc_version.pv_major = pv.pv_major;
916 		conn->cc_version.pv_minor = pv.pv_minor;
928 	struct ocfs2_cluster_connection *conn = arg;
931 	conn->cc_recovery_handler(slot->nodeid, conn->cc_recovery_data);
939 	struct ocfs2_cluster_connection *conn = arg;
940 	struct ocfs2_live_connection *lc = conn->cc_private;
959 static int user_cluster_disconnect(struct ocfs2_cluster_connection *conn)
961 	version_unlock(conn);
962 	dlm_release_lockspace(conn->cc_lockspace, 2);
963 	conn->cc_lockspace = NULL;
964 	ocfs2_live_connection_drop(conn->cc_private);
965 	conn->cc_private = NULL;
969 static int user_cluster_connect(struct ocfs2_cluster_connection *conn)
975 	BUG_ON(conn == NULL);
984 	conn->cc_private = lc;
987 	rc = dlm_new_lockspace(conn->cc_name, conn->cc_cluster_name,
989 			       &ocfs2_ls_ops, conn, &ops_rv, &fsdlm);
996 				conn->cc_name, rc);
1009 	conn->cc_lockspace = fsdlm;
1011 	rc = ocfs2_live_connection_attach(conn, lc);
1016 		rc = get_protocol_version(conn);
1020 			user_cluster_disconnect(conn);
1030 	if (fs_protocol_compare(&running_proto, &conn->cc_version)) {
1034 		       conn->cc_version.pv_major, conn->cc_version.pv_minor,
1048 static int user_cluster_this_node(struct ocfs2_cluster_connection *conn,
1052 	struct ocfs2_live_connection *lc = conn->cc_private;