Lines Matching full:fcc

570 	struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info;  in issue_flush_thread()  local
571 wait_queue_head_t *q = &fcc->flush_wait_queue; in issue_flush_thread()
576 if (!llist_empty(&fcc->issue_list)) { in issue_flush_thread()
580 fcc->dispatch_list = llist_del_all(&fcc->issue_list); in issue_flush_thread()
581 fcc->dispatch_list = llist_reverse_order(fcc->dispatch_list); in issue_flush_thread()
583 cmd = llist_entry(fcc->dispatch_list, struct flush_cmd, llnode); in issue_flush_thread()
586 atomic_inc(&fcc->issued_flush); in issue_flush_thread()
589 fcc->dispatch_list, llnode) { in issue_flush_thread()
593 fcc->dispatch_list = NULL; in issue_flush_thread()
597 kthread_should_stop() || !llist_empty(&fcc->issue_list)); in issue_flush_thread()
603 struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info; in f2fs_issue_flush() local
611 atomic_inc(&fcc->queued_flush); in f2fs_issue_flush()
613 atomic_dec(&fcc->queued_flush); in f2fs_issue_flush()
614 atomic_inc(&fcc->issued_flush); in f2fs_issue_flush()
618 if (atomic_inc_return(&fcc->queued_flush) == 1 || in f2fs_issue_flush()
621 atomic_dec(&fcc->queued_flush); in f2fs_issue_flush()
623 atomic_inc(&fcc->issued_flush); in f2fs_issue_flush()
630 llist_add(&cmd.llnode, &fcc->issue_list); in f2fs_issue_flush()
639 if (waitqueue_active(&fcc->flush_wait_queue)) in f2fs_issue_flush()
640 wake_up(&fcc->flush_wait_queue); in f2fs_issue_flush()
642 if (fcc->f2fs_issue_flush) { in f2fs_issue_flush()
644 atomic_dec(&fcc->queued_flush); in f2fs_issue_flush()
648 list = llist_del_all(&fcc->issue_list); in f2fs_issue_flush()
651 atomic_dec(&fcc->queued_flush); in f2fs_issue_flush()
660 atomic_dec(&fcc->queued_flush); in f2fs_issue_flush()
675 struct flush_cmd_control *fcc; in f2fs_create_flush_cmd_control() local
678 fcc = SM_I(sbi)->fcc_info; in f2fs_create_flush_cmd_control()
679 if (fcc->f2fs_issue_flush) in f2fs_create_flush_cmd_control()
684 fcc = f2fs_kzalloc(sbi, sizeof(struct flush_cmd_control), GFP_KERNEL); in f2fs_create_flush_cmd_control()
685 if (!fcc) in f2fs_create_flush_cmd_control()
687 atomic_set(&fcc->issued_flush, 0); in f2fs_create_flush_cmd_control()
688 atomic_set(&fcc->queued_flush, 0); in f2fs_create_flush_cmd_control()
689 init_waitqueue_head(&fcc->flush_wait_queue); in f2fs_create_flush_cmd_control()
690 init_llist_head(&fcc->issue_list); in f2fs_create_flush_cmd_control()
691 SM_I(sbi)->fcc_info = fcc; in f2fs_create_flush_cmd_control()
696 fcc->f2fs_issue_flush = kthread_run(issue_flush_thread, sbi, in f2fs_create_flush_cmd_control()
698 if (IS_ERR(fcc->f2fs_issue_flush)) { in f2fs_create_flush_cmd_control()
699 int err = PTR_ERR(fcc->f2fs_issue_flush); in f2fs_create_flush_cmd_control()
701 fcc->f2fs_issue_flush = NULL; in f2fs_create_flush_cmd_control()
710 struct flush_cmd_control *fcc = SM_I(sbi)->fcc_info; in f2fs_destroy_flush_cmd_control() local
712 if (fcc && fcc->f2fs_issue_flush) { in f2fs_destroy_flush_cmd_control()
713 struct task_struct *flush_thread = fcc->f2fs_issue_flush; in f2fs_destroy_flush_cmd_control()
715 fcc->f2fs_issue_flush = NULL; in f2fs_destroy_flush_cmd_control()
719 kfree(fcc); in f2fs_destroy_flush_cmd_control()