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()
87 static void mcryptd_fini_queue(struct mcryptd_queue *queue) in mcryptd_fini_queue() argument
93 cpu_queue = per_cpu_ptr(queue->cpu_queue, cpu); in mcryptd_fini_queue()
94 BUG_ON(cpu_queue->queue.qlen); in mcryptd_fini_queue()
96 free_percpu(queue->cpu_queue); in mcryptd_fini_queue()
99 static int mcryptd_enqueue_request(struct mcryptd_queue *queue, in mcryptd_enqueue_request() argument
107 cpu_queue = this_cpu_ptr(queue->cpu_queue); in mcryptd_enqueue_request()
110 err = crypto_enqueue_request(&cpu_queue->queue, request); in mcryptd_enqueue_request()
173 backlog = crypto_get_backlog(&cpu_queue->queue); in mcryptd_queue_worker()
174 req = crypto_dequeue_request(&cpu_queue->queue); in mcryptd_queue_worker()
186 if (!cpu_queue->queue.qlen) in mcryptd_queue_worker()
190 if (cpu_queue->queue.qlen) in mcryptd_queue_worker()
225 return ictx->queue; in mcryptd_get_queue()
324 struct mcryptd_queue *queue = in mcryptd_hash_enqueue() local
330 ret = mcryptd_enqueue_request(queue, &req->base, rctx); in mcryptd_hash_enqueue()
491 struct mcryptd_queue *queue) in mcryptd_create_hash() argument
516 ctx->queue = queue; in mcryptd_create_hash()