Lines Matching refs:queue

619 	io = ocf_volume_new_io(ocf_core_get_front_volume(vbdev->ocf_core), qctx->queue, offset, len, dir, 0,
774 /* Poller function for the OCF queue
780 	uint32_t iono = ocf_queue_pending_io(qctx->queue);
784 		ocf_queue_run_single(qctx->queue);
801 /* OCF queue deinitialization
818 /* Queue ops is an interface for running queue thread
819  * stop() operation in called just before queue gets destroyed */
835 	rc = vbdev_ocf_queue_create(vbdev->ocf_cache, &qctx->queue, &queue_ops);
840 	ocf_queue_set_priv(qctx->queue, qctx);
851  * Put OCF queue and relaunch poller with new context to finish pending requests */
860 		ocf_queue_set_priv(qctx->queue, copy);
866 		SPDK_ERRLOG("Unable to stop OCF queue properly: %s\n",
870 	vbdev_ocf_queue_put(qctx->queue);
873 /* OCF management queue deinitialization */
907 /* Queue ops is an interface for running queue thread
908  * stop() operation in called just before queue gets destroyed */