Lines Matching refs:cprc

1810 	struct ckpt_req_control *cprc = &sbi->cprc_info;  in __checkpoint_and_complete_reqs()  local
1816 dispatch_list = llist_del_all(&cprc->issue_list); in __checkpoint_and_complete_reqs()
1822 atomic_inc(&cprc->issued_ckpt); in __checkpoint_and_complete_reqs()
1833 atomic_sub(count, &cprc->queued_ckpt); in __checkpoint_and_complete_reqs()
1834 atomic_add(count, &cprc->total_ckpt); in __checkpoint_and_complete_reqs()
1836 spin_lock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1837 cprc->cur_time = (unsigned int)div64_u64(sum_diff, count); in __checkpoint_and_complete_reqs()
1838 if (cprc->peak_time < cprc->cur_time) in __checkpoint_and_complete_reqs()
1839 cprc->peak_time = cprc->cur_time; in __checkpoint_and_complete_reqs()
1840 spin_unlock(&cprc->stat_lock); in __checkpoint_and_complete_reqs()
1846 struct ckpt_req_control *cprc = &sbi->cprc_info; in issue_checkpoint_thread() local
1847 wait_queue_head_t *q = &cprc->ckpt_wait_queue; in issue_checkpoint_thread()
1852 if (!llist_empty(&cprc->issue_list)) in issue_checkpoint_thread()
1856 kthread_should_stop() || !llist_empty(&cprc->issue_list)); in issue_checkpoint_thread()
1863 struct ckpt_req_control *cprc = &sbi->cprc_info; in flush_remained_ckpt_reqs() local
1865 if (!llist_empty(&cprc->issue_list)) { in flush_remained_ckpt_reqs()
1884 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_issue_checkpoint() local
1900 if (!cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1905 llist_add(&req.llnode, &cprc->issue_list); in f2fs_issue_checkpoint()
1906 atomic_inc(&cprc->queued_ckpt); in f2fs_issue_checkpoint()
1915 if (waitqueue_active(&cprc->ckpt_wait_queue)) in f2fs_issue_checkpoint()
1916 wake_up(&cprc->ckpt_wait_queue); in f2fs_issue_checkpoint()
1918 if (cprc->f2fs_issue_ckpt) in f2fs_issue_checkpoint()
1925 "blocked on checkpoint for %u ms", cprc->peak_time); in f2fs_issue_checkpoint()
1935 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_start_ckpt_thread() local
1937 if (cprc->f2fs_issue_ckpt) in f2fs_start_ckpt_thread()
1940 cprc->f2fs_issue_ckpt = kthread_run(issue_checkpoint_thread, sbi, in f2fs_start_ckpt_thread()
1942 if (IS_ERR(cprc->f2fs_issue_ckpt)) { in f2fs_start_ckpt_thread()
1943 int err = PTR_ERR(cprc->f2fs_issue_ckpt); in f2fs_start_ckpt_thread()
1945 cprc->f2fs_issue_ckpt = NULL; in f2fs_start_ckpt_thread()
1949 set_task_ioprio(cprc->f2fs_issue_ckpt, cprc->ckpt_thread_ioprio); in f2fs_start_ckpt_thread()
1956 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_stop_ckpt_thread() local
1959 if (!cprc->f2fs_issue_ckpt) in f2fs_stop_ckpt_thread()
1962 ckpt_task = cprc->f2fs_issue_ckpt; in f2fs_stop_ckpt_thread()
1963 cprc->f2fs_issue_ckpt = NULL; in f2fs_stop_ckpt_thread()
1971 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_flush_ckpt_thread() local
1976 while (atomic_read(&cprc->queued_ckpt)) in f2fs_flush_ckpt_thread()
1982 struct ckpt_req_control *cprc = &sbi->cprc_info; in f2fs_init_ckpt_req_control() local
1984 atomic_set(&cprc->issued_ckpt, 0); in f2fs_init_ckpt_req_control()
1985 atomic_set(&cprc->total_ckpt, 0); in f2fs_init_ckpt_req_control()
1986 atomic_set(&cprc->queued_ckpt, 0); in f2fs_init_ckpt_req_control()
1987 cprc->ckpt_thread_ioprio = DEFAULT_CHECKPOINT_IOPRIO; in f2fs_init_ckpt_req_control()
1988 init_waitqueue_head(&cprc->ckpt_wait_queue); in f2fs_init_ckpt_req_control()
1989 init_llist_head(&cprc->issue_list); in f2fs_init_ckpt_req_control()
1990 spin_lock_init(&cprc->stat_lock); in f2fs_init_ckpt_req_control()