Lines Matching defs:process_req

2724 raid_bdev_process_request_complete(struct raid_bdev_process_request *process_req, int status)
2726 	struct raid_bdev_process *process = process_req->process;
2728 	TAILQ_INSERT_TAIL(&process->requests, process_req, link);
2731 	assert(process->window_remaining >= process_req->num_blocks);
2737 	process->window_remaining -= process_req->num_blocks;
2754 	struct raid_bdev_process_request *process_req;
2757 	process_req = TAILQ_FIRST(&process->requests);
2758 	if (process_req == NULL) {
2763 	process_req->target = process->target;
2764 	process_req->target_ch = process->raid_ch->process.target_ch;
2765 	process_req->offset_blocks = offset_blocks;
2766 	process_req->num_blocks = num_blocks;
2767 	process_req->iov.iov_len = num_blocks * raid_bdev->bdev.blocklen;
2769 	ret = raid_bdev->module->submit_process_request(process_req, process->raid_ch);
2779 	process_req->num_blocks = ret;
2780 	TAILQ_REMOVE(&process->requests, process_req, link);
3030 raid_bdev_process_request_free(struct raid_bdev_process_request *process_req)
3032 	spdk_dma_free(process_req->iov.iov_base);
3033 	spdk_dma_free(process_req->md_buf);
3034 	free(process_req);
3041 	struct raid_bdev_process_request *process_req;
3043 	process_req = calloc(1, sizeof(*process_req));
3044 	if (process_req == NULL) {
3048 	process_req->process = process;
3049 	process_req->iov.iov_len = process->max_window_size * raid_bdev->bdev.blocklen;
3050 	process_req->iov.iov_base = spdk_dma_malloc(process_req->iov.iov_len, 4096, 0);
3051 	if (process_req->iov.iov_base == NULL) {
3052 		free(process_req);
3056 		process_req->md_buf = spdk_dma_malloc(process->max_window_size * raid_bdev->bdev.md_len, 4096, 0);
3057 		if (process_req->md_buf == NULL) {
3058 			raid_bdev_process_request_free(process_req);
3063 	return process_req;
3069 	struct raid_bdev_process_request *process_req;
3071 	while ((process_req = TAILQ_FIRST(&process->requests)) != NULL) {
3072 		TAILQ_REMOVE(&process->requests, process_req, link);
3073 		raid_bdev_process_request_free(process_req);
3084 	struct raid_bdev_process_request *process_req;
3111 		process_req = raid_bdev_process_alloc_request(process);
3112 		if (process_req == NULL) {
3117 		TAILQ_INSERT_TAIL(&process->requests, process_req, link);