48 static int ocfs2_recover_node(struct ocfs2_super *osb,
51 static int ocfs2_commit_cache(struct ocfs2_super *osb);
52 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota);
53 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,
55 static int ocfs2_trylock_journal(struct ocfs2_super *osb,
57 static int ocfs2_recover_orphans(struct ocfs2_super *osb,
68 static inline int ocfs2_wait_on_mount(struct ocfs2_super *osb)  in ocfs2_wait_on_mount()  argument
70 	return __ocfs2_wait_on_mount(osb, 0);  in ocfs2_wait_on_mount()
73 static inline int ocfs2_wait_on_quotas(struct ocfs2_super *osb)  in ocfs2_wait_on_quotas()  argument
75 	return __ocfs2_wait_on_mount(osb, 1);  in ocfs2_wait_on_quotas()
95 static void ocfs2_replay_map_set_state(struct ocfs2_super *osb, int state)  in ocfs2_replay_map_set_state()  argument
97 	if (!osb->replay_map)  in ocfs2_replay_map_set_state()
101 	if (osb->replay_map->rm_state == REPLAY_DONE)  in ocfs2_replay_map_set_state()
104 	osb->replay_map->rm_state = state;  in ocfs2_replay_map_set_state()
107 int ocfs2_compute_replay_slots(struct ocfs2_super *osb)  in ocfs2_compute_replay_slots()  argument
113 	if (osb->replay_map)  in ocfs2_compute_replay_slots()
117 			     (osb->max_slots * sizeof(char)), GFP_KERNEL);  in ocfs2_compute_replay_slots()
124 	spin_lock(&osb->osb_lock);  in ocfs2_compute_replay_slots()
126 	replay_map->rm_slots = osb->max_slots;  in ocfs2_compute_replay_slots()
131 		if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT)  in ocfs2_compute_replay_slots()
135 	osb->replay_map = replay_map;  in ocfs2_compute_replay_slots()
136 	spin_unlock(&osb->osb_lock);  in ocfs2_compute_replay_slots()
140 static void ocfs2_queue_replay_slots(struct ocfs2_super *osb,  in ocfs2_queue_replay_slots()  argument
143 	struct ocfs2_replay_map *replay_map = osb->replay_map;  in ocfs2_queue_replay_slots()
154 			ocfs2_queue_recovery_completion(osb->journal, i, NULL,  in ocfs2_queue_replay_slots()
160 static void ocfs2_free_replay_slots(struct ocfs2_super *osb)  in ocfs2_free_replay_slots()  argument
162 	struct ocfs2_replay_map *replay_map = osb->replay_map;  in ocfs2_free_replay_slots()
164 	if (!osb->replay_map)  in ocfs2_free_replay_slots()
168 	osb->replay_map = NULL;  in ocfs2_free_replay_slots()
171 int ocfs2_recovery_init(struct ocfs2_super *osb)  in ocfs2_recovery_init()  argument
175 	mutex_init(&osb->recovery_lock);  in ocfs2_recovery_init()
176 	osb->disable_recovery = 0;  in ocfs2_recovery_init()
177 	osb->recovery_thread_task = NULL;  in ocfs2_recovery_init()
178 	init_waitqueue_head(&osb->recovery_event);  in ocfs2_recovery_init()
181 		     osb->max_slots * sizeof(unsigned int),  in ocfs2_recovery_init()
190 	osb->recovery_map = rm;  in ocfs2_recovery_init()
198 static int ocfs2_recovery_thread_running(struct ocfs2_super *osb)  in ocfs2_recovery_thread_running()  argument
201 	return osb->recovery_thread_task != NULL;  in ocfs2_recovery_thread_running()
204 void ocfs2_recovery_exit(struct ocfs2_super *osb)  in ocfs2_recovery_exit()  argument
210 	mutex_lock(&osb->recovery_lock);  in ocfs2_recovery_exit()
211 	osb->disable_recovery = 1;  in ocfs2_recovery_exit()
212 	mutex_unlock(&osb->recovery_lock);  in ocfs2_recovery_exit()
213 	wait_event(osb->recovery_event, !ocfs2_recovery_thread_running(osb));  in ocfs2_recovery_exit()
218 	if (osb->ocfs2_wq)  in ocfs2_recovery_exit()
219 		flush_workqueue(osb->ocfs2_wq);  in ocfs2_recovery_exit()
225 	rm = osb->recovery_map;  in ocfs2_recovery_exit()
231 static int __ocfs2_recovery_map_test(struct ocfs2_super *osb,  in __ocfs2_recovery_map_test()  argument
235 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in __ocfs2_recovery_map_test()
237 	assert_spin_locked(&osb->osb_lock);  in __ocfs2_recovery_map_test()
248 static int ocfs2_recovery_map_set(struct ocfs2_super *osb,  in ocfs2_recovery_map_set()  argument
251 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_map_set()
253 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_map_set()
254 	if (__ocfs2_recovery_map_test(osb, node_num)) {  in ocfs2_recovery_map_set()
255 		spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_set()
260 	BUG_ON(rm->rm_used >= osb->max_slots);  in ocfs2_recovery_map_set()
264 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_set()
269 static void ocfs2_recovery_map_clear(struct ocfs2_super *osb,  in ocfs2_recovery_map_clear()  argument
273 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_map_clear()
275 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_map_clear()
289 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_clear()
292 static int ocfs2_commit_cache(struct ocfs2_super *osb)  in ocfs2_commit_cache()  argument
298 	journal = osb->journal;  in ocfs2_commit_cache()
327 	ocfs2_wake_downconvert_thread(osb);  in ocfs2_commit_cache()
333 handle_t *ocfs2_start_trans(struct ocfs2_super *osb, int max_buffs)  in ocfs2_start_trans()  argument
335 	journal_t *journal = osb->journal->j_journal;  in ocfs2_start_trans()
338 	BUG_ON(!osb || !osb->journal->j_journal);  in ocfs2_start_trans()
340 	if (ocfs2_is_hard_readonly(osb))  in ocfs2_start_trans()
343 	BUG_ON(osb->journal->j_state == OCFS2_JOURNAL_FREE);  in ocfs2_start_trans()
350 	sb_start_intwrite(osb->sb);  in ocfs2_start_trans()
352 	down_read(&osb->journal->j_trans_barrier);  in ocfs2_start_trans()
356 		up_read(&osb->journal->j_trans_barrier);  in ocfs2_start_trans()
357 		sb_end_intwrite(osb->sb);  in ocfs2_start_trans()
362 			ocfs2_abort(osb->sb, "Detected aborted journal\n");  in ocfs2_start_trans()
366 		if (!ocfs2_mount_local(osb))  in ocfs2_start_trans()
367 			atomic_inc(&(osb->journal->j_num_trans));  in ocfs2_start_trans()
373 int ocfs2_commit_trans(struct ocfs2_super *osb,  in ocfs2_commit_trans()  argument
377 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_commit_trans()
388 		sb_end_intwrite(osb->sb);  in ocfs2_commit_trans()
640 	struct ocfs2_super *osb =  in __ocfs2_journal_access()  local
670 			return ocfs2_error(osb->sb, "A previous attempt to "  in __ocfs2_journal_access()
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()
796 void ocfs2_set_journal_params(struct ocfs2_super *osb)  in ocfs2_set_journal_params()  argument
798 	journal_t *journal = osb->journal->j_journal;  in ocfs2_set_journal_params()
801 	if (osb->osb_commit_interval)  in ocfs2_set_journal_params()
802 		commit_interval = osb->osb_commit_interval;  in ocfs2_set_journal_params()
806 	if (osb->s_mount_opt & OCFS2_MOUNT_BARRIER)  in ocfs2_set_journal_params()
817 int ocfs2_journal_alloc(struct ocfs2_super *osb)  in ocfs2_journal_alloc()  argument
828 	osb->journal = journal;  in ocfs2_journal_alloc()
829 	journal->j_osb = osb;  in ocfs2_journal_alloc()
844 int ocfs2_journal_init(struct ocfs2_super *osb, int *dirty)  in ocfs2_journal_init()  argument
849 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_journal_init()
856 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_journal_init()
857 					    osb->slot_num);  in ocfs2_journal_init()
919 	ocfs2_set_journal_params(osb);  in ocfs2_journal_init()
948 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,  in ocfs2_journal_toggle_dirty()  argument
953 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_journal_toggle_dirty()
974 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_journal_toggle_dirty()
975 	status = ocfs2_write_block(osb, bh, INODE_CACHE(journal->j_inode));  in ocfs2_journal_toggle_dirty()
986 void ocfs2_journal_shutdown(struct ocfs2_super *osb)  in ocfs2_journal_shutdown()  argument
993 	BUG_ON(!osb);  in ocfs2_journal_shutdown()
995 	journal = osb->journal;  in ocfs2_journal_shutdown()
1008 	num_running_trans = atomic_read(&(osb->journal->j_num_trans));  in ocfs2_journal_shutdown()
1020 	if (osb->commit_task) {  in ocfs2_journal_shutdown()
1022 		trace_ocfs2_journal_shutdown_wait(osb->commit_task);  in ocfs2_journal_shutdown()
1023 		kthread_stop(osb->commit_task);  in ocfs2_journal_shutdown()
1024 		osb->commit_task = NULL;  in ocfs2_journal_shutdown()
1027 	BUG_ON(atomic_read(&(osb->journal->j_num_trans)) != 0);  in ocfs2_journal_shutdown()
1029 	if (ocfs2_mount_local(osb)) {  in ocfs2_journal_shutdown()
1043 		status = ocfs2_journal_toggle_dirty(osb, 0, 0);  in ocfs2_journal_shutdown()
1062 	osb->journal = NULL;  in ocfs2_journal_shutdown()
1086 	struct ocfs2_super *osb;  in ocfs2_journal_load()  local
1090 	osb = journal->j_osb;  in ocfs2_journal_load()
1098 	ocfs2_clear_journal_error(osb->sb, journal->j_journal, osb->slot_num);  in ocfs2_journal_load()
1108 	status = ocfs2_journal_toggle_dirty(osb, 1, replayed);  in ocfs2_journal_load()
1116 		osb->commit_task = kthread_run(ocfs2_commit_thread, osb,  in ocfs2_journal_load()
1117 				"ocfs2cmt-%s", osb->uuid_str);  in ocfs2_journal_load()
1118 		if (IS_ERR(osb->commit_task)) {  in ocfs2_journal_load()
1119 			status = PTR_ERR(osb->commit_task);  in ocfs2_journal_load()
1120 			osb->commit_task = NULL;  in ocfs2_journal_load()
1126 		osb->commit_task = NULL;  in ocfs2_journal_load()
1155 static int ocfs2_recovery_completed(struct ocfs2_super *osb)  in ocfs2_recovery_completed()  argument
1158 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_completed()
1160 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_completed()
1162 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_completed()
1167 void ocfs2_wait_for_recovery(struct ocfs2_super *osb)  in ocfs2_wait_for_recovery()  argument
1169 	wait_event(osb->recovery_event, ocfs2_recovery_completed(osb));  in ocfs2_wait_for_recovery()
1188 	struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);  in ocfs2_force_read_journal()  local
1201 			bh = __find_get_block(osb->sb->s_bdev, p_blkno,  in ocfs2_force_read_journal()
1202 					osb->sb->s_blocksize);  in ocfs2_force_read_journal()
1212 			status = ocfs2_read_blocks_sync(osb, p_blkno, 1, &bh);  in ocfs2_force_read_journal()
1253 	struct ocfs2_super *osb = journal->j_osb;  in ocfs2_complete_recovery()  local
1270 		ocfs2_wait_on_quotas(osb);  in ocfs2_complete_recovery()
1283 			ret = ocfs2_complete_local_alloc_recovery(osb,  in ocfs2_complete_recovery()
1292 			ret = ocfs2_complete_truncate_log_recovery(osb,  in ocfs2_complete_recovery()
1300 		ret = ocfs2_recover_orphans(osb, item->lri_slot,  in ocfs2_complete_recovery()
1306 			ret = ocfs2_finish_quota_recovery(osb, qrec,  in ocfs2_complete_recovery()
1361 void ocfs2_complete_mount_recovery(struct ocfs2_super *osb)  in ocfs2_complete_mount_recovery()  argument
1363 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_complete_mount_recovery()
1365 	if (ocfs2_is_hard_readonly(osb))  in ocfs2_complete_mount_recovery()
1370 	ocfs2_queue_recovery_completion(journal, osb->slot_num,  in ocfs2_complete_mount_recovery()
1371 					osb->local_alloc_copy, NULL, NULL,  in ocfs2_complete_mount_recovery()
1373 	ocfs2_schedule_truncate_log_flush(osb, 0);  in ocfs2_complete_mount_recovery()
1375 	osb->local_alloc_copy = NULL;  in ocfs2_complete_mount_recovery()
1378 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_complete_mount_recovery()
1379 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in ocfs2_complete_mount_recovery()
1380 	ocfs2_free_replay_slots(osb);  in ocfs2_complete_mount_recovery()
1383 void ocfs2_complete_quota_recovery(struct ocfs2_super *osb)  in ocfs2_complete_quota_recovery()  argument
1385 	if (osb->quota_rec) {  in ocfs2_complete_quota_recovery()
1386 		ocfs2_queue_recovery_completion(osb->journal,  in ocfs2_complete_quota_recovery()
1387 						osb->slot_num,  in ocfs2_complete_quota_recovery()
1390 						osb->quota_rec,  in ocfs2_complete_quota_recovery()
1392 		osb->quota_rec = NULL;  in ocfs2_complete_quota_recovery()
1399 	struct ocfs2_super *osb = arg;  in __ocfs2_recovery_thread()  local
1400 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in __ocfs2_recovery_thread()
1406 	int quota_enabled = OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1408 		|| OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1411 	status = ocfs2_wait_on_mount(osb);  in __ocfs2_recovery_thread()
1417 		rm_quota = kcalloc(osb->max_slots, sizeof(int), GFP_NOFS);  in __ocfs2_recovery_thread()
1424 	status = ocfs2_super_lock(osb, 1);  in __ocfs2_recovery_thread()
1430 	status = ocfs2_compute_replay_slots(osb);  in __ocfs2_recovery_thread()
1435 	ocfs2_queue_recovery_completion(osb->journal, osb->slot_num, NULL,  in __ocfs2_recovery_thread()
1438 	spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1443 		spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1444 		slot_num = ocfs2_node_num_to_slot(osb, node_num);  in __ocfs2_recovery_thread()
1466 		status = ocfs2_recover_node(osb, node_num, slot_num);  in __ocfs2_recovery_thread()
1469 			ocfs2_recovery_map_clear(osb, node_num);  in __ocfs2_recovery_thread()
1474 			     MAJOR(osb->sb->s_dev), MINOR(osb->sb->s_dev));  in __ocfs2_recovery_thread()
1478 		spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1480 	spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1484 	status = ocfs2_check_journals_nolocks(osb);  in __ocfs2_recovery_thread()
1494 			qrec = ocfs2_begin_quota_recovery(osb, rm_quota[i]);  in __ocfs2_recovery_thread()
1500 			ocfs2_queue_recovery_completion(osb->journal,  in __ocfs2_recovery_thread()
1507 	ocfs2_super_unlock(osb, 1);  in __ocfs2_recovery_thread()
1510 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in __ocfs2_recovery_thread()
1513 	mutex_lock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1514 	if (!status && !ocfs2_recovery_completed(osb)) {  in __ocfs2_recovery_thread()
1515 		mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1519 	ocfs2_free_replay_slots(osb);  in __ocfs2_recovery_thread()
1520 	osb->recovery_thread_task = NULL;  in __ocfs2_recovery_thread()
1522 	wake_up(&osb->recovery_event);  in __ocfs2_recovery_thread()
1524 	mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1532 void ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num)  in ocfs2_recovery_thread()  argument
1534 	mutex_lock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1536 	trace_ocfs2_recovery_thread(node_num, osb->node_num,  in ocfs2_recovery_thread()
1537 		osb->disable_recovery, osb->recovery_thread_task,  in ocfs2_recovery_thread()
1538 		osb->disable_recovery ?  in ocfs2_recovery_thread()
1539 		-1 : ocfs2_recovery_map_set(osb, node_num));  in ocfs2_recovery_thread()
1541 	if (osb->disable_recovery)  in ocfs2_recovery_thread()
1544 	if (osb->recovery_thread_task)  in ocfs2_recovery_thread()
1547 	osb->recovery_thread_task =  kthread_run(__ocfs2_recovery_thread, osb,  in ocfs2_recovery_thread()
1548 			"ocfs2rec-%s", osb->uuid_str);  in ocfs2_recovery_thread()
1549 	if (IS_ERR(osb->recovery_thread_task)) {  in ocfs2_recovery_thread()
1550 		mlog_errno((int)PTR_ERR(osb->recovery_thread_task));  in ocfs2_recovery_thread()
1551 		osb->recovery_thread_task = NULL;  in ocfs2_recovery_thread()
1555 	mutex_unlock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1556 	wake_up(&osb->recovery_event);  in ocfs2_recovery_thread()
1559 static int ocfs2_read_journal_inode(struct ocfs2_super *osb,  in ocfs2_read_journal_inode()  argument
1567 	BUG_ON(slot_num >= osb->max_slots);  in ocfs2_read_journal_inode()
1569 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_read_journal_inode()
1597 static int ocfs2_replay_journal(struct ocfs2_super *osb,  in ocfs2_replay_journal()  argument
1610 	status = ocfs2_read_journal_inode(osb, slot_num, &bh, &inode);  in ocfs2_replay_journal()
1629 	if (osb->slot_recovery_generations[slot_num] != slot_reco_gen) {  in ocfs2_replay_journal()
1631 		     osb->slot_recovery_generations[slot_num], slot_reco_gen);  in ocfs2_replay_journal()
1632 		osb->slot_recovery_generations[slot_num] = slot_reco_gen;  in ocfs2_replay_journal()
1656 		osb->slot_recovery_generations[slot_num] = slot_reco_gen;  in ocfs2_replay_journal()
1661 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_replay_journal()
1664 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1665 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1690 	ocfs2_clear_journal_error(osb->sb, journal, slot_num);  in ocfs2_replay_journal()
1706 	osb->slot_recovery_generations[slot_num] =  in ocfs2_replay_journal()
1709 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_replay_journal()
1710 	status = ocfs2_write_block(osb, bh, INODE_CACHE(inode));  in ocfs2_replay_journal()
1719 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1720 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1744 static int ocfs2_recover_node(struct ocfs2_super *osb,  in ocfs2_recover_node()  argument
1751 	trace_ocfs2_recover_node(node_num, slot_num, osb->node_num);  in ocfs2_recover_node()
1755 	BUG_ON(osb->node_num == node_num);  in ocfs2_recover_node()
1757 	status = ocfs2_replay_journal(osb, node_num, slot_num);  in ocfs2_recover_node()
1769 	status = ocfs2_begin_local_alloc_recovery(osb, slot_num, &la_copy);  in ocfs2_recover_node()
1778 	status = ocfs2_begin_truncate_log_recovery(osb, slot_num, &tl_copy);  in ocfs2_recover_node()
1784 	status = ocfs2_clear_slot(osb, slot_num);  in ocfs2_recover_node()
1789 	ocfs2_queue_recovery_completion(osb->journal, slot_num, la_copy,  in ocfs2_recover_node()
1801 static int ocfs2_trylock_journal(struct ocfs2_super *osb,  in ocfs2_trylock_journal()  argument
1807 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_trylock_journal()
1840 int ocfs2_mark_dead_nodes(struct ocfs2_super *osb)  in ocfs2_mark_dead_nodes()  argument
1851 	for (i = 0; i < osb->max_slots; i++) {  in ocfs2_mark_dead_nodes()
1853 		status = ocfs2_read_journal_inode(osb, i, &bh, NULL);  in ocfs2_mark_dead_nodes()
1863 		spin_lock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1864 		osb->slot_recovery_generations[i] = gen;  in ocfs2_mark_dead_nodes()
1867 					    osb->slot_recovery_generations[i]);  in ocfs2_mark_dead_nodes()
1869 		if (i == osb->slot_num) {  in ocfs2_mark_dead_nodes()
1870 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1874 		status = ocfs2_slot_to_node_num_locked(osb, i, &node_num);  in ocfs2_mark_dead_nodes()
1876 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1880 		if (__ocfs2_recovery_map_test(osb, node_num)) {  in ocfs2_mark_dead_nodes()
1881 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1884 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1889 		status = ocfs2_trylock_journal(osb, i);  in ocfs2_mark_dead_nodes()
1894 			ocfs2_recovery_thread(osb, node_num);  in ocfs2_mark_dead_nodes()
1947 static void ocfs2_queue_orphan_scan(struct ocfs2_super *osb)  in ocfs2_queue_orphan_scan()  argument
1953 	os = &osb->osb_orphan_scan;  in ocfs2_queue_orphan_scan()
1961 	status = ocfs2_orphan_scan_lock(osb, &seqno);  in ocfs2_queue_orphan_scan()
1977 	for (i = 0; i < osb->max_slots; i++)  in ocfs2_queue_orphan_scan()
1978 		ocfs2_queue_recovery_completion(osb->journal, i, NULL, NULL,  in ocfs2_queue_orphan_scan()
1988 	ocfs2_orphan_scan_unlock(osb, seqno);  in ocfs2_queue_orphan_scan()
1999 	struct ocfs2_super *osb;  in ocfs2_orphan_scan_work()  local
2003 	osb = os->os_osb;  in ocfs2_orphan_scan_work()
2006 	ocfs2_queue_orphan_scan(osb);  in ocfs2_orphan_scan_work()
2008 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_work()
2013 void ocfs2_orphan_scan_stop(struct ocfs2_super *osb)  in ocfs2_orphan_scan_stop()  argument
2017 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_stop()
2026 void ocfs2_orphan_scan_init(struct ocfs2_super *osb)  in ocfs2_orphan_scan_init()  argument
2030 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_init()
2031 	os->os_osb = osb;  in ocfs2_orphan_scan_init()
2038 void ocfs2_orphan_scan_start(struct ocfs2_super *osb)  in ocfs2_orphan_scan_start()  argument
2042 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_start()
2044 	if (ocfs2_is_hard_readonly(osb) || ocfs2_mount_local(osb))  in ocfs2_orphan_scan_start()
2048 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_start()
2056 	struct ocfs2_super	*osb;  member
2080 	iter = ocfs2_iget(p->osb, ino,  in ocfs2_orphan_filldir()
2105 static int ocfs2_queue_orphans(struct ocfs2_super *osb,  in ocfs2_queue_orphans()  argument
2114 		.osb = osb,  in ocfs2_queue_orphans()
2119 	orphan_dir_inode = ocfs2_get_system_file_inode(osb,  in ocfs2_queue_orphans()
2151 static int ocfs2_orphan_recovery_can_continue(struct ocfs2_super *osb,  in ocfs2_orphan_recovery_can_continue()  argument
2156 	spin_lock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2157 	ret = !osb->osb_orphan_wipes[slot];  in ocfs2_orphan_recovery_can_continue()
2158 	spin_unlock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2162 static void ocfs2_mark_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_mark_recovering_orphan_dir()  argument
2165 	spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2168 	ocfs2_node_map_set_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_mark_recovering_orphan_dir()
2169 	while (osb->osb_orphan_wipes[slot]) {  in ocfs2_mark_recovering_orphan_dir()
2173 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2174 		wait_event_interruptible(osb->osb_wipe_event,  in ocfs2_mark_recovering_orphan_dir()
2175 					 ocfs2_orphan_recovery_can_continue(osb, slot));  in ocfs2_mark_recovering_orphan_dir()
2176 		spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2178 	spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2181 static void ocfs2_clear_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_clear_recovering_orphan_dir()  argument
2184 	ocfs2_node_map_clear_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_clear_recovering_orphan_dir()
2205 static int ocfs2_recover_orphans(struct ocfs2_super *osb,  in ocfs2_recover_orphans()  argument
2218 	ocfs2_mark_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2219 	ret = ocfs2_queue_orphans(osb, slot, &inode, orphan_reco_type);  in ocfs2_recover_orphans()
2220 	ocfs2_clear_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2263 				ret = ocfs2_del_inode_from_orphan(osb, inode,  in ocfs2_recover_orphans()
2294 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota)  in __ocfs2_wait_on_mount()  argument
2299 	wait_event(osb->osb_mount_event,  in __ocfs2_wait_on_mount()
2300 		  (!quota && atomic_read(&osb->vol_state) == VOLUME_MOUNTED) ||  in __ocfs2_wait_on_mount()
2301 		   atomic_read(&osb->vol_state) == VOLUME_MOUNTED_QUOTAS ||  in __ocfs2_wait_on_mount()
2302 		   atomic_read(&osb->vol_state) == VOLUME_DISABLED);  in __ocfs2_wait_on_mount()
2307 	if (atomic_read(&osb->vol_state) == VOLUME_DISABLED) {  in __ocfs2_wait_on_mount()
2319 	struct ocfs2_super *osb = arg;  in ocfs2_commit_thread()  local
2320 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_commit_thread()
2329 		wait_event_interruptible(osb->checkpoint_event,  in ocfs2_commit_thread()
2333 		status = ocfs2_commit_cache(osb);  in ocfs2_commit_thread()
2365 int ocfs2_check_journals_nolocks(struct ocfs2_super *osb)  in ocfs2_check_journals_nolocks()  argument
2373 	for(slot = 0; slot < osb->max_slots; slot++) {  in ocfs2_check_journals_nolocks()
2374 		ret = ocfs2_read_journal_inode(osb, slot, &di_bh, NULL);  in ocfs2_check_journals_nolocks()
2382 		osb->slot_recovery_generations[slot] =  in ocfs2_check_journals_nolocks()