Lines Matching refs:queue
45 struct mcryptd_queue *queue; member
68 static int mcryptd_init_queue(struct mcryptd_queue *queue, in mcryptd_init_queue() argument
74 queue->cpu_queue = alloc_percpu(struct mcryptd_cpu_queue); in mcryptd_init_queue()
75 pr_debug("mqueue:%p mcryptd_cpu_queue %p\n", queue, queue->cpu_queue); in mcryptd_init_queue()
76 if (!queue->cpu_queue) in mcryptd_init_queue()
79 cpu_queue = per_cpu_ptr(queue->cpu_queue, cpu); in mcryptd_init_queue()
80 pr_debug("cpu_queue #%d %p\n", cpu, queue->cpu_queue); in mcryptd_init_queue()
81 crypto_init_queue(&cpu_queue->queue, max_cpu_qlen); in mcryptd_init_queue()
88 static void mcryptd_fini_queue(struct mcryptd_queue *queue) in mcryptd_fini_queue() argument
94 cpu_queue = per_cpu_ptr(queue->cpu_queue, cpu); in mcryptd_fini_queue()
95 BUG_ON(cpu_queue->queue.qlen); in mcryptd_fini_queue()
97 free_percpu(queue->cpu_queue); in mcryptd_fini_queue()
100 static int mcryptd_enqueue_request(struct mcryptd_queue *queue, in mcryptd_enqueue_request() argument
107 cpu_queue = raw_cpu_ptr(queue->cpu_queue); in mcryptd_enqueue_request()
112 err = crypto_enqueue_request(&cpu_queue->queue, request); in mcryptd_enqueue_request()
171 backlog = crypto_get_backlog(&cpu_queue->queue); in mcryptd_queue_worker()
172 req = crypto_dequeue_request(&cpu_queue->queue); in mcryptd_queue_worker()
183 if (!cpu_queue->queue.qlen) in mcryptd_queue_worker()
187 if (cpu_queue->queue.qlen) in mcryptd_queue_worker()
222 return ictx->queue; in mcryptd_get_queue()
307 struct mcryptd_queue *queue = in mcryptd_hash_enqueue() local
313 ret = mcryptd_enqueue_request(queue, &req->base, rctx); in mcryptd_hash_enqueue()
474 struct mcryptd_queue *queue) in mcryptd_create_hash() argument
495 ctx->queue = queue; in mcryptd_create_hash()