Lines Matching refs:conn

215 static int ocfs2_live_connection_attach(struct ocfs2_cluster_connection *conn,  in ocfs2_live_connection_attach()  argument
221 c->oc_conn = conn; in ocfs2_live_connection_attach()
689 static int user_dlm_lock(struct ocfs2_cluster_connection *conn, in user_dlm_lock() argument
702 ret = dlm_lock(conn->cc_lockspace, mode, &lksb->lksb_fsdlm, in user_dlm_lock()
709 static int user_dlm_unlock(struct ocfs2_cluster_connection *conn, in user_dlm_unlock() argument
715 ret = dlm_unlock(conn->cc_lockspace, lksb->lksb_fsdlm.sb_lkid, in user_dlm_unlock()
744 static int user_plock(struct ocfs2_cluster_connection *conn, in user_plock() argument
768 return dlm_posix_get(conn->cc_lockspace, ino, file, fl); in user_plock()
770 return dlm_posix_unlock(conn->cc_lockspace, ino, file, fl); in user_plock()
772 return dlm_posix_lock(conn->cc_lockspace, ino, file, cmd, fl); in user_plock()
824 struct ocfs2_cluster_connection *conn = arg; in sync_wait_cb() local
825 struct ocfs2_live_connection *lc = conn->cc_private; in sync_wait_cb()
829 static int sync_unlock(struct ocfs2_cluster_connection *conn, in sync_unlock() argument
833 struct ocfs2_live_connection *lc = conn->cc_private; in sync_unlock()
835 error = dlm_unlock(conn->cc_lockspace, lksb->sb_lkid, 0, lksb, conn); in sync_unlock()
852 static int sync_lock(struct ocfs2_cluster_connection *conn, in sync_lock() argument
857 struct ocfs2_live_connection *lc = conn->cc_private; in sync_lock()
859 error = dlm_lock(conn->cc_lockspace, mode, lksb, flags, in sync_lock()
861 0, sync_wait_cb, conn, NULL); in sync_lock()
881 static int version_lock(struct ocfs2_cluster_connection *conn, int mode, in version_lock() argument
884 struct ocfs2_live_connection *lc = conn->cc_private; in version_lock()
885 return sync_lock(conn, mode, flags, in version_lock()
889 static int version_unlock(struct ocfs2_cluster_connection *conn) in version_unlock() argument
891 struct ocfs2_live_connection *lc = conn->cc_private; in version_unlock()
892 return sync_unlock(conn, &lc->oc_version_lksb, VERSION_LOCK); in version_unlock()
906 static int get_protocol_version(struct ocfs2_cluster_connection *conn) in get_protocol_version() argument
909 struct ocfs2_live_connection *lc = conn->cc_private; in get_protocol_version()
918 ret = version_lock(conn, DLM_LOCK_EX, in get_protocol_version()
921 conn->cc_version.pv_major = running_proto.pv_major; in get_protocol_version()
922 conn->cc_version.pv_minor = running_proto.pv_minor; in get_protocol_version()
924 version_lock(conn, DLM_LOCK_PR, DLM_LKF_CONVERT|DLM_LKF_VALBLK); in get_protocol_version()
926 ret = version_lock(conn, DLM_LOCK_PR, DLM_LKF_VALBLK); in get_protocol_version()
937 conn->cc_version.pv_major = pv.pv_major; in get_protocol_version()
938 conn->cc_version.pv_minor = pv.pv_minor; in get_protocol_version()
950 struct ocfs2_cluster_connection *conn = arg; in user_recover_slot() local
953 conn->cc_recovery_handler(slot->nodeid, conn->cc_recovery_data); in user_recover_slot()
961 struct ocfs2_cluster_connection *conn = arg; in user_recover_done() local
962 struct ocfs2_live_connection *lc = conn->cc_private; in user_recover_done()
981 static int user_cluster_disconnect(struct ocfs2_cluster_connection *conn) in user_cluster_disconnect() argument
983 version_unlock(conn); in user_cluster_disconnect()
984 dlm_release_lockspace(conn->cc_lockspace, 2); in user_cluster_disconnect()
985 conn->cc_lockspace = NULL; in user_cluster_disconnect()
986 ocfs2_live_connection_drop(conn->cc_private); in user_cluster_disconnect()
987 conn->cc_private = NULL; in user_cluster_disconnect()
991 static int user_cluster_connect(struct ocfs2_cluster_connection *conn) in user_cluster_connect() argument
997 BUG_ON(conn == NULL); in user_cluster_connect()
1006 conn->cc_private = lc; in user_cluster_connect()
1009 rc = dlm_new_lockspace(conn->cc_name, conn->cc_cluster_name, in user_cluster_connect()
1011 &ocfs2_ls_ops, conn, &ops_rv, &fsdlm); in user_cluster_connect()
1024 conn->cc_lockspace = fsdlm; in user_cluster_connect()
1026 rc = ocfs2_live_connection_attach(conn, lc); in user_cluster_connect()
1031 rc = get_protocol_version(conn); in user_cluster_connect()
1035 user_cluster_disconnect(conn); in user_cluster_connect()
1045 if (fs_protocol_compare(&running_proto, &conn->cc_version)) { in user_cluster_connect()
1049 conn->cc_version.pv_major, conn->cc_version.pv_minor, in user_cluster_connect()
1063 static int user_cluster_this_node(struct ocfs2_cluster_connection *conn, in user_cluster_this_node() argument
1067 struct ocfs2_live_connection *lc = conn->cc_private; in user_cluster_this_node()