Lines Matching refs:osb
103 static void ocfs2_dentry_post_unlock(struct ocfs2_super *osb,
291 static int ocfs2_lock_create(struct ocfs2_super *osb,
297 static void ocfs2_cluster_unlock(struct ocfs2_super *osb,
304 static void ocfs2_schedule_blocked_lock(struct ocfs2_super *osb,
313 static void ocfs2_vote_on_unlock(struct ocfs2_super *osb,
317 static void ocfs2_drop_osb_locks(struct ocfs2_super *osb);
362 static void ocfs2_lock_res_init_common(struct ocfs2_super *osb,
380 ocfs2_add_lockres_tracking(res, osb->osb_dlm_debug);
489 struct ocfs2_super *osb)
496 ocfs2_lock_res_init_common(osb, res, OCFS2_LOCK_TYPE_SUPER,
497 &ocfs2_super_lops, osb);
501 struct ocfs2_super *osb)
507 ocfs2_lock_res_init_common(osb, res, OCFS2_LOCK_TYPE_RENAME,
508 &ocfs2_rename_lops, osb);
719 struct ocfs2_super *osb = ocfs2_get_lockres_osb(lockres);
732 ocfs2_schedule_blocked_lock(osb, lockres);
737 ocfs2_kick_vote_thread(osb);
804 static int ocfs2_lock_create(struct ocfs2_super *osb,
830 status = dlmlock(osb->dlm,
940 static int ocfs2_cluster_lock(struct ocfs2_super *osb,
948 int wait, catch_signals = !(osb->s_mount_opt & OCFS2_MOUNT_NOINTR);
989 ret = ocfs2_lock_create(osb, lockres, LKM_NLMODE, 0);
1023 status = dlmlock(osb->dlm,
1082 static void ocfs2_cluster_unlock(struct ocfs2_super *osb,
1091 ocfs2_vote_on_unlock(osb, lockres);
1096 static int ocfs2_create_new_lock(struct ocfs2_super *osb,
1110 return ocfs2_lock_create(osb, lockres, level, lkm_flags);
1122 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1139 ret = ocfs2_create_new_lock(osb, &OCFS2_I(inode)->ip_rw_lockres, 1, 1);
1149 ret = ocfs2_create_new_lock(osb, &OCFS2_I(inode)->ip_meta_lockres, 1, 0);
1155 ret = ocfs2_create_new_lock(osb, &OCFS2_I(inode)->ip_data_lockres, 1, 1);
1161 ret = ocfs2_create_new_lock(osb, &OCFS2_I(inode)->ip_open_lockres, 0, 0);
1176 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1186 if (ocfs2_mount_local(osb))
1206 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1214 if (!ocfs2_mount_local(osb))
1227 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1236 if (ocfs2_mount_local(osb))
1255 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1265 if (ocfs2_mount_local(osb))
1292 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1299 if (ocfs2_mount_local(osb))
1319 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1339 if (ocfs2_mount_local(osb))
1374 static void ocfs2_vote_on_unlock(struct ocfs2_super *osb,
1400 ocfs2_kick_vote_thread(osb);
1410 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1419 !ocfs2_mount_local(osb))
1611 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1615 if (ocfs2_mount_local(osb))
1728 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1743 if (ocfs2_is_hard_readonly(osb)) {
1749 if (ocfs2_mount_local(osb))
1753 wait_event(osb->recovery_event,
1754 ocfs2_node_map_is_empty(osb, &osb->recovery_map));
1762 status = ocfs2_cluster_lock(osb, lockres, level, dlm_flags, arg_flags);
1777 wait_event(osb->recovery_event,
1778 ocfs2_node_map_is_empty(osb, &osb->recovery_map));
1913 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);
1922 !ocfs2_mount_local(osb))
1928 int ocfs2_super_lock(struct ocfs2_super *osb,
1933 struct ocfs2_lock_res *lockres = &osb->osb_super_lockres;
1935 struct ocfs2_slot_info *si = osb->slot_info;
1939 if (ocfs2_is_hard_readonly(osb))
1942 if (ocfs2_mount_local(osb))
1945 status = ocfs2_cluster_lock(osb, lockres, level, 0, 0);
1962 status = ocfs2_read_block(osb, bh->b_blocknr, &bh, 0,
1977 void ocfs2_super_unlock(struct ocfs2_super *osb,
1981 struct ocfs2_lock_res *lockres = &osb->osb_super_lockres;
1983 if (!ocfs2_mount_local(osb))
1984 ocfs2_cluster_unlock(osb, lockres, level);
1987 int ocfs2_rename_lock(struct ocfs2_super *osb)
1990 struct ocfs2_lock_res *lockres = &osb->osb_rename_lockres;
1992 if (ocfs2_is_hard_readonly(osb))
1995 if (ocfs2_mount_local(osb))
1998 status = ocfs2_cluster_lock(osb, lockres, LKM_EXMODE, 0, 0);
2005 void ocfs2_rename_unlock(struct ocfs2_super *osb)
2007 struct ocfs2_lock_res *lockres = &osb->osb_rename_lockres;
2009 if (!ocfs2_mount_local(osb))
2010 ocfs2_cluster_unlock(osb, lockres, LKM_EXMODE);
2018 struct ocfs2_super *osb = OCFS2_SB(dentry->d_sb);
2022 if (ocfs2_is_hard_readonly(osb))
2025 if (ocfs2_mount_local(osb))
2028 ret = ocfs2_cluster_lock(osb, &dl->dl_lockres, level, 0, 0);
2039 struct ocfs2_super *osb = OCFS2_SB(dentry->d_sb);
2041 if (!ocfs2_mount_local(osb))
2042 ocfs2_cluster_unlock(osb, &dl->dl_lockres, level);
2234 struct ocfs2_super *osb;
2242 osb = inode->i_private;
2243 ocfs2_get_dlm_debug(osb->osb_dlm_debug);
2244 priv->p_dlm_debug = osb->osb_dlm_debug;
2271 static int ocfs2_dlm_init_debug(struct ocfs2_super *osb)
2274 struct ocfs2_dlm_debug *dlm_debug = osb->osb_dlm_debug;
2278 osb->osb_debug_root,
2279 osb,
2293 static void ocfs2_dlm_shutdown_debug(struct ocfs2_super *osb)
2295 struct ocfs2_dlm_debug *dlm_debug = osb->osb_dlm_debug;
2303 int ocfs2_dlm_init(struct ocfs2_super *osb)
2311 if (ocfs2_mount_local(osb))
2314 status = ocfs2_dlm_init_debug(osb);
2321 osb->vote_task = kthread_run(ocfs2_vote_thread, osb, "ocfs2vote");
2322 if (IS_ERR(osb->vote_task)) {
2323 status = PTR_ERR(osb->vote_task);
2324 osb->vote_task = NULL;
2331 dlm_key = crc32_le(0, osb->uuid_str, strlen(osb->uuid_str));
2334 dlm = dlm_register_domain(osb->uuid_str, dlm_key);
2341 dlm_register_eviction_cb(dlm, &osb->osb_eviction_cb);
2344 ocfs2_super_lock_res_init(&osb->osb_super_lockres, osb);
2345 ocfs2_rename_lock_res_init(&osb->osb_rename_lockres, osb);
2347 osb->dlm = dlm;
2352 ocfs2_dlm_shutdown_debug(osb);
2353 if (osb->vote_task)
2354 kthread_stop(osb->vote_task);
2361 void ocfs2_dlm_shutdown(struct ocfs2_super *osb)
2365 dlm_unregister_eviction_cb(&osb->osb_eviction_cb);
2367 ocfs2_drop_osb_locks(osb);
2369 if (osb->vote_task) {
2370 kthread_stop(osb->vote_task);
2371 osb->vote_task = NULL;
2374 ocfs2_lock_res_free(&osb->osb_super_lockres);
2375 ocfs2_lock_res_free(&osb->osb_rename_lockres);
2377 dlm_unregister_domain(osb->dlm);
2378 osb->dlm = NULL;
2380 ocfs2_dlm_shutdown_debug(osb);
2441 static int ocfs2_drop_lock(struct ocfs2_super *osb,
2505 status = dlmunlock(osb->dlm, &lockres->l_lksb, lkm_flags,
2553 void ocfs2_simple_drop_lockres(struct ocfs2_super *osb,
2559 ret = ocfs2_drop_lock(osb, lockres);
2564 static void ocfs2_drop_osb_locks(struct ocfs2_super *osb)
2566 ocfs2_simple_drop_lockres(osb, &osb->osb_super_lockres);
2567 ocfs2_simple_drop_lockres(osb, &osb->osb_rename_lockres);
2632 static int ocfs2_downconvert_lock(struct ocfs2_super *osb,
2645 status = dlmlock(osb->dlm,
2668 static int ocfs2_prepare_cancel_convert(struct ocfs2_super *osb,
2699 static int ocfs2_cancel_convert(struct ocfs2_super *osb,
2709 status = dlmunlock(osb->dlm,
2726 static int ocfs2_unblock_lock(struct ocfs2_super *osb,
2745 ret = ocfs2_prepare_cancel_convert(osb, lockres);
2748 ret = ocfs2_cancel_convert(osb, lockres);
2825 ret = ocfs2_downconvert_lock(osb, lockres, new_level, set_lvb);
2903 static void ocfs2_dentry_post_unlock(struct ocfs2_super *osb,
2907 ocfs2_dentry_lock_put(osb, dl);
3020 void ocfs2_process_blocked_lock(struct ocfs2_super *osb,
3048 status = ocfs2_unblock_lock(osb, lockres, &ctl);
3057 ocfs2_schedule_blocked_lock(osb, lockres);
3065 lockres->l_ops->post_unlock(osb, lockres);
3070 static void ocfs2_schedule_blocked_lock(struct ocfs2_super *osb,
3088 spin_lock(&osb->vote_task_lock);
3091 &osb->blocked_lock_list);
3092 osb->blocked_lock_count++;
3094 spin_unlock(&osb->vote_task_lock);