Lines Matching refs:cprc
2020 struct ckpt_req_control *cprc = &sbi->cprc_info; in __checkpoint_and_complete_reqs() local
2026 dispatch_list = llist_del_all(&cprc->issue_list); in __checkpoint_and_complete_reqs()
2032 atomic_inc(&cprc->issued_ckpt); in __checkpoint_and_complete_reqs()
2043 atomic_sub(count, &cprc->queued_ckpt); in __checkpoint_and_complete_reqs()
2044 atomic_add(count, &cprc->total_ckpt); in __checkpoint_and_complete_reqs()
2046 spin_lock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
2047 cprc->cur_time = (unsigned int)div64_u64(sum_diff, count); in __checkpoint_and_complete_reqs()
2048 if (cprc->peak_time < cprc->cur_time) in __checkpoint_and_complete_reqs()
2049 cprc->peak_time = cprc->cur_time; in __checkpoint_and_complete_reqs()
2050 spin_unlock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
2056 struct ckpt_req_control *cprc = &sbi->cprc_info; in issue_checkpoint_thread() local
2057 wait_queue_head_t *q = &cprc->ckpt_wait_queue; in issue_checkpoint_thread()
2062 if (!llist_empty(&cprc->issue_list)) in issue_checkpoint_thread()
2066 kthread_should_stop() || !llist_empty(&cprc->issue_list)); in issue_checkpoint_thread()
2073 struct ckpt_req_control *cprc = &sbi->cprc_info; in flush_remained_ckpt_reqs() local
2075 if (!llist_empty(&cprc->issue_list)) { in flush_remained_ckpt_reqs()
2094 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_issue_checkpoint() local
2111 if (!cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
2116 llist_add(&req.llnode, &cprc->issue_list); in f2fs_issue_checkpoint()
2117 atomic_inc(&cprc->queued_ckpt); in f2fs_issue_checkpoint()
2126 if (waitqueue_active(&cprc->ckpt_wait_queue)) in f2fs_issue_checkpoint()
2127 wake_up(&cprc->ckpt_wait_queue); in f2fs_issue_checkpoint()
2129 if (cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
2136 "blocked on checkpoint for %u ms", cprc->peak_time); in f2fs_issue_checkpoint()
2146 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_start_ckpt_thread() local
2148 if (cprc->f2fs_issue_ckpt) in f2fs_start_ckpt_thread()
2151 cprc->f2fs_issue_ckpt = kthread_run(issue_checkpoint_thread, sbi, in f2fs_start_ckpt_thread()
2153 if (IS_ERR(cprc->f2fs_issue_ckpt)) { in f2fs_start_ckpt_thread()
2154 int err = PTR_ERR(cprc->f2fs_issue_ckpt); in f2fs_start_ckpt_thread()
2156 cprc->f2fs_issue_ckpt = NULL; in f2fs_start_ckpt_thread()
2160 set_task_ioprio(cprc->f2fs_issue_ckpt, cprc->ckpt_thread_ioprio); in f2fs_start_ckpt_thread()
2161 set_user_nice(cprc->f2fs_issue_ckpt, in f2fs_start_ckpt_thread()
2169 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_stop_ckpt_thread() local
2172 if (!cprc->f2fs_issue_ckpt) in f2fs_stop_ckpt_thread()
2175 ckpt_task = cprc->f2fs_issue_ckpt; in f2fs_stop_ckpt_thread()
2176 cprc->f2fs_issue_ckpt = NULL; in f2fs_stop_ckpt_thread()
2184 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_flush_ckpt_thread() local
2189 while (atomic_read(&cprc->queued_ckpt)) in f2fs_flush_ckpt_thread()
2195 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_init_ckpt_req_control() local
2197 atomic_set(&cprc->issued_ckpt, 0); in f2fs_init_ckpt_req_control()
2198 atomic_set(&cprc->total_ckpt, 0); in f2fs_init_ckpt_req_control()
2199 atomic_set(&cprc->queued_ckpt, 0); in f2fs_init_ckpt_req_control()
2200 cprc->ckpt_thread_ioprio = DEFAULT_CHECKPOINT_IOPRIO; in f2fs_init_ckpt_req_control()
2201 init_waitqueue_head(&cprc->ckpt_wait_queue); in f2fs_init_ckpt_req_control()
2202 init_llist_head(&cprc->issue_list); in f2fs_init_ckpt_req_control()
2203 spin_lock_init(&cprc->stat_lock); in f2fs_init_ckpt_req_control()