Lines Matching refs:cprc
1746 struct ckpt_req_control *cprc = &sbi->cprc_info; in __checkpoint_and_complete_reqs() local
1752 dispatch_list = llist_del_all(&cprc->issue_list); in __checkpoint_and_complete_reqs()
1758 atomic_inc(&cprc->issued_ckpt); in __checkpoint_and_complete_reqs()
1768 atomic_sub(count, &cprc->queued_ckpt); in __checkpoint_and_complete_reqs()
1769 atomic_add(count, &cprc->total_ckpt); in __checkpoint_and_complete_reqs()
1771 spin_lock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1772 cprc->cur_time = (unsigned int)div64_u64(sum_diff, count); in __checkpoint_and_complete_reqs()
1773 if (cprc->peak_time < cprc->cur_time) in __checkpoint_and_complete_reqs()
1774 cprc->peak_time = cprc->cur_time; in __checkpoint_and_complete_reqs()
1775 spin_unlock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1781 struct ckpt_req_control *cprc = &sbi->cprc_info; in issue_checkpoint_thread() local
1782 wait_queue_head_t *q = &cprc->ckpt_wait_queue; in issue_checkpoint_thread()
1787 if (!llist_empty(&cprc->issue_list)) in issue_checkpoint_thread()
1791 kthread_should_stop() || !llist_empty(&cprc->issue_list)); in issue_checkpoint_thread()
1798 struct ckpt_req_control *cprc = &sbi->cprc_info; in flush_remained_ckpt_reqs() local
1800 if (!llist_empty(&cprc->issue_list)) { in flush_remained_ckpt_reqs()
1819 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_issue_checkpoint() local
1834 if (!cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1839 llist_add(&req.llnode, &cprc->issue_list); in f2fs_issue_checkpoint()
1840 atomic_inc(&cprc->queued_ckpt); in f2fs_issue_checkpoint()
1849 if (waitqueue_active(&cprc->ckpt_wait_queue)) in f2fs_issue_checkpoint()
1850 wake_up(&cprc->ckpt_wait_queue); in f2fs_issue_checkpoint()
1852 if (cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1863 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_start_ckpt_thread() local
1865 if (cprc->f2fs_issue_ckpt) in f2fs_start_ckpt_thread()
1868 cprc->f2fs_issue_ckpt = kthread_run(issue_checkpoint_thread, sbi, in f2fs_start_ckpt_thread()
1870 if (IS_ERR(cprc->f2fs_issue_ckpt)) { in f2fs_start_ckpt_thread()
1871 cprc->f2fs_issue_ckpt = NULL; in f2fs_start_ckpt_thread()
1875 set_task_ioprio(cprc->f2fs_issue_ckpt, cprc->ckpt_thread_ioprio); in f2fs_start_ckpt_thread()
1882 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_stop_ckpt_thread() local
1885 if (!cprc->f2fs_issue_ckpt) in f2fs_stop_ckpt_thread()
1888 ckpt_task = cprc->f2fs_issue_ckpt; in f2fs_stop_ckpt_thread()
1889 cprc->f2fs_issue_ckpt = NULL; in f2fs_stop_ckpt_thread()
1897 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_flush_ckpt_thread() local
1902 while (atomic_read(&cprc->queued_ckpt)) in f2fs_flush_ckpt_thread()
1908 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_init_ckpt_req_control() local
1910 atomic_set(&cprc->issued_ckpt, 0); in f2fs_init_ckpt_req_control()
1911 atomic_set(&cprc->total_ckpt, 0); in f2fs_init_ckpt_req_control()
1912 atomic_set(&cprc->queued_ckpt, 0); in f2fs_init_ckpt_req_control()
1913 cprc->ckpt_thread_ioprio = DEFAULT_CHECKPOINT_IOPRIO; in f2fs_init_ckpt_req_control()
1914 init_waitqueue_head(&cprc->ckpt_wait_queue); in f2fs_init_ckpt_req_control()
1915 init_llist_head(&cprc->issue_list); in f2fs_init_ckpt_req_control()
1916 spin_lock_init(&cprc->stat_lock); in f2fs_init_ckpt_req_control()