Lines Matching refs:osb
64 static int ocfs2_recover_node(struct ocfs2_super *osb,
67 static int ocfs2_commit_cache(struct ocfs2_super *osb);
68 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota);
69 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,
71 static int ocfs2_trylock_journal(struct ocfs2_super *osb,
73 static int ocfs2_recover_orphans(struct ocfs2_super *osb,
84 static inline int ocfs2_wait_on_mount(struct ocfs2_super *osb) in ocfs2_wait_on_mount() argument
86 return __ocfs2_wait_on_mount(osb, 0); in ocfs2_wait_on_mount()
89 static inline int ocfs2_wait_on_quotas(struct ocfs2_super *osb) in ocfs2_wait_on_quotas() argument
91 return __ocfs2_wait_on_mount(osb, 1); in ocfs2_wait_on_quotas()
111 void ocfs2_replay_map_set_state(struct ocfs2_super *osb, int state) in ocfs2_replay_map_set_state() argument
113 if (!osb->replay_map) in ocfs2_replay_map_set_state()
117 if (osb->replay_map->rm_state == REPLAY_DONE) in ocfs2_replay_map_set_state()
120 osb->replay_map->rm_state = state; in ocfs2_replay_map_set_state()
123 int ocfs2_compute_replay_slots(struct ocfs2_super *osb) in ocfs2_compute_replay_slots() argument
129 if (osb->replay_map) in ocfs2_compute_replay_slots()
133 (osb->max_slots * sizeof(char)), GFP_KERNEL); in ocfs2_compute_replay_slots()
140 spin_lock(&osb->osb_lock); in ocfs2_compute_replay_slots()
142 replay_map->rm_slots = osb->max_slots; in ocfs2_compute_replay_slots()
147 if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT) in ocfs2_compute_replay_slots()
151 osb->replay_map = replay_map; in ocfs2_compute_replay_slots()
152 spin_unlock(&osb->osb_lock); in ocfs2_compute_replay_slots()
156 void ocfs2_queue_replay_slots(struct ocfs2_super *osb, in ocfs2_queue_replay_slots() argument
159 struct ocfs2_replay_map *replay_map = osb->replay_map; in ocfs2_queue_replay_slots()
170 ocfs2_queue_recovery_completion(osb->journal, i, NULL, in ocfs2_queue_replay_slots()
176 void ocfs2_free_replay_slots(struct ocfs2_super *osb) in ocfs2_free_replay_slots() argument
178 struct ocfs2_replay_map *replay_map = osb->replay_map; in ocfs2_free_replay_slots()
180 if (!osb->replay_map) in ocfs2_free_replay_slots()
184 osb->replay_map = NULL; in ocfs2_free_replay_slots()
187 int ocfs2_recovery_init(struct ocfs2_super *osb) in ocfs2_recovery_init() argument
191 mutex_init(&osb->recovery_lock); in ocfs2_recovery_init()
192 osb->disable_recovery = 0; in ocfs2_recovery_init()
193 osb->recovery_thread_task = NULL; in ocfs2_recovery_init()
194 init_waitqueue_head(&osb->recovery_event); in ocfs2_recovery_init()
197 osb->max_slots * sizeof(unsigned int), in ocfs2_recovery_init()
206 osb->recovery_map = rm; in ocfs2_recovery_init()
214 static int ocfs2_recovery_thread_running(struct ocfs2_super *osb) in ocfs2_recovery_thread_running() argument
217 return osb->recovery_thread_task != NULL; in ocfs2_recovery_thread_running()
220 void ocfs2_recovery_exit(struct ocfs2_super *osb) in ocfs2_recovery_exit() argument
226 mutex_lock(&osb->recovery_lock); in ocfs2_recovery_exit()
227 osb->disable_recovery = 1; in ocfs2_recovery_exit()
228 mutex_unlock(&osb->recovery_lock); in ocfs2_recovery_exit()
229 wait_event(osb->recovery_event, !ocfs2_recovery_thread_running(osb)); in ocfs2_recovery_exit()
240 rm = osb->recovery_map; in ocfs2_recovery_exit()
246 static int __ocfs2_recovery_map_test(struct ocfs2_super *osb, in __ocfs2_recovery_map_test() argument
250 struct ocfs2_recovery_map *rm = osb->recovery_map; in __ocfs2_recovery_map_test()
252 assert_spin_locked(&osb->osb_lock); in __ocfs2_recovery_map_test()
263 static int ocfs2_recovery_map_set(struct ocfs2_super *osb, in ocfs2_recovery_map_set() argument
266 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_map_set()
268 spin_lock(&osb->osb_lock); in ocfs2_recovery_map_set()
269 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_recovery_map_set()
270 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_set()
275 BUG_ON(rm->rm_used >= osb->max_slots); in ocfs2_recovery_map_set()
279 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_set()
284 static void ocfs2_recovery_map_clear(struct ocfs2_super *osb, in ocfs2_recovery_map_clear() argument
288 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_map_clear()
290 spin_lock(&osb->osb_lock); in ocfs2_recovery_map_clear()
304 spin_unlock(&osb->osb_lock); in ocfs2_recovery_map_clear()
307 static int ocfs2_commit_cache(struct ocfs2_super *osb) in ocfs2_commit_cache() argument
313 journal = osb->journal; in ocfs2_commit_cache()
342 ocfs2_wake_downconvert_thread(osb); in ocfs2_commit_cache()
348 handle_t *ocfs2_start_trans(struct ocfs2_super *osb, int max_buffs) in ocfs2_start_trans() argument
350 journal_t *journal = osb->journal->j_journal; in ocfs2_start_trans()
353 BUG_ON(!osb || !osb->journal->j_journal); in ocfs2_start_trans()
355 if (ocfs2_is_hard_readonly(osb)) in ocfs2_start_trans()
358 BUG_ON(osb->journal->j_state == OCFS2_JOURNAL_FREE); in ocfs2_start_trans()
365 sb_start_intwrite(osb->sb); in ocfs2_start_trans()
367 down_read(&osb->journal->j_trans_barrier); in ocfs2_start_trans()
371 up_read(&osb->journal->j_trans_barrier); in ocfs2_start_trans()
372 sb_end_intwrite(osb->sb); in ocfs2_start_trans()
377 ocfs2_abort(osb->sb, "Detected aborted journal"); in ocfs2_start_trans()
381 if (!ocfs2_mount_local(osb)) in ocfs2_start_trans()
382 atomic_inc(&(osb->journal->j_num_trans)); in ocfs2_start_trans()
388 int ocfs2_commit_trans(struct ocfs2_super *osb, in ocfs2_commit_trans() argument
392 struct ocfs2_journal *journal = osb->journal; in ocfs2_commit_trans()
403 sb_end_intwrite(osb->sb); in ocfs2_commit_trans()
657 struct ocfs2_super *osb = in __ocfs2_journal_access() local
682 ocfs2_set_ci_lock_trans(osb->journal, ci); in __ocfs2_journal_access()
699 if (!status && ocfs2_meta_ecc(osb) && triggers) in __ocfs2_journal_access()
783 void ocfs2_set_journal_params(struct ocfs2_super *osb) in ocfs2_set_journal_params() argument
785 journal_t *journal = osb->journal->j_journal; in ocfs2_set_journal_params()
788 if (osb->osb_commit_interval) in ocfs2_set_journal_params()
789 commit_interval = osb->osb_commit_interval; in ocfs2_set_journal_params()
793 if (osb->s_mount_opt & OCFS2_MOUNT_BARRIER) in ocfs2_set_journal_params()
807 struct ocfs2_super *osb; in ocfs2_journal_init() local
812 osb = journal->j_osb; in ocfs2_journal_init()
815 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_journal_init()
816 osb->slot_num); in ocfs2_journal_init()
874 ocfs2_set_journal_params(osb); in ocfs2_journal_init()
903 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb, in ocfs2_journal_toggle_dirty() argument
908 struct ocfs2_journal *journal = osb->journal; in ocfs2_journal_toggle_dirty()
929 ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check); in ocfs2_journal_toggle_dirty()
930 status = ocfs2_write_block(osb, bh, INODE_CACHE(journal->j_inode)); in ocfs2_journal_toggle_dirty()
941 void ocfs2_journal_shutdown(struct ocfs2_super *osb) in ocfs2_journal_shutdown() argument
948 BUG_ON(!osb); in ocfs2_journal_shutdown()
950 journal = osb->journal; in ocfs2_journal_shutdown()
963 num_running_trans = atomic_read(&(osb->journal->j_num_trans)); in ocfs2_journal_shutdown()
975 if (osb->commit_task) { in ocfs2_journal_shutdown()
977 trace_ocfs2_journal_shutdown_wait(osb->commit_task); in ocfs2_journal_shutdown()
978 kthread_stop(osb->commit_task); in ocfs2_journal_shutdown()
979 osb->commit_task = NULL; in ocfs2_journal_shutdown()
982 BUG_ON(atomic_read(&(osb->journal->j_num_trans)) != 0); in ocfs2_journal_shutdown()
984 if (ocfs2_mount_local(osb)) { in ocfs2_journal_shutdown()
997 status = ocfs2_journal_toggle_dirty(osb, 0, 0); in ocfs2_journal_shutdown()
1043 struct ocfs2_super *osb; in ocfs2_journal_load() local
1047 osb = journal->j_osb; in ocfs2_journal_load()
1055 ocfs2_clear_journal_error(osb->sb, journal->j_journal, osb->slot_num); in ocfs2_journal_load()
1057 status = ocfs2_journal_toggle_dirty(osb, 1, replayed); in ocfs2_journal_load()
1065 osb->commit_task = kthread_run(ocfs2_commit_thread, osb, in ocfs2_journal_load()
1067 if (IS_ERR(osb->commit_task)) { in ocfs2_journal_load()
1068 status = PTR_ERR(osb->commit_task); in ocfs2_journal_load()
1069 osb->commit_task = NULL; in ocfs2_journal_load()
1075 osb->commit_task = NULL; in ocfs2_journal_load()
1104 static int ocfs2_recovery_completed(struct ocfs2_super *osb) in ocfs2_recovery_completed() argument
1107 struct ocfs2_recovery_map *rm = osb->recovery_map; in ocfs2_recovery_completed()
1109 spin_lock(&osb->osb_lock); in ocfs2_recovery_completed()
1111 spin_unlock(&osb->osb_lock); in ocfs2_recovery_completed()
1116 void ocfs2_wait_for_recovery(struct ocfs2_super *osb) in ocfs2_wait_for_recovery() argument
1118 wait_event(osb->recovery_event, ocfs2_recovery_completed(osb)); in ocfs2_wait_for_recovery()
1201 struct ocfs2_super *osb = journal->j_osb; in ocfs2_complete_recovery() local
1218 ocfs2_wait_on_quotas(osb); in ocfs2_complete_recovery()
1231 ret = ocfs2_complete_local_alloc_recovery(osb, in ocfs2_complete_recovery()
1240 ret = ocfs2_complete_truncate_log_recovery(osb, in ocfs2_complete_recovery()
1248 ret = ocfs2_recover_orphans(osb, item->lri_slot, in ocfs2_complete_recovery()
1254 ret = ocfs2_finish_quota_recovery(osb, qrec, in ocfs2_complete_recovery()
1309 void ocfs2_complete_mount_recovery(struct ocfs2_super *osb) in ocfs2_complete_mount_recovery() argument
1311 struct ocfs2_journal *journal = osb->journal; in ocfs2_complete_mount_recovery()
1313 if (ocfs2_is_hard_readonly(osb)) in ocfs2_complete_mount_recovery()
1318 ocfs2_queue_recovery_completion(journal, osb->slot_num, in ocfs2_complete_mount_recovery()
1319 osb->local_alloc_copy, NULL, NULL, in ocfs2_complete_mount_recovery()
1321 ocfs2_schedule_truncate_log_flush(osb, 0); in ocfs2_complete_mount_recovery()
1323 osb->local_alloc_copy = NULL; in ocfs2_complete_mount_recovery()
1324 osb->dirty = 0; in ocfs2_complete_mount_recovery()
1327 ocfs2_replay_map_set_state(osb, REPLAY_NEEDED); in ocfs2_complete_mount_recovery()
1328 ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE); in ocfs2_complete_mount_recovery()
1329 ocfs2_free_replay_slots(osb); in ocfs2_complete_mount_recovery()
1332 void ocfs2_complete_quota_recovery(struct ocfs2_super *osb) in ocfs2_complete_quota_recovery() argument
1334 if (osb->quota_rec) { in ocfs2_complete_quota_recovery()
1335 ocfs2_queue_recovery_completion(osb->journal, in ocfs2_complete_quota_recovery()
1336 osb->slot_num, in ocfs2_complete_quota_recovery()
1339 osb->quota_rec, in ocfs2_complete_quota_recovery()
1341 osb->quota_rec = NULL; in ocfs2_complete_quota_recovery()
1348 struct ocfs2_super *osb = arg; in __ocfs2_recovery_thread() local
1349 struct ocfs2_recovery_map *rm = osb->recovery_map; in __ocfs2_recovery_thread()
1354 status = ocfs2_wait_on_mount(osb); in __ocfs2_recovery_thread()
1359 rm_quota = kzalloc(osb->max_slots * sizeof(int), GFP_NOFS); in __ocfs2_recovery_thread()
1365 status = ocfs2_super_lock(osb, 1); in __ocfs2_recovery_thread()
1371 status = ocfs2_compute_replay_slots(osb); in __ocfs2_recovery_thread()
1376 ocfs2_queue_recovery_completion(osb->journal, osb->slot_num, NULL, in __ocfs2_recovery_thread()
1379 spin_lock(&osb->osb_lock); in __ocfs2_recovery_thread()
1384 spin_unlock(&osb->osb_lock); in __ocfs2_recovery_thread()
1385 slot_num = ocfs2_node_num_to_slot(osb, node_num); in __ocfs2_recovery_thread()
1402 status = ocfs2_recover_node(osb, node_num, slot_num); in __ocfs2_recovery_thread()
1405 ocfs2_recovery_map_clear(osb, node_num); in __ocfs2_recovery_thread()
1410 MAJOR(osb->sb->s_dev), MINOR(osb->sb->s_dev)); in __ocfs2_recovery_thread()
1414 spin_lock(&osb->osb_lock); in __ocfs2_recovery_thread()
1416 spin_unlock(&osb->osb_lock); in __ocfs2_recovery_thread()
1420 status = ocfs2_check_journals_nolocks(osb); in __ocfs2_recovery_thread()
1429 qrec = ocfs2_begin_quota_recovery(osb, rm_quota[i]); in __ocfs2_recovery_thread()
1435 ocfs2_queue_recovery_completion(osb->journal, rm_quota[i], in __ocfs2_recovery_thread()
1440 ocfs2_super_unlock(osb, 1); in __ocfs2_recovery_thread()
1443 ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE); in __ocfs2_recovery_thread()
1446 mutex_lock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1447 if (!status && !ocfs2_recovery_completed(osb)) { in __ocfs2_recovery_thread()
1448 mutex_unlock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1452 ocfs2_free_replay_slots(osb); in __ocfs2_recovery_thread()
1453 osb->recovery_thread_task = NULL; in __ocfs2_recovery_thread()
1455 wake_up(&osb->recovery_event); in __ocfs2_recovery_thread()
1457 mutex_unlock(&osb->recovery_lock); in __ocfs2_recovery_thread()
1467 void ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num) in ocfs2_recovery_thread() argument
1469 mutex_lock(&osb->recovery_lock); in ocfs2_recovery_thread()
1471 trace_ocfs2_recovery_thread(node_num, osb->node_num, in ocfs2_recovery_thread()
1472 osb->disable_recovery, osb->recovery_thread_task, in ocfs2_recovery_thread()
1473 osb->disable_recovery ? in ocfs2_recovery_thread()
1474 -1 : ocfs2_recovery_map_set(osb, node_num)); in ocfs2_recovery_thread()
1476 if (osb->disable_recovery) in ocfs2_recovery_thread()
1479 if (osb->recovery_thread_task) in ocfs2_recovery_thread()
1482 osb->recovery_thread_task = kthread_run(__ocfs2_recovery_thread, osb, in ocfs2_recovery_thread()
1484 if (IS_ERR(osb->recovery_thread_task)) { in ocfs2_recovery_thread()
1485 mlog_errno((int)PTR_ERR(osb->recovery_thread_task)); in ocfs2_recovery_thread()
1486 osb->recovery_thread_task = NULL; in ocfs2_recovery_thread()
1490 mutex_unlock(&osb->recovery_lock); in ocfs2_recovery_thread()
1491 wake_up(&osb->recovery_event); in ocfs2_recovery_thread()
1494 static int ocfs2_read_journal_inode(struct ocfs2_super *osb, in ocfs2_read_journal_inode() argument
1502 BUG_ON(slot_num >= osb->max_slots); in ocfs2_read_journal_inode()
1504 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_read_journal_inode()
1532 static int ocfs2_replay_journal(struct ocfs2_super *osb, in ocfs2_replay_journal() argument
1545 status = ocfs2_read_journal_inode(osb, slot_num, &bh, &inode); in ocfs2_replay_journal()
1564 if (osb->slot_recovery_generations[slot_num] != slot_reco_gen) { in ocfs2_replay_journal()
1566 osb->slot_recovery_generations[slot_num], slot_reco_gen); in ocfs2_replay_journal()
1567 osb->slot_recovery_generations[slot_num] = slot_reco_gen; in ocfs2_replay_journal()
1591 osb->slot_recovery_generations[slot_num] = slot_reco_gen; in ocfs2_replay_journal()
1596 ocfs2_replay_map_set_state(osb, REPLAY_NEEDED); in ocfs2_replay_journal()
1599 "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev), in ocfs2_replay_journal()
1600 MINOR(osb->sb->s_dev)); in ocfs2_replay_journal()
1626 ocfs2_clear_journal_error(osb->sb, journal, slot_num); in ocfs2_replay_journal()
1642 osb->slot_recovery_generations[slot_num] = in ocfs2_replay_journal()
1645 ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check); in ocfs2_replay_journal()
1646 status = ocfs2_write_block(osb, bh, INODE_CACHE(inode)); in ocfs2_replay_journal()
1656 "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev), in ocfs2_replay_journal()
1657 MINOR(osb->sb->s_dev)); in ocfs2_replay_journal()
1683 static int ocfs2_recover_node(struct ocfs2_super *osb, in ocfs2_recover_node() argument
1690 trace_ocfs2_recover_node(node_num, slot_num, osb->node_num); in ocfs2_recover_node()
1694 BUG_ON(osb->node_num == node_num); in ocfs2_recover_node()
1696 status = ocfs2_replay_journal(osb, node_num, slot_num); in ocfs2_recover_node()
1708 status = ocfs2_begin_local_alloc_recovery(osb, slot_num, &la_copy); in ocfs2_recover_node()
1717 status = ocfs2_begin_truncate_log_recovery(osb, slot_num, &tl_copy); in ocfs2_recover_node()
1723 status = ocfs2_clear_slot(osb, slot_num); in ocfs2_recover_node()
1728 ocfs2_queue_recovery_completion(osb->journal, slot_num, la_copy, in ocfs2_recover_node()
1740 static int ocfs2_trylock_journal(struct ocfs2_super *osb, in ocfs2_trylock_journal() argument
1746 inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE, in ocfs2_trylock_journal()
1780 int ocfs2_mark_dead_nodes(struct ocfs2_super *osb) in ocfs2_mark_dead_nodes() argument
1791 for (i = 0; i < osb->max_slots; i++) { in ocfs2_mark_dead_nodes()
1793 status = ocfs2_read_journal_inode(osb, i, &bh, NULL); in ocfs2_mark_dead_nodes()
1803 spin_lock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1804 osb->slot_recovery_generations[i] = gen; in ocfs2_mark_dead_nodes()
1807 osb->slot_recovery_generations[i]); in ocfs2_mark_dead_nodes()
1809 if (i == osb->slot_num) { in ocfs2_mark_dead_nodes()
1810 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1814 status = ocfs2_slot_to_node_num_locked(osb, i, &node_num); in ocfs2_mark_dead_nodes()
1816 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1820 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_mark_dead_nodes()
1821 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1824 spin_unlock(&osb->osb_lock); in ocfs2_mark_dead_nodes()
1829 status = ocfs2_trylock_journal(osb, i); in ocfs2_mark_dead_nodes()
1834 ocfs2_recovery_thread(osb, node_num); in ocfs2_mark_dead_nodes()
1887 void ocfs2_queue_orphan_scan(struct ocfs2_super *osb) in ocfs2_queue_orphan_scan() argument
1893 os = &osb->osb_orphan_scan; in ocfs2_queue_orphan_scan()
1901 status = ocfs2_orphan_scan_lock(osb, &seqno); in ocfs2_queue_orphan_scan()
1917 for (i = 0; i < osb->max_slots; i++) in ocfs2_queue_orphan_scan()
1918 ocfs2_queue_recovery_completion(osb->journal, i, NULL, NULL, in ocfs2_queue_orphan_scan()
1928 ocfs2_orphan_scan_unlock(osb, seqno); in ocfs2_queue_orphan_scan()
1939 struct ocfs2_super *osb; in ocfs2_orphan_scan_work() local
1943 osb = os->os_osb; in ocfs2_orphan_scan_work()
1946 ocfs2_queue_orphan_scan(osb); in ocfs2_orphan_scan_work()
1953 void ocfs2_orphan_scan_stop(struct ocfs2_super *osb) in ocfs2_orphan_scan_stop() argument
1957 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_stop()
1966 void ocfs2_orphan_scan_init(struct ocfs2_super *osb) in ocfs2_orphan_scan_init() argument
1970 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_init()
1971 os->os_osb = osb; in ocfs2_orphan_scan_init()
1978 void ocfs2_orphan_scan_start(struct ocfs2_super *osb) in ocfs2_orphan_scan_start() argument
1982 os = &osb->osb_orphan_scan; in ocfs2_orphan_scan_start()
1984 if (ocfs2_is_hard_readonly(osb) || ocfs2_mount_local(osb)) in ocfs2_orphan_scan_start()
1996 struct ocfs2_super *osb; member
2013 iter = ocfs2_iget(p->osb, ino, in ocfs2_orphan_filldir()
2034 static int ocfs2_queue_orphans(struct ocfs2_super *osb, in ocfs2_queue_orphans() argument
2042 .osb = osb, in ocfs2_queue_orphans()
2046 orphan_dir_inode = ocfs2_get_system_file_inode(osb, in ocfs2_queue_orphans()
2078 static int ocfs2_orphan_recovery_can_continue(struct ocfs2_super *osb, in ocfs2_orphan_recovery_can_continue() argument
2083 spin_lock(&osb->osb_lock); in ocfs2_orphan_recovery_can_continue()
2084 ret = !osb->osb_orphan_wipes[slot]; in ocfs2_orphan_recovery_can_continue()
2085 spin_unlock(&osb->osb_lock); in ocfs2_orphan_recovery_can_continue()
2089 static void ocfs2_mark_recovering_orphan_dir(struct ocfs2_super *osb, in ocfs2_mark_recovering_orphan_dir() argument
2092 spin_lock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2095 ocfs2_node_map_set_bit(osb, &osb->osb_recovering_orphan_dirs, slot); in ocfs2_mark_recovering_orphan_dir()
2096 while (osb->osb_orphan_wipes[slot]) { in ocfs2_mark_recovering_orphan_dir()
2100 spin_unlock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2101 wait_event_interruptible(osb->osb_wipe_event, in ocfs2_mark_recovering_orphan_dir()
2102 ocfs2_orphan_recovery_can_continue(osb, slot)); in ocfs2_mark_recovering_orphan_dir()
2103 spin_lock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2105 spin_unlock(&osb->osb_lock); in ocfs2_mark_recovering_orphan_dir()
2108 static void ocfs2_clear_recovering_orphan_dir(struct ocfs2_super *osb, in ocfs2_clear_recovering_orphan_dir() argument
2111 ocfs2_node_map_clear_bit(osb, &osb->osb_recovering_orphan_dirs, slot); in ocfs2_clear_recovering_orphan_dir()
2132 static int ocfs2_recover_orphans(struct ocfs2_super *osb, in ocfs2_recover_orphans() argument
2143 ocfs2_mark_recovering_orphan_dir(osb, slot); in ocfs2_recover_orphans()
2144 ret = ocfs2_queue_orphans(osb, slot, &inode); in ocfs2_recover_orphans()
2145 ocfs2_clear_recovering_orphan_dir(osb, slot); in ocfs2_recover_orphans()
2204 ret = ocfs2_del_inode_from_orphan(osb, inode, 0, 0); in ocfs2_recover_orphans()
2220 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota) in __ocfs2_wait_on_mount() argument
2225 wait_event(osb->osb_mount_event, in __ocfs2_wait_on_mount()
2226 (!quota && atomic_read(&osb->vol_state) == VOLUME_MOUNTED) || in __ocfs2_wait_on_mount()
2227 atomic_read(&osb->vol_state) == VOLUME_MOUNTED_QUOTAS || in __ocfs2_wait_on_mount()
2228 atomic_read(&osb->vol_state) == VOLUME_DISABLED); in __ocfs2_wait_on_mount()
2233 if (atomic_read(&osb->vol_state) == VOLUME_DISABLED) { in __ocfs2_wait_on_mount()
2245 struct ocfs2_super *osb = arg; in ocfs2_commit_thread() local
2246 struct ocfs2_journal *journal = osb->journal; in ocfs2_commit_thread()
2255 wait_event_interruptible(osb->checkpoint_event, in ocfs2_commit_thread()
2259 status = ocfs2_commit_cache(osb); in ocfs2_commit_thread()
2291 int ocfs2_check_journals_nolocks(struct ocfs2_super *osb) in ocfs2_check_journals_nolocks() argument
2299 for(slot = 0; slot < osb->max_slots; slot++) { in ocfs2_check_journals_nolocks()
2300 ret = ocfs2_read_journal_inode(osb, slot, &di_bh, NULL); in ocfs2_check_journals_nolocks()
2308 osb->slot_recovery_generations[slot] = in ocfs2_check_journals_nolocks()