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()
893 	ocfs2_set_journal_params(osb);  in ocfs2_journal_init()
922 static int ocfs2_journal_toggle_dirty(struct ocfs2_super *osb,  in ocfs2_journal_toggle_dirty()  argument
927 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_journal_toggle_dirty()
948 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_journal_toggle_dirty()
949 	status = ocfs2_write_block(osb, bh, INODE_CACHE(journal->j_inode));  in ocfs2_journal_toggle_dirty()
960 void ocfs2_journal_shutdown(struct ocfs2_super *osb)  in ocfs2_journal_shutdown()  argument
967 	BUG_ON(!osb);  in ocfs2_journal_shutdown()
969 	journal = osb->journal;  in ocfs2_journal_shutdown()
982 	num_running_trans = atomic_read(&(osb->journal->j_num_trans));  in ocfs2_journal_shutdown()
994 	if (osb->commit_task) {  in ocfs2_journal_shutdown()
996 		trace_ocfs2_journal_shutdown_wait(osb->commit_task);  in ocfs2_journal_shutdown()
997 		kthread_stop(osb->commit_task);  in ocfs2_journal_shutdown()
998 		osb->commit_task = NULL;  in ocfs2_journal_shutdown()
1001 	BUG_ON(atomic_read(&(osb->journal->j_num_trans)) != 0);  in ocfs2_journal_shutdown()
1003 	if (ocfs2_mount_local(osb)) {  in ocfs2_journal_shutdown()
1017 		status = ocfs2_journal_toggle_dirty(osb, 0, 0);  in ocfs2_journal_shutdown()
1059 	struct ocfs2_super *osb;  in ocfs2_journal_load()  local
1063 	osb = journal->j_osb;  in ocfs2_journal_load()
1071 	ocfs2_clear_journal_error(osb->sb, journal->j_journal, osb->slot_num);  in ocfs2_journal_load()
1081 	status = ocfs2_journal_toggle_dirty(osb, 1, replayed);  in ocfs2_journal_load()
1089 		osb->commit_task = kthread_run(ocfs2_commit_thread, osb,  in ocfs2_journal_load()
1090 				"ocfs2cmt-%s", osb->uuid_str);  in ocfs2_journal_load()
1091 		if (IS_ERR(osb->commit_task)) {  in ocfs2_journal_load()
1092 			status = PTR_ERR(osb->commit_task);  in ocfs2_journal_load()
1093 			osb->commit_task = NULL;  in ocfs2_journal_load()
1099 		osb->commit_task = NULL;  in ocfs2_journal_load()
1128 static int ocfs2_recovery_completed(struct ocfs2_super *osb)  in ocfs2_recovery_completed()  argument
1131 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in ocfs2_recovery_completed()
1133 	spin_lock(&osb->osb_lock);  in ocfs2_recovery_completed()
1135 	spin_unlock(&osb->osb_lock);  in ocfs2_recovery_completed()
1140 void ocfs2_wait_for_recovery(struct ocfs2_super *osb)  in ocfs2_wait_for_recovery()  argument
1142 	wait_event(osb->recovery_event, ocfs2_recovery_completed(osb));  in ocfs2_wait_for_recovery()
1161 	struct ocfs2_super *osb = OCFS2_SB(inode->i_sb);  in ocfs2_force_read_journal()  local
1174 			bh = __find_get_block(osb->sb->s_bdev, p_blkno,  in ocfs2_force_read_journal()
1175 					osb->sb->s_blocksize);  in ocfs2_force_read_journal()
1185 			status = ocfs2_read_blocks_sync(osb, p_blkno, 1, &bh);  in ocfs2_force_read_journal()
1226 	struct ocfs2_super *osb = journal->j_osb;  in ocfs2_complete_recovery()  local
1243 		ocfs2_wait_on_quotas(osb);  in ocfs2_complete_recovery()
1256 			ret = ocfs2_complete_local_alloc_recovery(osb,  in ocfs2_complete_recovery()
1265 			ret = ocfs2_complete_truncate_log_recovery(osb,  in ocfs2_complete_recovery()
1273 		ret = ocfs2_recover_orphans(osb, item->lri_slot,  in ocfs2_complete_recovery()
1279 			ret = ocfs2_finish_quota_recovery(osb, qrec,  in ocfs2_complete_recovery()
1334 void ocfs2_complete_mount_recovery(struct ocfs2_super *osb)  in ocfs2_complete_mount_recovery()  argument
1336 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_complete_mount_recovery()
1338 	if (ocfs2_is_hard_readonly(osb))  in ocfs2_complete_mount_recovery()
1343 	ocfs2_queue_recovery_completion(journal, osb->slot_num,  in ocfs2_complete_mount_recovery()
1344 					osb->local_alloc_copy, NULL, NULL,  in ocfs2_complete_mount_recovery()
1346 	ocfs2_schedule_truncate_log_flush(osb, 0);  in ocfs2_complete_mount_recovery()
1348 	osb->local_alloc_copy = NULL;  in ocfs2_complete_mount_recovery()
1351 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_complete_mount_recovery()
1352 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in ocfs2_complete_mount_recovery()
1353 	ocfs2_free_replay_slots(osb);  in ocfs2_complete_mount_recovery()
1356 void ocfs2_complete_quota_recovery(struct ocfs2_super *osb)  in ocfs2_complete_quota_recovery()  argument
1358 	if (osb->quota_rec) {  in ocfs2_complete_quota_recovery()
1359 		ocfs2_queue_recovery_completion(osb->journal,  in ocfs2_complete_quota_recovery()
1360 						osb->slot_num,  in ocfs2_complete_quota_recovery()
1363 						osb->quota_rec,  in ocfs2_complete_quota_recovery()
1365 		osb->quota_rec = NULL;  in ocfs2_complete_quota_recovery()
1372 	struct ocfs2_super *osb = arg;  in __ocfs2_recovery_thread()  local
1373 	struct ocfs2_recovery_map *rm = osb->recovery_map;  in __ocfs2_recovery_thread()
1379 	int quota_enabled = OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1381 		|| OCFS2_HAS_RO_COMPAT_FEATURE(osb->sb,  in __ocfs2_recovery_thread()
1384 	status = ocfs2_wait_on_mount(osb);  in __ocfs2_recovery_thread()
1390 		rm_quota = kcalloc(osb->max_slots, sizeof(int), GFP_NOFS);  in __ocfs2_recovery_thread()
1397 	status = ocfs2_super_lock(osb, 1);  in __ocfs2_recovery_thread()
1403 	status = ocfs2_compute_replay_slots(osb);  in __ocfs2_recovery_thread()
1408 	ocfs2_queue_recovery_completion(osb->journal, osb->slot_num, NULL,  in __ocfs2_recovery_thread()
1411 	spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1416 		spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1417 		slot_num = ocfs2_node_num_to_slot(osb, node_num);  in __ocfs2_recovery_thread()
1439 		status = ocfs2_recover_node(osb, node_num, slot_num);  in __ocfs2_recovery_thread()
1442 			ocfs2_recovery_map_clear(osb, node_num);  in __ocfs2_recovery_thread()
1447 			     MAJOR(osb->sb->s_dev), MINOR(osb->sb->s_dev));  in __ocfs2_recovery_thread()
1451 		spin_lock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1453 	spin_unlock(&osb->osb_lock);  in __ocfs2_recovery_thread()
1457 	status = ocfs2_check_journals_nolocks(osb);  in __ocfs2_recovery_thread()
1467 			qrec = ocfs2_begin_quota_recovery(osb, rm_quota[i]);  in __ocfs2_recovery_thread()
1473 			ocfs2_queue_recovery_completion(osb->journal,  in __ocfs2_recovery_thread()
1480 	ocfs2_super_unlock(osb, 1);  in __ocfs2_recovery_thread()
1483 	ocfs2_queue_replay_slots(osb, ORPHAN_NEED_TRUNCATE);  in __ocfs2_recovery_thread()
1486 	mutex_lock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1487 	if (!status && !ocfs2_recovery_completed(osb)) {  in __ocfs2_recovery_thread()
1488 		mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1492 	ocfs2_free_replay_slots(osb);  in __ocfs2_recovery_thread()
1493 	osb->recovery_thread_task = NULL;  in __ocfs2_recovery_thread()
1495 	wake_up(&osb->recovery_event);  in __ocfs2_recovery_thread()
1497 	mutex_unlock(&osb->recovery_lock);  in __ocfs2_recovery_thread()
1508 void ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num)  in ocfs2_recovery_thread()  argument
1510 	mutex_lock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1512 	trace_ocfs2_recovery_thread(node_num, osb->node_num,  in ocfs2_recovery_thread()
1513 		osb->disable_recovery, osb->recovery_thread_task,  in ocfs2_recovery_thread()
1514 		osb->disable_recovery ?  in ocfs2_recovery_thread()
1515 		-1 : ocfs2_recovery_map_set(osb, node_num));  in ocfs2_recovery_thread()
1517 	if (osb->disable_recovery)  in ocfs2_recovery_thread()
1520 	if (osb->recovery_thread_task)  in ocfs2_recovery_thread()
1523 	osb->recovery_thread_task =  kthread_run(__ocfs2_recovery_thread, osb,  in ocfs2_recovery_thread()
1524 			"ocfs2rec-%s", osb->uuid_str);  in ocfs2_recovery_thread()
1525 	if (IS_ERR(osb->recovery_thread_task)) {  in ocfs2_recovery_thread()
1526 		mlog_errno((int)PTR_ERR(osb->recovery_thread_task));  in ocfs2_recovery_thread()
1527 		osb->recovery_thread_task = NULL;  in ocfs2_recovery_thread()
1531 	mutex_unlock(&osb->recovery_lock);  in ocfs2_recovery_thread()
1532 	wake_up(&osb->recovery_event);  in ocfs2_recovery_thread()
1535 static int ocfs2_read_journal_inode(struct ocfs2_super *osb,  in ocfs2_read_journal_inode()  argument
1543 	BUG_ON(slot_num >= osb->max_slots);  in ocfs2_read_journal_inode()
1545 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_read_journal_inode()
1573 static int ocfs2_replay_journal(struct ocfs2_super *osb,  in ocfs2_replay_journal()  argument
1586 	status = ocfs2_read_journal_inode(osb, slot_num, &bh, &inode);  in ocfs2_replay_journal()
1605 	if (osb->slot_recovery_generations[slot_num] != slot_reco_gen) {  in ocfs2_replay_journal()
1607 		     osb->slot_recovery_generations[slot_num], slot_reco_gen);  in ocfs2_replay_journal()
1608 		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()
1637 	ocfs2_replay_map_set_state(osb, REPLAY_NEEDED);  in ocfs2_replay_journal()
1640 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1641 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1667 	ocfs2_clear_journal_error(osb->sb, journal, slot_num);  in ocfs2_replay_journal()
1683 	osb->slot_recovery_generations[slot_num] =  in ocfs2_replay_journal()
1686 	ocfs2_compute_meta_ecc(osb->sb, bh->b_data, &fe->i_check);  in ocfs2_replay_journal()
1687 	status = ocfs2_write_block(osb, bh, INODE_CACHE(inode));  in ocfs2_replay_journal()
1697 	       "device (%u,%u)\n", node_num, slot_num, MAJOR(osb->sb->s_dev),  in ocfs2_replay_journal()
1698 	       MINOR(osb->sb->s_dev));  in ocfs2_replay_journal()
1722 static int ocfs2_recover_node(struct ocfs2_super *osb,  in ocfs2_recover_node()  argument
1729 	trace_ocfs2_recover_node(node_num, slot_num, osb->node_num);  in ocfs2_recover_node()
1733 	BUG_ON(osb->node_num == node_num);  in ocfs2_recover_node()
1735 	status = ocfs2_replay_journal(osb, node_num, slot_num);  in ocfs2_recover_node()
1747 	status = ocfs2_begin_local_alloc_recovery(osb, slot_num, &la_copy);  in ocfs2_recover_node()
1756 	status = ocfs2_begin_truncate_log_recovery(osb, slot_num, &tl_copy);  in ocfs2_recover_node()
1762 	status = ocfs2_clear_slot(osb, slot_num);  in ocfs2_recover_node()
1767 	ocfs2_queue_recovery_completion(osb->journal, slot_num, la_copy,  in ocfs2_recover_node()
1779 static int ocfs2_trylock_journal(struct ocfs2_super *osb,  in ocfs2_trylock_journal()  argument
1785 	inode = ocfs2_get_system_file_inode(osb, JOURNAL_SYSTEM_INODE,  in ocfs2_trylock_journal()
1818 int ocfs2_mark_dead_nodes(struct ocfs2_super *osb)  in ocfs2_mark_dead_nodes()  argument
1829 	for (i = 0; i < osb->max_slots; i++) {  in ocfs2_mark_dead_nodes()
1831 		status = ocfs2_read_journal_inode(osb, i, &bh, NULL);  in ocfs2_mark_dead_nodes()
1841 		spin_lock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1842 		osb->slot_recovery_generations[i] = gen;  in ocfs2_mark_dead_nodes()
1845 					    osb->slot_recovery_generations[i]);  in ocfs2_mark_dead_nodes()
1847 		if (i == osb->slot_num) {  in ocfs2_mark_dead_nodes()
1848 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1852 		status = ocfs2_slot_to_node_num_locked(osb, i, &node_num);  in ocfs2_mark_dead_nodes()
1854 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1858 		if (__ocfs2_recovery_map_test(osb, node_num)) {  in ocfs2_mark_dead_nodes()
1859 			spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1862 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_dead_nodes()
1867 		status = ocfs2_trylock_journal(osb, i);  in ocfs2_mark_dead_nodes()
1872 			ocfs2_recovery_thread(osb, node_num);  in ocfs2_mark_dead_nodes()
1925 static void ocfs2_queue_orphan_scan(struct ocfs2_super *osb)  in ocfs2_queue_orphan_scan()  argument
1931 	os = &osb->osb_orphan_scan;  in ocfs2_queue_orphan_scan()
1939 	status = ocfs2_orphan_scan_lock(osb, &seqno);  in ocfs2_queue_orphan_scan()
1955 	for (i = 0; i < osb->max_slots; i++)  in ocfs2_queue_orphan_scan()
1956 		ocfs2_queue_recovery_completion(osb->journal, i, NULL, NULL,  in ocfs2_queue_orphan_scan()
1966 	ocfs2_orphan_scan_unlock(osb, seqno);  in ocfs2_queue_orphan_scan()
1977 	struct ocfs2_super *osb;  in ocfs2_orphan_scan_work()  local
1981 	osb = os->os_osb;  in ocfs2_orphan_scan_work()
1984 	ocfs2_queue_orphan_scan(osb);  in ocfs2_orphan_scan_work()
1986 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_work()
1991 void ocfs2_orphan_scan_stop(struct ocfs2_super *osb)  in ocfs2_orphan_scan_stop()  argument
1995 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_stop()
2004 void ocfs2_orphan_scan_init(struct ocfs2_super *osb)  in ocfs2_orphan_scan_init()  argument
2008 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_init()
2009 	os->os_osb = osb;  in ocfs2_orphan_scan_init()
2016 void ocfs2_orphan_scan_start(struct ocfs2_super *osb)  in ocfs2_orphan_scan_start()  argument
2020 	os = &osb->osb_orphan_scan;  in ocfs2_orphan_scan_start()
2022 	if (ocfs2_is_hard_readonly(osb) || ocfs2_mount_local(osb))  in ocfs2_orphan_scan_start()
2026 		queue_delayed_work(osb->ocfs2_wq, &os->os_orphan_scan_work,  in ocfs2_orphan_scan_start()
2034 	struct ocfs2_super	*osb;  member
2058 	iter = ocfs2_iget(p->osb, ino,  in ocfs2_orphan_filldir()
2083 static int ocfs2_queue_orphans(struct ocfs2_super *osb,  in ocfs2_queue_orphans()  argument
2092 		.osb = osb,  in ocfs2_queue_orphans()
2097 	orphan_dir_inode = ocfs2_get_system_file_inode(osb,  in ocfs2_queue_orphans()
2129 static int ocfs2_orphan_recovery_can_continue(struct ocfs2_super *osb,  in ocfs2_orphan_recovery_can_continue()  argument
2134 	spin_lock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2135 	ret = !osb->osb_orphan_wipes[slot];  in ocfs2_orphan_recovery_can_continue()
2136 	spin_unlock(&osb->osb_lock);  in ocfs2_orphan_recovery_can_continue()
2140 static void ocfs2_mark_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_mark_recovering_orphan_dir()  argument
2143 	spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2146 	ocfs2_node_map_set_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_mark_recovering_orphan_dir()
2147 	while (osb->osb_orphan_wipes[slot]) {  in ocfs2_mark_recovering_orphan_dir()
2151 		spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2152 		wait_event_interruptible(osb->osb_wipe_event,  in ocfs2_mark_recovering_orphan_dir()
2153 					 ocfs2_orphan_recovery_can_continue(osb, slot));  in ocfs2_mark_recovering_orphan_dir()
2154 		spin_lock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2156 	spin_unlock(&osb->osb_lock);  in ocfs2_mark_recovering_orphan_dir()
2159 static void ocfs2_clear_recovering_orphan_dir(struct ocfs2_super *osb,  in ocfs2_clear_recovering_orphan_dir()  argument
2162 	ocfs2_node_map_clear_bit(osb, &osb->osb_recovering_orphan_dirs, slot);  in ocfs2_clear_recovering_orphan_dir()
2183 static int ocfs2_recover_orphans(struct ocfs2_super *osb,  in ocfs2_recover_orphans()  argument
2196 	ocfs2_mark_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2197 	ret = ocfs2_queue_orphans(osb, slot, &inode, orphan_reco_type);  in ocfs2_recover_orphans()
2198 	ocfs2_clear_recovering_orphan_dir(osb, slot);  in ocfs2_recover_orphans()
2241 				ret = ocfs2_del_inode_from_orphan(osb, inode,  in ocfs2_recover_orphans()
2272 static int __ocfs2_wait_on_mount(struct ocfs2_super *osb, int quota)  in __ocfs2_wait_on_mount()  argument
2277 	wait_event(osb->osb_mount_event,  in __ocfs2_wait_on_mount()
2278 		  (!quota && atomic_read(&osb->vol_state) == VOLUME_MOUNTED) ||  in __ocfs2_wait_on_mount()
2279 		   atomic_read(&osb->vol_state) == VOLUME_MOUNTED_QUOTAS ||  in __ocfs2_wait_on_mount()
2280 		   atomic_read(&osb->vol_state) == VOLUME_DISABLED);  in __ocfs2_wait_on_mount()
2285 	if (atomic_read(&osb->vol_state) == VOLUME_DISABLED) {  in __ocfs2_wait_on_mount()
2297 	struct ocfs2_super *osb = arg;  in ocfs2_commit_thread()  local
2298 	struct ocfs2_journal *journal = osb->journal;  in ocfs2_commit_thread()
2307 		wait_event_interruptible(osb->checkpoint_event,  in ocfs2_commit_thread()
2311 		status = ocfs2_commit_cache(osb);  in ocfs2_commit_thread()
2343 int ocfs2_check_journals_nolocks(struct ocfs2_super *osb)  in ocfs2_check_journals_nolocks()  argument
2351 	for(slot = 0; slot < osb->max_slots; slot++) {  in ocfs2_check_journals_nolocks()
2352 		ret = ocfs2_read_journal_inode(osb, slot, &di_bh, NULL);  in ocfs2_check_journals_nolocks()
2360 		osb->slot_recovery_generations[slot] =  in ocfs2_check_journals_nolocks()