Lines Matching refs:conn

200 static int o2cb_dlm_lock(struct ocfs2_cluster_connection *conn,  in o2cb_dlm_lock()  argument
212 status = dlmlock(conn->cc_lockspace, o2dlm_mode, &lksb->lksb_o2dlm, in o2cb_dlm_lock()
220 static int o2cb_dlm_unlock(struct ocfs2_cluster_connection *conn, in o2cb_dlm_unlock() argument
228 status = dlmunlock(conn->cc_lockspace, &lksb->lksb_o2dlm, in o2cb_dlm_unlock()
320 struct ocfs2_cluster_connection *conn = data; in o2dlm_eviction_cb() local
323 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
325 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
328 static int o2cb_cluster_connect(struct ocfs2_cluster_connection *conn) in o2cb_cluster_connect() argument
336 BUG_ON(conn == NULL); in o2cb_cluster_connect()
337 BUG_ON(conn->cc_proto == NULL); in o2cb_cluster_connect()
355 conn); in o2cb_cluster_connect()
357 conn->cc_private = priv; in o2cb_cluster_connect()
361 dlm_key = crc32_le(0, conn->cc_name, conn->cc_namelen); in o2cb_cluster_connect()
362 fs_version.pv_major = conn->cc_version.pv_major; in o2cb_cluster_connect()
363 fs_version.pv_minor = conn->cc_version.pv_minor; in o2cb_cluster_connect()
365 dlm = dlm_register_domain(conn->cc_name, dlm_key, &fs_version); in o2cb_cluster_connect()
372 conn->cc_version.pv_major = fs_version.pv_major; in o2cb_cluster_connect()
373 conn->cc_version.pv_minor = fs_version.pv_minor; in o2cb_cluster_connect()
374 conn->cc_lockspace = dlm; in o2cb_cluster_connect()
380 kfree(conn->cc_private); in o2cb_cluster_connect()
386 static int o2cb_cluster_disconnect(struct ocfs2_cluster_connection *conn) in o2cb_cluster_disconnect() argument
388 struct dlm_ctxt *dlm = conn->cc_lockspace; in o2cb_cluster_disconnect()
389 struct o2dlm_private *priv = conn->cc_private; in o2cb_cluster_disconnect()
392 conn->cc_private = NULL; in o2cb_cluster_disconnect()
396 conn->cc_lockspace = NULL; in o2cb_cluster_disconnect()
401 static int o2cb_cluster_this_node(struct ocfs2_cluster_connection *conn, in o2cb_cluster_this_node() argument