Lines Matching refs:log_mgr
90 struct nvmet_pr_log_mgr *log_mgr = &req->sq->ctrl->pr_log_mgr; in nvmet_execute_get_log_page_resv() local
98 mutex_lock(&log_mgr->lock); in nvmet_execute_get_log_page_resv()
99 if (!kfifo_get(&log_mgr->log_queue, &log)) in nvmet_execute_get_log_page_resv()
110 if (kfifo_peek(&log_mgr->log_queue, &next_log)) { in nvmet_execute_get_log_page_resv()
117 lost_count = log_mgr->lost_count; in nvmet_execute_get_log_page_resv()
122 log_mgr->lost_count -= lost_count; in nvmet_execute_get_log_page_resv()
124 log.nr_pages = kfifo_len(&log_mgr->log_queue); in nvmet_execute_get_log_page_resv()
128 mutex_unlock(&log_mgr->lock); in nvmet_execute_get_log_page_resv()
135 struct nvmet_pr_log_mgr *log_mgr = &ctrl->pr_log_mgr; in nvmet_pr_add_resv_log() local
138 mutex_lock(&log_mgr->lock); in nvmet_pr_add_resv_log()
139 log_mgr->counter++; in nvmet_pr_add_resv_log()
140 if (log_mgr->counter == 0) in nvmet_pr_add_resv_log()
141 log_mgr->counter = 1; in nvmet_pr_add_resv_log()
143 log.count = cpu_to_le64(log_mgr->counter); in nvmet_pr_add_resv_log()
147 if (!kfifo_put(&log_mgr->log_queue, log)) { in nvmet_pr_add_resv_log()
150 log_mgr->lost_count++; in nvmet_pr_add_resv_log()
153 mutex_unlock(&log_mgr->lock); in nvmet_pr_add_resv_log()