590 	struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info;  in issue_flush_thread()  local
591 	wait_queue_head_t *q = &fcc->flush_wait_queue;  in issue_flush_thread()
598 	if (!llist_empty(&fcc->issue_list)) {  in issue_flush_thread()
602 		fcc->dispatch_list = llist_del_all(&fcc->issue_list);  in issue_flush_thread()
603 		fcc->dispatch_list = llist_reverse_order(fcc->dispatch_list);  in issue_flush_thread()
605 		cmd = llist_entry(fcc->dispatch_list, struct flush_cmd, llnode);  in issue_flush_thread()
608 		atomic_inc(&fcc->issued_flush);  in issue_flush_thread()
611 					  fcc->dispatch_list, llnode) {  in issue_flush_thread()
615 		fcc->dispatch_list = NULL;  in issue_flush_thread()
621 		kthread_should_stop() || !llist_empty(&fcc->issue_list));  in issue_flush_thread()
627 	struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info;  in f2fs_issue_flush()  local
635 		atomic_inc(&fcc->queued_flush);  in f2fs_issue_flush()
637 		atomic_dec(&fcc->queued_flush);  in f2fs_issue_flush()
638 		atomic_inc(&fcc->issued_flush);  in f2fs_issue_flush()
642 	if (atomic_inc_return(&fcc->queued_flush) == 1 ||  in f2fs_issue_flush()
645 		atomic_dec(&fcc->queued_flush);  in f2fs_issue_flush()
647 		atomic_inc(&fcc->issued_flush);  in f2fs_issue_flush()
654 	llist_add(&cmd.llnode, &fcc->issue_list);  in f2fs_issue_flush()
659 	if (waitqueue_active(&fcc->flush_wait_queue))  in f2fs_issue_flush()
660 		wake_up(&fcc->flush_wait_queue);  in f2fs_issue_flush()
662 	if (fcc->f2fs_issue_flush) {  in f2fs_issue_flush()
664 		atomic_dec(&fcc->queued_flush);  in f2fs_issue_flush()
668 		list = llist_del_all(&fcc->issue_list);  in f2fs_issue_flush()
671 			atomic_dec(&fcc->queued_flush);  in f2fs_issue_flush()
680 					atomic_dec(&fcc->queued_flush);  in f2fs_issue_flush()
695 	struct flush_cmd_control *fcc;  in f2fs_create_flush_cmd_control()  local
699 		fcc = SM_I(sbi)->fcc_info;  in f2fs_create_flush_cmd_control()
700 		if (fcc->f2fs_issue_flush)  in f2fs_create_flush_cmd_control()
705 	fcc = f2fs_kzalloc(sbi, sizeof(struct flush_cmd_control), GFP_KERNEL);  in f2fs_create_flush_cmd_control()
706 	if (!fcc)  in f2fs_create_flush_cmd_control()
708 	atomic_set(&fcc->issued_flush, 0);  in f2fs_create_flush_cmd_control()
709 	atomic_set(&fcc->queued_flush, 0);  in f2fs_create_flush_cmd_control()
710 	init_waitqueue_head(&fcc->flush_wait_queue);  in f2fs_create_flush_cmd_control()
711 	init_llist_head(&fcc->issue_list);  in f2fs_create_flush_cmd_control()
712 	SM_I(sbi)->fcc_info = fcc;  in f2fs_create_flush_cmd_control()
717 	fcc->f2fs_issue_flush = kthread_run(issue_flush_thread, sbi,  in f2fs_create_flush_cmd_control()
719 	if (IS_ERR(fcc->f2fs_issue_flush)) {  in f2fs_create_flush_cmd_control()
720 		err = PTR_ERR(fcc->f2fs_issue_flush);  in f2fs_create_flush_cmd_control()
721 		kvfree(fcc);  in f2fs_create_flush_cmd_control()
731 	struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info;  in f2fs_destroy_flush_cmd_control()  local
733 	if (fcc && fcc->f2fs_issue_flush) {  in f2fs_destroy_flush_cmd_control()
734 		struct task_struct *flush_thread = fcc->f2fs_issue_flush;  in f2fs_destroy_flush_cmd_control()
736 		fcc->f2fs_issue_flush = NULL;  in f2fs_destroy_flush_cmd_control()
740 		kvfree(fcc);  in f2fs_destroy_flush_cmd_control()