Lines Matching defs:conn
207 static int ocfs2_live_connection_attach(struct ocfs2_cluster_connection *conn,
213 c->oc_conn = conn;
681 static int user_dlm_lock(struct ocfs2_cluster_connection *conn,
694 ret = dlm_lock(conn->cc_lockspace, mode, &lksb->lksb_fsdlm,
701 static int user_dlm_unlock(struct ocfs2_cluster_connection *conn,
707 ret = dlm_unlock(conn->cc_lockspace, lksb->lksb_fsdlm.sb_lkid,
736 static int user_plock(struct ocfs2_cluster_connection *conn,
760 return dlm_posix_get(conn->cc_lockspace, ino, file, fl);
762 return dlm_posix_unlock(conn->cc_lockspace, ino, file, fl);
764 return dlm_posix_lock(conn->cc_lockspace, ino, file, cmd, fl);
816 struct ocfs2_cluster_connection *conn = arg;
817 struct ocfs2_live_connection *lc = conn->cc_private;
821 static int sync_unlock(struct ocfs2_cluster_connection *conn,
825 struct ocfs2_live_connection *lc = conn->cc_private;
827 error = dlm_unlock(conn->cc_lockspace, lksb->sb_lkid, 0, lksb, conn);
844 static int sync_lock(struct ocfs2_cluster_connection *conn,
849 struct ocfs2_live_connection *lc = conn->cc_private;
851 error = dlm_lock(conn->cc_lockspace, mode, lksb, flags,
853 0, sync_wait_cb, conn, NULL);
873 static int version_lock(struct ocfs2_cluster_connection *conn, int mode,
876 struct ocfs2_live_connection *lc = conn->cc_private;
877 return sync_lock(conn, mode, flags,
881 static int version_unlock(struct ocfs2_cluster_connection *conn)
883 struct ocfs2_live_connection *lc = conn->cc_private;
884 return sync_unlock(conn, &lc->oc_version_lksb, VERSION_LOCK);
898 static int get_protocol_version(struct ocfs2_cluster_connection *conn)
901 struct ocfs2_live_connection *lc = conn->cc_private;
910 ret = version_lock(conn, DLM_LOCK_EX,
913 conn->cc_version.pv_major = running_proto.pv_major;
914 conn->cc_version.pv_minor = running_proto.pv_minor;
916 version_lock(conn, DLM_LOCK_PR, DLM_LKF_CONVERT|DLM_LKF_VALBLK);
918 ret = version_lock(conn, DLM_LOCK_PR, DLM_LKF_VALBLK);
929 conn->cc_version.pv_major = pv.pv_major;
930 conn->cc_version.pv_minor = pv.pv_minor;
942 struct ocfs2_cluster_connection *conn = arg;
945 conn->cc_recovery_handler(slot->nodeid, conn->cc_recovery_data);
953 struct ocfs2_cluster_connection *conn = arg;
954 struct ocfs2_live_connection *lc = conn->cc_private;
973 static int user_cluster_disconnect(struct ocfs2_cluster_connection *conn)
975 version_unlock(conn);
976 dlm_release_lockspace(conn->cc_lockspace, 2);
977 conn->cc_lockspace = NULL;
978 ocfs2_live_connection_drop(conn->cc_private);
979 conn->cc_private = NULL;
983 static int user_cluster_connect(struct ocfs2_cluster_connection *conn)
989 BUG_ON(conn == NULL);
998 conn->cc_private = lc;
1001 rc = dlm_new_lockspace(conn->cc_name, conn->cc_cluster_name,
1003 &ocfs2_ls_ops, conn, &ops_rv, &fsdlm);
1010 conn->cc_name, rc);
1023 conn->cc_lockspace = fsdlm;
1025 rc = ocfs2_live_connection_attach(conn, lc);
1030 rc = get_protocol_version(conn);
1034 user_cluster_disconnect(conn);
1044 if (fs_protocol_compare(&running_proto, &conn->cc_version)) {
1048 conn->cc_version.pv_major, conn->cc_version.pv_minor,
1062 static int user_cluster_this_node(struct ocfs2_cluster_connection *conn,
1066 struct ocfs2_live_connection *lc = conn->cc_private;