50 static int ocfs2_recover_node(struct ocfs2_super *osb,
53 static int ocfs2_commit_cache(struct ocfs2_super *osb);
54 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota);
55 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,
57 static int ocfs2_trylock_journal(struct ocfs2_super *osb,
59 static int ocfs2_recover_orphans(struct ocfs2_super *osb,
70 static inline int ocfs2_wait_on_mount(struct ocfs2_super *osb)  in ocfs2_wait_on_mount()  argument
72 	return __ocfs2_wait_on_mount(osb, 0);  in ocfs2_wait_on_mount()
75 static inline int ocfs2_wait_on_quotas(struct ocfs2_super *osb)  in ocfs2_wait_on_quotas()  argument
77 	return __ocfs2_wait_on_mount(osb, 1);  in ocfs2_wait_on_quotas()
97 static void ocfs2_replay_map_set_state(struct ocfs2_super *osb, int state)  in ocfs2_replay_map_set_state()  argument
99 	if (!osb->replay_map)  in ocfs2_replay_map_set_state()
103 	if (osb->replay_map->rm_state == REPLAY_DONE)  in ocfs2_replay_map_set_state()
106 	osb->replay_map->rm_state = state;  in ocfs2_replay_map_set_state()
109 int ocfs2_compute_replay_slots(struct ocfs2_super *osb)  in ocfs2_compute_replay_slots()  argument
115 	if (osb->replay_map)  in ocfs2_compute_replay_slots()
119 			     (osb->max_slots * sizeof(char)), GFP_KERNEL);  in ocfs2_compute_replay_slots()
126 	spin_lock(&osb->osb_lock);  in ocfs2_compute_replay_slots()
128 	replay_map->rm_slots = osb->max_slots;  in ocfs2_compute_replay_slots()
133 		if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT)  in ocfs2_compute_replay_slots()
137 	osb->replay_map = replay_map;  in ocfs2_compute_replay_slots()
138 	spin_unlock(&osb->osb_lock);  in ocfs2_compute_replay_slots()
142 static void ocfs2_queue_replay_slots(struct ocfs2_super *osb,  in ocfs2_queue_replay_slots()  argument
145 	struct ocfs2_replay_map *replay_map = osb->replay_map;  in ocfs2_queue_replay_slots()
156 			ocfs2_queue_recovery_completion(osb->journal, i, NULL,  in ocfs2_queue_replay_slots()
162 static void ocfs2_free_replay_slots(struct ocfs2_super *osb)  in ocfs2_free_replay_slots()  argument
164 	struct ocfs2_replay_map *replay_map = osb->replay_map;  in ocfs2_free_replay_slots()
166 	if (!osb->replay_map)  in ocfs2_free_replay_slots()
170 	osb->replay_map = NULL;  in ocfs2_free_replay_slots()
173 int ocfs2_recovery_init(struct ocfs2_super *osb)  in ocfs2_recovery_init()  argument
177 	mutex_init(&osb->recovery_lock);  in ocfs2_recovery_init()
178 	osb->disable_recovery = 0;  in ocfs2_recovery_init()
179 	osb->recovery_thread_task = NULL;  in ocfs2_recovery_init()
180 	init_waitqueue_head(&osb->recovery_event);  in ocfs2_recovery_init()
183 		     osb->max_slots * sizeof(unsigned int),  in ocfs2_recovery_init()
192 	osb->recovery_map = rm;  in ocfs2_recovery_init()
200 static int ocfs2_recovery_thread_running(struct ocfs2_super *osb)  in ocfs2_recovery_thread_running()  argument
203 	return osb->recovery_thread_task != NULL;  in ocfs2_recovery_thread_running()
206 void ocfs2_recovery_exit(struct ocfs2_super *osb)  in ocfs2_recovery_exit()  argument
212 	mutex_lock(&osb->recovery_lock);  in ocfs2_recovery_exit()
213 	osb->disable_recovery = 1;  in ocfs2_recovery_exit()
214 	mutex_unlock(&osb->recovery_lock);  in ocfs2_recovery_exit()
215 	wait_event(osb->recovery_event, !ocfs2_recovery_thread_running(osb));  in ocfs2_recovery_exit()
220 	if (osb->ocfs2_wq)  in ocfs2_recovery_exit()
221 		flush_workqueue(osb->ocfs2_wq);  in ocfs2_recovery_exit()
227 	rm = osb->recovery_map;  in ocfs2_recovery_exit()
233 static int __ocfs2_recovery_map_test(struct ocfs2_super *osb,  in __ocfs2_recovery_map_test()  argument
237 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in __ocfs2_recovery_map_test()
239 	assert_spin_locked(&osb->osb_lock);  in __ocfs2_recovery_map_test()
250 static int ocfs2_recovery_map_set(struct ocfs2_super *osb,  in ocfs2_recovery_map_set()  argument
253 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_map_set()
255 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_map_set()
256 	if (__ocfs2_recovery_map_test(osb, node_num)) {  in ocfs2_recovery_map_set()
257 		spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_set()
262 	BUG_ON(rm->rm_used >= osb->max_slots);  in ocfs2_recovery_map_set()
266 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_set()
271 static void ocfs2_recovery_map_clear(struct ocfs2_super *osb,  in ocfs2_recovery_map_clear()  argument
275 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_map_clear()
277 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_map_clear()
291 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_map_clear()
294 static int ocfs2_commit_cache(struct ocfs2_super *osb)  in ocfs2_commit_cache()  argument
300 	journal = osb->journal;  in ocfs2_commit_cache()
329 	ocfs2_wake_downconvert_thread(osb);  in ocfs2_commit_cache()
335 handle_t *ocfs2_start_trans(struct ocfs2_super *osb, int max_buffs)  in ocfs2_start_trans()  argument
337 	journal_t *journal = osb->journal->j_journal;  in ocfs2_start_trans()
340 	BUG_ON(!osb || !osb->journal->j_journal);  in ocfs2_start_trans()
342 	if (ocfs2_is_hard_readonly(osb))  in ocfs2_start_trans()
345 	BUG_ON(osb->journal->j_state == OCFS2_JOURNAL_FREE);  in ocfs2_start_trans()
352 	sb_start_intwrite(osb->sb);  in ocfs2_start_trans()
354 	down_read(&osb->journal->j_trans_barrier);  in ocfs2_start_trans()
358 		up_read(&osb->journal->j_trans_barrier);  in ocfs2_start_trans()
359 		sb_end_intwrite(osb->sb);  in ocfs2_start_trans()
364 			ocfs2_abort(osb->sb, "Detected aborted journal\n");  in ocfs2_start_trans()
368 		if (!ocfs2_mount_local(osb))  in ocfs2_start_trans()
369 			atomic_inc(&(osb->journal->j_num_trans));  in ocfs2_start_trans()
375 int ocfs2_commit_trans(struct ocfs2_super *osb,  in ocfs2_commit_trans()  argument
379 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_commit_trans()
390 		sb_end_intwrite(osb->sb);  in ocfs2_commit_trans()
642 	struct ocfs2_super *osb =  in __ocfs2_journal_access()  local
672 			return ocfs2_error(osb->sb, "A previous attempt to "  in __ocfs2_journal_access()
684 	ocfs2_set_ci_lock_trans(osb->journal, ci);  in __ocfs2_journal_access()
701 	if (!status && ocfs2_meta_ecc(osb) && triggers)  in __ocfs2_journal_access()
798 void ocfs2_set_journal_params(struct ocfs2_super *osb)  in ocfs2_set_journal_params()  argument
800 	journal_t *journal = osb->journal->j_journal;  in ocfs2_set_journal_params()
803 	if (osb->osb_commit_interval)  in ocfs2_set_journal_params()
804 		commit_interval = osb->osb_commit_interval;  in ocfs2_set_journal_params()
808 	if (osb->s_mount_opt & OCFS2_MOUNT_BARRIER)  in ocfs2_set_journal_params()
822 	struct ocfs2_super *osb;  in ocfs2_journal_init()  local
827 	osb = journal->j_osb;  in ocfs2_journal_init()
830 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_journal_init()
831 					    osb->slot_num);  in ocfs2_journal_init()
889 	ocfs2_set_journal_params(osb);  in ocfs2_journal_init()
918 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,  in ocfs2_journal_toggle_dirty()  argument
923 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_journal_toggle_dirty()
944 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_journal_toggle_dirty()
945 	status = ocfs2_write_block(osb, bh, INODE_CACHE(journal->j_inode));  in ocfs2_journal_toggle_dirty()
956 void ocfs2_journal_shutdown(struct ocfs2_super *osb)  in ocfs2_journal_shutdown()  argument
963 	BUG_ON(!osb);  in ocfs2_journal_shutdown()
965 	journal = osb->journal;  in ocfs2_journal_shutdown()
978 	num_running_trans = atomic_read(&(osb->journal->j_num_trans));  in ocfs2_journal_shutdown()
990 	if (osb->commit_task) {  in ocfs2_journal_shutdown()
992 		trace_ocfs2_journal_shutdown_wait(osb->commit_task);  in ocfs2_journal_shutdown()
993 		kthread_stop(osb->commit_task);  in ocfs2_journal_shutdown()
994 		osb->commit_task = NULL;  in ocfs2_journal_shutdown()
997 	BUG_ON(atomic_read(&(osb->journal->j_num_trans)) != 0);  in ocfs2_journal_shutdown()
999 	if (ocfs2_mount_local(osb)) {  in ocfs2_journal_shutdown()
1013 		status = ocfs2_journal_toggle_dirty(osb, 0, 0);  in ocfs2_journal_shutdown()
1055 	struct ocfs2_super *osb;  in ocfs2_journal_load()  local
1059 	osb = journal->j_osb;  in ocfs2_journal_load()
1067 	ocfs2_clear_journal_error(osb->sb, journal->j_journal, osb->slot_num);  in ocfs2_journal_load()
1069 	status = ocfs2_journal_toggle_dirty(osb, 1, replayed);  in ocfs2_journal_load()
1077 		osb->commit_task = kthread_run(ocfs2_commit_thread, osb,  in ocfs2_journal_load()
1078 				"ocfs2cmt-%s", osb->uuid_str);  in ocfs2_journal_load()
1079 		if (IS_ERR(osb->commit_task)) {  in ocfs2_journal_load()
1080 			status = PTR_ERR(osb->commit_task);  in ocfs2_journal_load()
1081 			osb->commit_task = NULL;  in ocfs2_journal_load()
1087 		osb->commit_task = NULL;  in ocfs2_journal_load()
1116 static int ocfs2_recovery_completed(struct ocfs2_super *osb)  in ocfs2_recovery_completed()  argument
1119 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_completed()
1121 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_completed()
1123 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_completed()
1128 void ocfs2_wait_for_recovery(struct ocfs2_super *osb)  in ocfs2_wait_for_recovery()  argument
1130 	wait_event(osb->recovery_event, ocfs2_recovery_completed(osb));  in ocfs2_wait_for_recovery()
1149 	struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);  in ocfs2_force_read_journal()  local
1162 			bh = __find_get_block(osb->sb->s_bdev, p_blkno,  in ocfs2_force_read_journal()
1163 					osb->sb->s_blocksize);  in ocfs2_force_read_journal()
1173 			status = ocfs2_read_blocks_sync(osb, p_blkno, 1, &bh);  in ocfs2_force_read_journal()
1214 	struct ocfs2_super *osb = journal->j_osb;  in ocfs2_complete_recovery()  local
1231 		ocfs2_wait_on_quotas(osb);  in ocfs2_complete_recovery()
1244 			ret = ocfs2_complete_local_alloc_recovery(osb,  in ocfs2_complete_recovery()
1253 			ret = ocfs2_complete_truncate_log_recovery(osb,  in ocfs2_complete_recovery()
1261 		ret = ocfs2_recover_orphans(osb, item->lri_slot,  in ocfs2_complete_recovery()
1267 			ret = ocfs2_finish_quota_recovery(osb, qrec,  in ocfs2_complete_recovery()
1322 void ocfs2_complete_mount_recovery(struct ocfs2_super *osb)  in ocfs2_complete_mount_recovery()  argument
1324 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_complete_mount_recovery()
1326 	if (ocfs2_is_hard_readonly(osb))  in ocfs2_complete_mount_recovery()
1331 	ocfs2_queue_recovery_completion(journal, osb->slot_num,  in ocfs2_complete_mount_recovery()
1332 					osb->local_alloc_copy, NULL, NULL,  in ocfs2_complete_mount_recovery()
1334 	ocfs2_schedule_truncate_log_flush(osb, 0);  in ocfs2_complete_mount_recovery()
1336 	osb->local_alloc_copy = NULL;  in ocfs2_complete_mount_recovery()
1339 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_complete_mount_recovery()
1340 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in ocfs2_complete_mount_recovery()
1341 	ocfs2_free_replay_slots(osb);  in ocfs2_complete_mount_recovery()
1344 void ocfs2_complete_quota_recovery(struct ocfs2_super *osb)  in ocfs2_complete_quota_recovery()  argument
1346 	if (osb->quota_rec) {  in ocfs2_complete_quota_recovery()
1347 		ocfs2_queue_recovery_completion(osb->journal,  in ocfs2_complete_quota_recovery()
1348 						osb->slot_num,  in ocfs2_complete_quota_recovery()
1351 						osb->quota_rec,  in ocfs2_complete_quota_recovery()
1353 		osb->quota_rec = NULL;  in ocfs2_complete_quota_recovery()
1360 	struct ocfs2_super *osb = arg;  in __ocfs2_recovery_thread()  local
1361 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in __ocfs2_recovery_thread()
1367 	int quota_enabled = OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1369 		|| OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1372 	status = ocfs2_wait_on_mount(osb);  in __ocfs2_recovery_thread()
1378 		rm_quota = kcalloc(osb->max_slots, sizeof(int), GFP_NOFS);  in __ocfs2_recovery_thread()
1385 	status = ocfs2_super_lock(osb, 1);  in __ocfs2_recovery_thread()
1391 	status = ocfs2_compute_replay_slots(osb);  in __ocfs2_recovery_thread()
1396 	ocfs2_queue_recovery_completion(osb->journal, osb->slot_num, NULL,  in __ocfs2_recovery_thread()
1399 	spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1404 		spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1405 		slot_num = ocfs2_node_num_to_slot(osb, node_num);  in __ocfs2_recovery_thread()
1427 		status = ocfs2_recover_node(osb, node_num, slot_num);  in __ocfs2_recovery_thread()
1430 			ocfs2_recovery_map_clear(osb, node_num);  in __ocfs2_recovery_thread()
1435 			     MAJOR(osb->sb->s_dev), MINOR(osb->sb->s_dev));  in __ocfs2_recovery_thread()
1439 		spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1441 	spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1445 	status = ocfs2_check_journals_nolocks(osb);  in __ocfs2_recovery_thread()
1455 			qrec = ocfs2_begin_quota_recovery(osb, rm_quota[i]);  in __ocfs2_recovery_thread()
1461 			ocfs2_queue_recovery_completion(osb->journal,  in __ocfs2_recovery_thread()
1468 	ocfs2_super_unlock(osb, 1);  in __ocfs2_recovery_thread()
1471 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in __ocfs2_recovery_thread()
1474 	mutex_lock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1475 	if (!status && !ocfs2_recovery_completed(osb)) {  in __ocfs2_recovery_thread()
1476 		mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1480 	ocfs2_free_replay_slots(osb);  in __ocfs2_recovery_thread()
1481 	osb->recovery_thread_task = NULL;  in __ocfs2_recovery_thread()
1483 	wake_up(&osb->recovery_event);  in __ocfs2_recovery_thread()
1485 	mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1496 void ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num)  in ocfs2_recovery_thread()  argument
1498 	mutex_lock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1500 	trace_ocfs2_recovery_thread(node_num, osb->node_num,  in ocfs2_recovery_thread()
1501 		osb->disable_recovery, osb->recovery_thread_task,  in ocfs2_recovery_thread()
1502 		osb->disable_recovery ?  in ocfs2_recovery_thread()
1503 		-1 : ocfs2_recovery_map_set(osb, node_num));  in ocfs2_recovery_thread()
1505 	if (osb->disable_recovery)  in ocfs2_recovery_thread()
1508 	if (osb->recovery_thread_task)  in ocfs2_recovery_thread()
1511 	osb->recovery_thread_task =  kthread_run(__ocfs2_recovery_thread, osb,  in ocfs2_recovery_thread()
1512 			"ocfs2rec-%s", osb->uuid_str);  in ocfs2_recovery_thread()
1513 	if (IS_ERR(osb->recovery_thread_task)) {  in ocfs2_recovery_thread()
1514 		mlog_errno((int)PTR_ERR(osb->recovery_thread_task));  in ocfs2_recovery_thread()
1515 		osb->recovery_thread_task = NULL;  in ocfs2_recovery_thread()
1519 	mutex_unlock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1520 	wake_up(&osb->recovery_event);  in ocfs2_recovery_thread()
1523 static int ocfs2_read_journal_inode(struct ocfs2_super *osb,  in ocfs2_read_journal_inode()  argument
1531 	BUG_ON(slot_num >= osb->max_slots);  in ocfs2_read_journal_inode()
1533 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_read_journal_inode()
1561 static int ocfs2_replay_journal(struct ocfs2_super *osb,  in ocfs2_replay_journal()  argument
1574 	status = ocfs2_read_journal_inode(osb, slot_num, &bh, &inode);  in ocfs2_replay_journal()
1593 	if (osb->slot_recovery_generations[slot_num] != slot_reco_gen) {  in ocfs2_replay_journal()
1595 		     osb->slot_recovery_generations[slot_num], slot_reco_gen);  in ocfs2_replay_journal()
1596 		osb->slot_recovery_generations[slot_num] = slot_reco_gen;  in ocfs2_replay_journal()
1620 		osb->slot_recovery_generations[slot_num] = slot_reco_gen;  in ocfs2_replay_journal()
1625 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_replay_journal()
1628 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1629 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1655 	ocfs2_clear_journal_error(osb->sb, journal, slot_num);  in ocfs2_replay_journal()
1671 	osb->slot_recovery_generations[slot_num] =  in ocfs2_replay_journal()
1674 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_replay_journal()
1675 	status = ocfs2_write_block(osb, bh, INODE_CACHE(inode));  in ocfs2_replay_journal()
1685 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1686 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1710 static int ocfs2_recover_node(struct ocfs2_super *osb,  in ocfs2_recover_node()  argument
1717 	trace_ocfs2_recover_node(node_num, slot_num, osb->node_num);  in ocfs2_recover_node()
1721 	BUG_ON(osb->node_num == node_num);  in ocfs2_recover_node()
1723 	status = ocfs2_replay_journal(osb, node_num, slot_num);  in ocfs2_recover_node()
1735 	status = ocfs2_begin_local_alloc_recovery(osb, slot_num, &la_copy);  in ocfs2_recover_node()
1744 	status = ocfs2_begin_truncate_log_recovery(osb, slot_num, &tl_copy);  in ocfs2_recover_node()
1750 	status = ocfs2_clear_slot(osb, slot_num);  in ocfs2_recover_node()
1755 	ocfs2_queue_recovery_completion(osb->journal, slot_num, la_copy,  in ocfs2_recover_node()
1767 static int ocfs2_trylock_journal(struct ocfs2_super *osb,  in ocfs2_trylock_journal()  argument
1773 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_trylock_journal()
1806 int ocfs2_mark_dead_nodes(struct ocfs2_super *osb)  in ocfs2_mark_dead_nodes()  argument
1817 	for (i = 0; i < osb->max_slots; i++) {  in ocfs2_mark_dead_nodes()
1819 		status = ocfs2_read_journal_inode(osb, i, &bh, NULL);  in ocfs2_mark_dead_nodes()
1829 		spin_lock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1830 		osb->slot_recovery_generations[i] = gen;  in ocfs2_mark_dead_nodes()
1833 					    osb->slot_recovery_generations[i]);  in ocfs2_mark_dead_nodes()
1835 		if (i == osb->slot_num) {  in ocfs2_mark_dead_nodes()
1836 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1840 		status = ocfs2_slot_to_node_num_locked(osb, i, &node_num);  in ocfs2_mark_dead_nodes()
1842 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1846 		if (__ocfs2_recovery_map_test(osb, node_num)) {  in ocfs2_mark_dead_nodes()
1847 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1850 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1855 		status = ocfs2_trylock_journal(osb, i);  in ocfs2_mark_dead_nodes()
1860 			ocfs2_recovery_thread(osb, node_num);  in ocfs2_mark_dead_nodes()
1913 static void ocfs2_queue_orphan_scan(struct ocfs2_super *osb)  in ocfs2_queue_orphan_scan()  argument
1919 	os = &osb->osb_orphan_scan;  in ocfs2_queue_orphan_scan()
1927 	status = ocfs2_orphan_scan_lock(osb, &seqno);  in ocfs2_queue_orphan_scan()
1943 	for (i = 0; i < osb->max_slots; i++)  in ocfs2_queue_orphan_scan()
1944 		ocfs2_queue_recovery_completion(osb->journal, i, NULL, NULL,  in ocfs2_queue_orphan_scan()
1954 	ocfs2_orphan_scan_unlock(osb, seqno);  in ocfs2_queue_orphan_scan()
1965 	struct ocfs2_super *osb;  in ocfs2_orphan_scan_work()  local
1969 	osb = os->os_osb;  in ocfs2_orphan_scan_work()
1972 	ocfs2_queue_orphan_scan(osb);  in ocfs2_orphan_scan_work()
1974 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_work()
1979 void ocfs2_orphan_scan_stop(struct ocfs2_super *osb)  in ocfs2_orphan_scan_stop()  argument
1983 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_stop()
1992 void ocfs2_orphan_scan_init(struct ocfs2_super *osb)  in ocfs2_orphan_scan_init()  argument
1996 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_init()
1997 	os->os_osb = osb;  in ocfs2_orphan_scan_init()
2004 void ocfs2_orphan_scan_start(struct ocfs2_super *osb)  in ocfs2_orphan_scan_start()  argument
2008 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_start()
2010 	if (ocfs2_is_hard_readonly(osb) || ocfs2_mount_local(osb))  in ocfs2_orphan_scan_start()
2014 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_start()
2022 	struct ocfs2_super	*osb;  member
2046 	iter = ocfs2_iget(p->osb, ino,  in ocfs2_orphan_filldir()
2071 static int ocfs2_queue_orphans(struct ocfs2_super *osb,  in ocfs2_queue_orphans()  argument
2080 		.osb = osb,  in ocfs2_queue_orphans()
2085 	orphan_dir_inode = ocfs2_get_system_file_inode(osb,  in ocfs2_queue_orphans()
2117 static int ocfs2_orphan_recovery_can_continue(struct ocfs2_super *osb,  in ocfs2_orphan_recovery_can_continue()  argument
2122 	spin_lock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2123 	ret = !osb->osb_orphan_wipes[slot];  in ocfs2_orphan_recovery_can_continue()
2124 	spin_unlock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2128 static void ocfs2_mark_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_mark_recovering_orphan_dir()  argument
2131 	spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2134 	ocfs2_node_map_set_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_mark_recovering_orphan_dir()
2135 	while (osb->osb_orphan_wipes[slot]) {  in ocfs2_mark_recovering_orphan_dir()
2139 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2140 		wait_event_interruptible(osb->osb_wipe_event,  in ocfs2_mark_recovering_orphan_dir()
2141 					 ocfs2_orphan_recovery_can_continue(osb, slot));  in ocfs2_mark_recovering_orphan_dir()
2142 		spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2144 	spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2147 static void ocfs2_clear_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_clear_recovering_orphan_dir()  argument
2150 	ocfs2_node_map_clear_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_clear_recovering_orphan_dir()
2171 static int ocfs2_recover_orphans(struct ocfs2_super *osb,  in ocfs2_recover_orphans()  argument
2184 	ocfs2_mark_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2185 	ret = ocfs2_queue_orphans(osb, slot, &inode, orphan_reco_type);  in ocfs2_recover_orphans()
2186 	ocfs2_clear_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2229 				ret = ocfs2_del_inode_from_orphan(osb, inode,  in ocfs2_recover_orphans()
2260 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota)  in __ocfs2_wait_on_mount()  argument
2265 	wait_event(osb->osb_mount_event,  in __ocfs2_wait_on_mount()
2266 		  (!quota && atomic_read(&osb->vol_state) == VOLUME_MOUNTED) ||  in __ocfs2_wait_on_mount()
2267 		   atomic_read(&osb->vol_state) == VOLUME_MOUNTED_QUOTAS ||  in __ocfs2_wait_on_mount()
2268 		   atomic_read(&osb->vol_state) == VOLUME_DISABLED);  in __ocfs2_wait_on_mount()
2273 	if (atomic_read(&osb->vol_state) == VOLUME_DISABLED) {  in __ocfs2_wait_on_mount()
2285 	struct ocfs2_super *osb = arg;  in ocfs2_commit_thread()  local
2286 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_commit_thread()
2295 		wait_event_interruptible(osb->checkpoint_event,  in ocfs2_commit_thread()
2299 		status = ocfs2_commit_cache(osb);  in ocfs2_commit_thread()
2331 int ocfs2_check_journals_nolocks(struct ocfs2_super *osb)  in ocfs2_check_journals_nolocks()  argument
2339 	for(slot = 0; slot < osb->max_slots; slot++) {  in ocfs2_check_journals_nolocks()
2340 		ret = ocfs2_read_journal_inode(osb, slot, &di_bh, NULL);  in ocfs2_check_journals_nolocks()
2348 		osb->slot_recovery_generations[slot] =  in ocfs2_check_journals_nolocks()