Lines Matching refs:cprc
1755 struct ckpt_req_control *cprc = &sbi->cprc_info; in __checkpoint_and_complete_reqs() local
1761 dispatch_list = llist_del_all(&cprc->issue_list); in __checkpoint_and_complete_reqs()
1767 atomic_inc(&cprc->issued_ckpt); in __checkpoint_and_complete_reqs()
1777 atomic_sub(count, &cprc->queued_ckpt); in __checkpoint_and_complete_reqs()
1778 atomic_add(count, &cprc->total_ckpt); in __checkpoint_and_complete_reqs()
1780 spin_lock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1781 cprc->cur_time = (unsigned int)div64_u64(sum_diff, count); in __checkpoint_and_complete_reqs()
1782 if (cprc->peak_time < cprc->cur_time) in __checkpoint_and_complete_reqs()
1783 cprc->peak_time = cprc->cur_time; in __checkpoint_and_complete_reqs()
1784 spin_unlock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1790 struct ckpt_req_control *cprc = &sbi->cprc_info; in issue_checkpoint_thread() local
1791 wait_queue_head_t *q = &cprc->ckpt_wait_queue; in issue_checkpoint_thread()
1796 if (!llist_empty(&cprc->issue_list)) in issue_checkpoint_thread()
1800 kthread_should_stop() || !llist_empty(&cprc->issue_list)); in issue_checkpoint_thread()
1807 struct ckpt_req_control *cprc = &sbi->cprc_info; in flush_remained_ckpt_reqs() local
1809 if (!llist_empty(&cprc->issue_list)) { in flush_remained_ckpt_reqs()
1828 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_issue_checkpoint() local
1843 if (!cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1848 llist_add(&req.llnode, &cprc->issue_list); in f2fs_issue_checkpoint()
1849 atomic_inc(&cprc->queued_ckpt); in f2fs_issue_checkpoint()
1858 if (waitqueue_active(&cprc->ckpt_wait_queue)) in f2fs_issue_checkpoint()
1859 wake_up(&cprc->ckpt_wait_queue); in f2fs_issue_checkpoint()
1861 if (cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1872 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_start_ckpt_thread() local
1874 if (cprc->f2fs_issue_ckpt) in f2fs_start_ckpt_thread()
1877 cprc->f2fs_issue_ckpt = kthread_run(issue_checkpoint_thread, sbi, in f2fs_start_ckpt_thread()
1879 if (IS_ERR(cprc->f2fs_issue_ckpt)) { in f2fs_start_ckpt_thread()
1880 cprc->f2fs_issue_ckpt = NULL; in f2fs_start_ckpt_thread()
1884 set_task_ioprio(cprc->f2fs_issue_ckpt, cprc->ckpt_thread_ioprio); in f2fs_start_ckpt_thread()
1891 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_stop_ckpt_thread() local
1893 if (cprc->f2fs_issue_ckpt) { in f2fs_stop_ckpt_thread()
1894 struct task_struct *ckpt_task = cprc->f2fs_issue_ckpt; in f2fs_stop_ckpt_thread()
1896 cprc->f2fs_issue_ckpt = NULL; in f2fs_stop_ckpt_thread()
1905 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_init_ckpt_req_control() local
1907 atomic_set(&cprc->issued_ckpt, 0); in f2fs_init_ckpt_req_control()
1908 atomic_set(&cprc->total_ckpt, 0); in f2fs_init_ckpt_req_control()
1909 atomic_set(&cprc->queued_ckpt, 0); in f2fs_init_ckpt_req_control()
1910 cprc->ckpt_thread_ioprio = DEFAULT_CHECKPOINT_IOPRIO; in f2fs_init_ckpt_req_control()
1911 init_waitqueue_head(&cprc->ckpt_wait_queue); in f2fs_init_ckpt_req_control()
1912 init_llist_head(&cprc->issue_list); in f2fs_init_ckpt_req_control()
1913 spin_lock_init(&cprc->stat_lock); in f2fs_init_ckpt_req_control()