Lines Matching refs:osb
49 static int ocfs2_recover_node(struct ocfs2_super *osb,
52 static int ocfs2_commit_cache(struct ocfs2_super *osb);
53 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota);
54 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,
56 static int ocfs2_trylock_journal(struct ocfs2_super *osb,
58 static int ocfs2_recover_orphans(struct ocfs2_super *osb,
69 static inline int ocfs2_wait_on_mount(struct ocfs2_super *osb) in ocfs2_wait_on_mount() argument
71 return __ocfs2_wait_on_mount(osb, 0); in ocfs2_wait_on_mount()
74 static inline int ocfs2_wait_on_quotas(struct ocfs2_super *osb) in ocfs2_wait_on_quotas() argument
76 return __ocfs2_wait_on_mount(osb, 1); in ocfs2_wait_on_quotas()
96 static void ocfs2_replay_map_set_state(struct ocfs2_super *osb, int state) in ocfs2_replay_map_set_state() argument
98 if (!osb->replay_map) in ocfs2_replay_map_set_state()
102 if (osb->replay_map->rm_state == REPLAY_DONE) in ocfs2_replay_map_set_state()
105 osb->replay_map->rm_state = state; in ocfs2_replay_map_set_state()
108 int ocfs2_compute_replay_slots(struct ocfs2_super *osb) in ocfs2_compute_replay_slots() argument
114 if (osb->replay_map) in ocfs2_compute_replay_slots()
118 osb->max_slots), in ocfs2_compute_replay_slots()
125 spin_lock(&osb->osb_lock); in ocfs2_compute_replay_slots()
127 replay_map->rm_slots = osb->max_slots; in ocfs2_compute_replay_slots()
132 if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT) in ocfs2_compute_replay_slots()
136 osb->replay_map = replay_map; in ocfs2_compute_replay_slots()
137 spin_unlock(&osb->osb_lock); in ocfs2_compute_replay_slots()
141 static void ocfs2_queue_replay_slots(struct ocfs2_super *osb, in ocfs2_queue_replay_slots() argument
144 struct ocfs2_replay_map *replay_map = osb->replay_map; in ocfs2_queue_replay_slots()
155 ocfs2_queue_recovery_completion(osb->journal, i, NULL, in ocfs2_queue_replay_slots()
161 void ocfs2_free_replay_slots(struct ocfs2_super *osb) in ocfs2_free_replay_slots() argument
163 struct ocfs2_replay_map *replay_map = osb->replay_map; in ocfs2_free_replay_slots()
165 if (!osb->replay_map) in ocfs2_free_replay_slots()
169 osb->replay_map = NULL; in ocfs2_free_replay_slots()
172 int ocfs2_recovery_init(struct ocfs2_super *osb) in ocfs2_recovery_init() argument
176 mutex_init(&osb->recovery_lock); in ocfs2_recovery_init()
177 osb->disable_recovery = 0; in ocfs2_recovery_init()
178 osb->recovery_thread_task = NULL; in ocfs2_recovery_init()
179 init_waitqueue_head(&osb->recovery_event); in ocfs2_recovery_init()
181 rm = kzalloc(struct_size(rm, rm_entries, osb->max_slots), in ocfs2_recovery_init()
188 osb->recovery_map = rm; in ocfs2_recovery_init()
196 static int ocfs2_recovery_thread_running(struct ocfs2_super *osb) in ocfs2_recovery_thread_running() argument
199 return osb->recovery_thread_task != NULL; in ocfs2_recovery_thread_running()
202 void ocfs2_recovery_exit(struct ocfs2_super *osb) in ocfs2_recovery_exit() argument
208 mutex_lock(&osb->recovery_lock); in ocfs2_recovery_exit()
209 osb->disable_recovery = 1; in ocfs2_recovery_exit()
210 mutex_unlock(&osb->recovery_lock); in ocfs2_recovery_exit()
211 wait_event(osb->recovery_event, !ocfs2_recovery_thread_running(osb)); in ocfs2_recovery_exit()
216 if (osb->ocfs2_wq) in ocfs2_recovery_exit()
217 flush_workqueue(osb->ocfs2_wq); in ocfs2_recovery_exit()
223 rm = osb->recovery_map; in ocfs2_recovery_exit()
229 static int __ocfs2_recovery_map_test(struct ocfs2_super *osb, in __ocfs2_recovery_map_test() argument
233 struct ocfs2_recovery_map *rm = osb->recovery_map; in __ocfs2_recovery_map_test()
235 assert_spin_locked(&osb->osb_lock); in __ocfs2_recovery_map_test()
246 static int ocfs2_recovery_map_set(struct ocfs2_super *osb, in ocfs2_recovery_map_set() argument
249 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_map_set()
251 spin_lock(&osb->osb_lock); in ocfs2_recovery_map_set()
252 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_recovery_map_set()
253 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_set()
258 BUG_ON(rm->rm_used >= osb->max_slots); in ocfs2_recovery_map_set()
262 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_set()
267 static void ocfs2_recovery_map_clear(struct ocfs2_super *osb, in ocfs2_recovery_map_clear() argument
271 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_map_clear()
273 spin_lock(&osb->osb_lock); in ocfs2_recovery_map_clear()
287 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_clear()
290 static int ocfs2_commit_cache(struct ocfs2_super *osb) in ocfs2_commit_cache() argument
296 journal = osb->journal; in ocfs2_commit_cache()
325 ocfs2_wake_downconvert_thread(osb); in ocfs2_commit_cache()
331 handle_t *ocfs2_start_trans(struct ocfs2_super *osb, int max_buffs) in ocfs2_start_trans() argument
333 journal_t *journal = osb->journal->j_journal; in ocfs2_start_trans()
336 BUG_ON(!osb || !osb->journal->j_journal); in ocfs2_start_trans()
338 if (ocfs2_is_hard_readonly(osb)) in ocfs2_start_trans()
341 BUG_ON(osb->journal->j_state == OCFS2_JOURNAL_FREE); in ocfs2_start_trans()
348 sb_start_intwrite(osb->sb); in ocfs2_start_trans()
350 down_read(&osb->journal->j_trans_barrier); in ocfs2_start_trans()
354 up_read(&osb->journal->j_trans_barrier); in ocfs2_start_trans()
355 sb_end_intwrite(osb->sb); in ocfs2_start_trans()
360 ocfs2_abort(osb->sb, "Detected aborted journal\n"); in ocfs2_start_trans()
364 if (!ocfs2_mount_local(osb)) in ocfs2_start_trans()
365 atomic_inc(&(osb->journal->j_num_trans)); in ocfs2_start_trans()
371 int ocfs2_commit_trans(struct ocfs2_super *osb, in ocfs2_commit_trans() argument
375 struct ocfs2_journal *journal = osb->journal; in ocfs2_commit_trans()
386 sb_end_intwrite(osb->sb); in ocfs2_commit_trans()
638 struct ocfs2_super *osb = in __ocfs2_journal_access() local
668 return ocfs2_error(osb->sb, "A previous attempt to " in __ocfs2_journal_access()
680 ocfs2_set_ci_lock_trans(osb->journal, ci); in __ocfs2_journal_access()
697 if (!status && ocfs2_meta_ecc(osb) && triggers) in __ocfs2_journal_access()
794 void ocfs2_set_journal_params(struct ocfs2_super *osb) in ocfs2_set_journal_params() argument
796 journal_t *journal = osb->journal->j_journal; in ocfs2_set_journal_params()
799 if (osb->osb_commit_interval) in ocfs2_set_journal_params()
800 commit_interval = osb->osb_commit_interval; in ocfs2_set_journal_params()
804 if (osb->s_mount_opt & OCFS2_MOUNT_BARRIER) in ocfs2_set_journal_params()
815 int ocfs2_journal_alloc(struct ocfs2_super *osb) in ocfs2_journal_alloc() argument
826 osb->journal = journal; in ocfs2_journal_alloc()
827 journal->j_osb = osb; in ocfs2_journal_alloc()
855 int ocfs2_journal_init(struct ocfs2_super *osb, int *dirty) in ocfs2_journal_init() argument
860 struct ocfs2_journal *journal = osb->journal; in ocfs2_journal_init()
867 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_journal_init()
868 osb->slot_num); in ocfs2_journal_init()
930 ocfs2_set_journal_params(osb); in ocfs2_journal_init()
959 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb, in ocfs2_journal_toggle_dirty() argument
964 struct ocfs2_journal *journal = osb->journal; in ocfs2_journal_toggle_dirty()
985 ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check); in ocfs2_journal_toggle_dirty()
986 status = ocfs2_write_block(osb, bh, INODE_CACHE(journal->j_inode)); in ocfs2_journal_toggle_dirty()
997 void ocfs2_journal_shutdown(struct ocfs2_super *osb) in ocfs2_journal_shutdown() argument
1004 BUG_ON(!osb); in ocfs2_journal_shutdown()
1006 journal = osb->journal; in ocfs2_journal_shutdown()
1019 num_running_trans = atomic_read(&(osb->journal->j_num_trans)); in ocfs2_journal_shutdown()
1031 if (osb->commit_task) { in ocfs2_journal_shutdown()
1033 trace_ocfs2_journal_shutdown_wait(osb->commit_task); in ocfs2_journal_shutdown()
1034 kthread_stop(osb->commit_task); in ocfs2_journal_shutdown()
1035 osb->commit_task = NULL; in ocfs2_journal_shutdown()
1038 BUG_ON(atomic_read(&(osb->journal->j_num_trans)) != 0); in ocfs2_journal_shutdown()
1040 if (ocfs2_mount_local(osb)) { in ocfs2_journal_shutdown()
1054 status = ocfs2_journal_toggle_dirty(osb, 0, 0); in ocfs2_journal_shutdown()
1073 osb->journal = NULL; in ocfs2_journal_shutdown()
1097 struct ocfs2_super *osb; in ocfs2_journal_load() local
1101 osb = journal->j_osb; in ocfs2_journal_load()
1109 ocfs2_clear_journal_error(osb->sb, journal->j_journal, osb->slot_num); in ocfs2_journal_load()
1119 status = ocfs2_journal_toggle_dirty(osb, 1, replayed); in ocfs2_journal_load()
1127 osb->commit_task = kthread_run(ocfs2_commit_thread, osb, in ocfs2_journal_load()
1128 "ocfs2cmt-%s", osb->uuid_str); in ocfs2_journal_load()
1129 if (IS_ERR(osb->commit_task)) { in ocfs2_journal_load()
1130 status = PTR_ERR(osb->commit_task); in ocfs2_journal_load()
1131 osb->commit_task = NULL; in ocfs2_journal_load()
1137 osb->commit_task = NULL; in ocfs2_journal_load()
1166 static int ocfs2_recovery_completed(struct ocfs2_super *osb) in ocfs2_recovery_completed() argument
1169 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_completed()
1171 spin_lock(&osb->osb_lock); in ocfs2_recovery_completed()
1173 spin_unlock(&osb->osb_lock); in ocfs2_recovery_completed()
1178 void ocfs2_wait_for_recovery(struct ocfs2_super *osb) in ocfs2_wait_for_recovery() argument
1180 wait_event(osb->recovery_event, ocfs2_recovery_completed(osb)); in ocfs2_wait_for_recovery()
1199 struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); in ocfs2_force_read_journal() local
1212 bh = __find_get_block(osb->sb->s_bdev, p_blkno, in ocfs2_force_read_journal()
1213 osb->sb->s_blocksize); in ocfs2_force_read_journal()
1223 status = ocfs2_read_blocks_sync(osb, p_blkno, 1, &bh); in ocfs2_force_read_journal()
1264 struct ocfs2_super *osb = journal->j_osb; in ocfs2_complete_recovery() local
1281 ocfs2_wait_on_quotas(osb); in ocfs2_complete_recovery()
1294 ret = ocfs2_complete_local_alloc_recovery(osb, in ocfs2_complete_recovery()
1303 ret = ocfs2_complete_truncate_log_recovery(osb, in ocfs2_complete_recovery()
1311 ret = ocfs2_recover_orphans(osb, item->lri_slot, in ocfs2_complete_recovery()
1317 ret = ocfs2_finish_quota_recovery(osb, qrec, in ocfs2_complete_recovery()
1372 void ocfs2_complete_mount_recovery(struct ocfs2_super *osb) in ocfs2_complete_mount_recovery() argument
1374 struct ocfs2_journal *journal = osb->journal; in ocfs2_complete_mount_recovery()
1376 if (ocfs2_is_hard_readonly(osb)) in ocfs2_complete_mount_recovery()
1381 ocfs2_queue_recovery_completion(journal, osb->slot_num, in ocfs2_complete_mount_recovery()
1382 osb->local_alloc_copy, NULL, NULL, in ocfs2_complete_mount_recovery()
1384 ocfs2_schedule_truncate_log_flush(osb, 0); in ocfs2_complete_mount_recovery()
1386 osb->local_alloc_copy = NULL; in ocfs2_complete_mount_recovery()
1389 ocfs2_replay_map_set_state(osb, REPLAY_NEEDED); in ocfs2_complete_mount_recovery()
1390 ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE); in ocfs2_complete_mount_recovery()
1391 ocfs2_free_replay_slots(osb); in ocfs2_complete_mount_recovery()
1394 void ocfs2_complete_quota_recovery(struct ocfs2_super *osb) in ocfs2_complete_quota_recovery() argument
1396 if (osb->quota_rec) { in ocfs2_complete_quota_recovery()
1397 ocfs2_queue_recovery_completion(osb->journal, in ocfs2_complete_quota_recovery()
1398 osb->slot_num, in ocfs2_complete_quota_recovery()
1401 osb->quota_rec, in ocfs2_complete_quota_recovery()
1403 osb->quota_rec = NULL; in ocfs2_complete_quota_recovery()
1410 struct ocfs2_super *osb = arg; in __ocfs2_recovery_thread() local
1411 struct ocfs2_recovery_map *rm = osb->recovery_map; in __ocfs2_recovery_thread()
1417 int quota_enabled = OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb, in __ocfs2_recovery_thread()
1419 || OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb, in __ocfs2_recovery_thread()
1422 status = ocfs2_wait_on_mount(osb); in __ocfs2_recovery_thread()
1428 rm_quota = kcalloc(osb->max_slots, sizeof(int), GFP_NOFS); in __ocfs2_recovery_thread()
1435 status = ocfs2_super_lock(osb, 1); in __ocfs2_recovery_thread()
1441 status = ocfs2_compute_replay_slots(osb); in __ocfs2_recovery_thread()
1446 ocfs2_queue_recovery_completion(osb->journal, osb->slot_num, NULL, in __ocfs2_recovery_thread()
1449 spin_lock(&osb->osb_lock); in __ocfs2_recovery_thread()
1454 spin_unlock(&osb->osb_lock); in __ocfs2_recovery_thread()
1455 slot_num = ocfs2_node_num_to_slot(osb, node_num); in __ocfs2_recovery_thread()
1477 status = ocfs2_recover_node(osb, node_num, slot_num); in __ocfs2_recovery_thread()
1480 ocfs2_recovery_map_clear(osb, node_num); in __ocfs2_recovery_thread()
1485 MAJOR(osb->sb->s_dev), MINOR(osb->sb->s_dev)); in __ocfs2_recovery_thread()
1489 spin_lock(&osb->osb_lock); in __ocfs2_recovery_thread()
1491 spin_unlock(&osb->osb_lock); in __ocfs2_recovery_thread()
1495 status = ocfs2_check_journals_nolocks(osb); in __ocfs2_recovery_thread()
1505 qrec = ocfs2_begin_quota_recovery(osb, rm_quota[i]); in __ocfs2_recovery_thread()
1511 ocfs2_queue_recovery_completion(osb->journal, in __ocfs2_recovery_thread()
1518 ocfs2_super_unlock(osb, 1); in __ocfs2_recovery_thread()
1521 ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE); in __ocfs2_recovery_thread()
1524 mutex_lock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1525 if (!status && !ocfs2_recovery_completed(osb)) { in __ocfs2_recovery_thread()
1526 mutex_unlock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1530 ocfs2_free_replay_slots(osb); in __ocfs2_recovery_thread()
1531 osb->recovery_thread_task = NULL; in __ocfs2_recovery_thread()
1533 wake_up(&osb->recovery_event); in __ocfs2_recovery_thread()
1535 mutex_unlock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1543 void ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num) in ocfs2_recovery_thread() argument
1545 mutex_lock(&osb->recovery_lock); in ocfs2_recovery_thread()
1547 trace_ocfs2_recovery_thread(node_num, osb->node_num, in ocfs2_recovery_thread()
1548 osb->disable_recovery, osb->recovery_thread_task, in ocfs2_recovery_thread()
1549 osb->disable_recovery ? in ocfs2_recovery_thread()
1550 -1 : ocfs2_recovery_map_set(osb, node_num)); in ocfs2_recovery_thread()
1552 if (osb->disable_recovery) in ocfs2_recovery_thread()
1555 if (osb->recovery_thread_task) in ocfs2_recovery_thread()
1558 osb->recovery_thread_task = kthread_run(__ocfs2_recovery_thread, osb, in ocfs2_recovery_thread()
1559 "ocfs2rec-%s", osb->uuid_str); in ocfs2_recovery_thread()
1560 if (IS_ERR(osb->recovery_thread_task)) { in ocfs2_recovery_thread()
1561 mlog_errno((int)PTR_ERR(osb->recovery_thread_task)); in ocfs2_recovery_thread()
1562 osb->recovery_thread_task = NULL; in ocfs2_recovery_thread()
1566 mutex_unlock(&osb->recovery_lock); in ocfs2_recovery_thread()
1567 wake_up(&osb->recovery_event); in ocfs2_recovery_thread()
1570 static int ocfs2_read_journal_inode(struct ocfs2_super *osb, in ocfs2_read_journal_inode() argument
1578 BUG_ON(slot_num >= osb->max_slots); in ocfs2_read_journal_inode()
1580 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_read_journal_inode()
1608 static int ocfs2_replay_journal(struct ocfs2_super *osb, in ocfs2_replay_journal() argument
1621 status = ocfs2_read_journal_inode(osb, slot_num, &bh, &inode); in ocfs2_replay_journal()
1640 if (osb->slot_recovery_generations[slot_num] != slot_reco_gen) { in ocfs2_replay_journal()
1642 osb->slot_recovery_generations[slot_num], slot_reco_gen); in ocfs2_replay_journal()
1643 osb->slot_recovery_generations[slot_num] = slot_reco_gen; in ocfs2_replay_journal()
1667 osb->slot_recovery_generations[slot_num] = slot_reco_gen; in ocfs2_replay_journal()
1672 ocfs2_replay_map_set_state(osb, REPLAY_NEEDED); in ocfs2_replay_journal()
1675 "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev), in ocfs2_replay_journal()
1676 MINOR(osb->sb->s_dev)); in ocfs2_replay_journal()
1701 ocfs2_clear_journal_error(osb->sb, journal, slot_num); in ocfs2_replay_journal()
1717 osb->slot_recovery_generations[slot_num] = in ocfs2_replay_journal()
1720 ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check); in ocfs2_replay_journal()
1721 status = ocfs2_write_block(osb, bh, INODE_CACHE(inode)); in ocfs2_replay_journal()
1730 "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev), in ocfs2_replay_journal()
1731 MINOR(osb->sb->s_dev)); in ocfs2_replay_journal()
1755 static int ocfs2_recover_node(struct ocfs2_super *osb, in ocfs2_recover_node() argument
1762 trace_ocfs2_recover_node(node_num, slot_num, osb->node_num); in ocfs2_recover_node()
1766 BUG_ON(osb->node_num == node_num); in ocfs2_recover_node()
1768 status = ocfs2_replay_journal(osb, node_num, slot_num); in ocfs2_recover_node()
1780 status = ocfs2_begin_local_alloc_recovery(osb, slot_num, &la_copy); in ocfs2_recover_node()
1789 status = ocfs2_begin_truncate_log_recovery(osb, slot_num, &tl_copy); in ocfs2_recover_node()
1795 status = ocfs2_clear_slot(osb, slot_num); in ocfs2_recover_node()
1800 ocfs2_queue_recovery_completion(osb->journal, slot_num, la_copy, in ocfs2_recover_node()
1812 static int ocfs2_trylock_journal(struct ocfs2_super *osb, in ocfs2_trylock_journal() argument
1818 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_trylock_journal()
1851 int ocfs2_mark_dead_nodes(struct ocfs2_super *osb) in ocfs2_mark_dead_nodes() argument
1862 for (i = 0; i < osb->max_slots; i++) { in ocfs2_mark_dead_nodes()
1864 status = ocfs2_read_journal_inode(osb, i, &bh, NULL); in ocfs2_mark_dead_nodes()
1874 spin_lock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1875 osb->slot_recovery_generations[i] = gen; in ocfs2_mark_dead_nodes()
1878 osb->slot_recovery_generations[i]); in ocfs2_mark_dead_nodes()
1880 if (i == osb->slot_num) { in ocfs2_mark_dead_nodes()
1881 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1885 status = ocfs2_slot_to_node_num_locked(osb, i, &node_num); in ocfs2_mark_dead_nodes()
1887 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1891 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_mark_dead_nodes()
1892 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1895 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1900 status = ocfs2_trylock_journal(osb, i); in ocfs2_mark_dead_nodes()
1905 ocfs2_recovery_thread(osb, node_num); in ocfs2_mark_dead_nodes()
1958 static void ocfs2_queue_orphan_scan(struct ocfs2_super *osb) in ocfs2_queue_orphan_scan() argument
1964 os = &osb->osb_orphan_scan; in ocfs2_queue_orphan_scan()
1972 status = ocfs2_orphan_scan_lock(osb, &seqno); in ocfs2_queue_orphan_scan()
1988 for (i = 0; i < osb->max_slots; i++) in ocfs2_queue_orphan_scan()
1989 ocfs2_queue_recovery_completion(osb->journal, i, NULL, NULL, in ocfs2_queue_orphan_scan()
1999 ocfs2_orphan_scan_unlock(osb, seqno); in ocfs2_queue_orphan_scan()
2010 struct ocfs2_super *osb; in ocfs2_orphan_scan_work() local
2014 osb = os->os_osb; in ocfs2_orphan_scan_work()
2017 ocfs2_queue_orphan_scan(osb); in ocfs2_orphan_scan_work()
2019 queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work, in ocfs2_orphan_scan_work()
2024 void ocfs2_orphan_scan_stop(struct ocfs2_super *osb) in ocfs2_orphan_scan_stop() argument
2028 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_stop()
2037 void ocfs2_orphan_scan_init(struct ocfs2_super *osb) in ocfs2_orphan_scan_init() argument
2041 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_init()
2042 os->os_osb = osb; in ocfs2_orphan_scan_init()
2049 void ocfs2_orphan_scan_start(struct ocfs2_super *osb) in ocfs2_orphan_scan_start() argument
2053 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_start()
2055 if (ocfs2_is_hard_readonly(osb) || ocfs2_mount_local(osb)) in ocfs2_orphan_scan_start()
2059 queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work, in ocfs2_orphan_scan_start()
2067 struct ocfs2_super *osb; member
2091 iter = ocfs2_iget(p->osb, ino, in ocfs2_orphan_filldir()
2116 static int ocfs2_queue_orphans(struct ocfs2_super *osb, in ocfs2_queue_orphans() argument
2125 .osb = osb, in ocfs2_queue_orphans()
2130 orphan_dir_inode = ocfs2_get_system_file_inode(osb, in ocfs2_queue_orphans()
2162 static int ocfs2_orphan_recovery_can_continue(struct ocfs2_super *osb, in ocfs2_orphan_recovery_can_continue() argument
2167 spin_lock(&osb->osb_lock); in ocfs2_orphan_recovery_can_continue()
2168 ret = !osb->osb_orphan_wipes[slot]; in ocfs2_orphan_recovery_can_continue()
2169 spin_unlock(&osb->osb_lock); in ocfs2_orphan_recovery_can_continue()
2173 static void ocfs2_mark_recovering_orphan_dir(struct ocfs2_super *osb, in ocfs2_mark_recovering_orphan_dir() argument
2176 spin_lock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2179 ocfs2_node_map_set_bit(osb, &osb->osb_recovering_orphan_dirs, slot); in ocfs2_mark_recovering_orphan_dir()
2180 while (osb->osb_orphan_wipes[slot]) { in ocfs2_mark_recovering_orphan_dir()
2184 spin_unlock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2185 wait_event_interruptible(osb->osb_wipe_event, in ocfs2_mark_recovering_orphan_dir()
2186 ocfs2_orphan_recovery_can_continue(osb, slot)); in ocfs2_mark_recovering_orphan_dir()
2187 spin_lock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2189 spin_unlock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2192 static void ocfs2_clear_recovering_orphan_dir(struct ocfs2_super *osb, in ocfs2_clear_recovering_orphan_dir() argument
2195 ocfs2_node_map_clear_bit(osb, &osb->osb_recovering_orphan_dirs, slot); in ocfs2_clear_recovering_orphan_dir()
2216 static int ocfs2_recover_orphans(struct ocfs2_super *osb, in ocfs2_recover_orphans() argument
2229 ocfs2_mark_recovering_orphan_dir(osb, slot); in ocfs2_recover_orphans()
2230 ret = ocfs2_queue_orphans(osb, slot, &inode, orphan_reco_type); in ocfs2_recover_orphans()
2231 ocfs2_clear_recovering_orphan_dir(osb, slot); in ocfs2_recover_orphans()
2274 ret = ocfs2_del_inode_from_orphan(osb, inode, in ocfs2_recover_orphans()
2305 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota) in __ocfs2_wait_on_mount() argument
2310 wait_event(osb->osb_mount_event, in __ocfs2_wait_on_mount()
2311 (!quota && atomic_read(&osb->vol_state) == VOLUME_MOUNTED) || in __ocfs2_wait_on_mount()
2312 atomic_read(&osb->vol_state) == VOLUME_MOUNTED_QUOTAS || in __ocfs2_wait_on_mount()
2313 atomic_read(&osb->vol_state) == VOLUME_DISABLED); in __ocfs2_wait_on_mount()
2318 if (atomic_read(&osb->vol_state) == VOLUME_DISABLED) { in __ocfs2_wait_on_mount()
2330 struct ocfs2_super *osb = arg; in ocfs2_commit_thread() local
2331 struct ocfs2_journal *journal = osb->journal; in ocfs2_commit_thread()
2340 wait_event_interruptible(osb->checkpoint_event, in ocfs2_commit_thread()
2344 status = ocfs2_commit_cache(osb); in ocfs2_commit_thread()
2376 int ocfs2_check_journals_nolocks(struct ocfs2_super *osb) in ocfs2_check_journals_nolocks() argument
2384 for(slot = 0; slot < osb->max_slots; slot++) { in ocfs2_check_journals_nolocks()
2385 ret = ocfs2_read_journal_inode(osb, slot, &di_bh, NULL); in ocfs2_check_journals_nolocks()
2393 osb->slot_recovery_generations[slot] = in ocfs2_check_journals_nolocks()