qat/qat_common/qat_comp_algs.c

29 	int (*qat_comp_callback)(struct qat_compression_req *qat_req, void *resp);
49 static int qat_alg_send_dc_message(struct qat_compression_req *qat_req,
53 	struct qat_alg_req *alg_req = &qat_req->alg_req;
55 	alg_req->fw_req = (u32 *)&qat_req->req;
65 	struct qat_compression_req *qat_req =
67 	struct qat_compression_ctx *ctx = qat_req->qat_compression_ctx;
69 	struct qat_request_buffs *qat_bufs = &qat_req->buf;
71 	struct acomp_req *areq = qat_req->acompress_req;
74 	u8 *req = qat_req->req;
82 		qat_req->dir == COMPRESSION ? "comp" : "decomp", dlen);
89 	qat_req->dst.resubmitted = true;
91 	dfbuf = qat_req->buf.bloutp;
94 	ret = qat_alg_send_dc_message(qat_req, inst, &areq->base);
103 static void qat_comp_generic_callback(struct qat_compression_req *qat_req,
106 	struct acomp_req *areq = qat_req->acompress_req;
107 	struct qat_compression_ctx *ctx = qat_req->qat_compression_ctx;
128 		qat_req->dir == COMPRESSION ? "comp  " : "decomp",
134 	if (qat_req->dir == DECOMPRESSION && qat_req->dst.is_null) {
136 			if (qat_req->dst.resubmitted) {
143 			INIT_WORK(&qat_req->resubmit, qat_comp_resubmit);
144 			adf_misc_wq_queue_work(&qat_req->resubmit);
152 	if (qat_req->dir == COMPRESSION) {
160 		if (unlikely(produced > qat_req->actual_dlen)) {
165 				produced, qat_req->actual_dlen);
174 		res = ctx->qat_comp_callback(qat_req, resp);
177 	qat_bl_free_bufl(accel_dev, &qat_req->buf);
183 	struct qat_compression_req *qat_req =
185 	struct qat_instance_backlog *backlog = qat_req->alg_req.backlog;
187 	qat_comp_generic_callback(qat_req, resp);
228 	struct qat_compression_req *qat_req = acomp_request_ctx(areq);
238 	u8 *req = qat_req->req;
251 	qat_req->dst.is_null = false;
259 		qat_req->dst.is_null = true;
268 		qat_req->dst.resubmitted = false;
278 				 &qat_req->buf, &params, f);
282 	sfbuf = qat_req->buf.blp;
283 	dfbuf = qat_req->buf.bloutp;
284 	qat_req->qat_compression_ctx = ctx;
285 	qat_req->acompress_req = areq;
286 	qat_req->dir = dir;
289 		qat_req->actual_dlen = dlen;
294 						(u64)(__force long)qat_req);
299 						  (u64)(__force long)qat_req);
302 	ret = qat_alg_send_dc_message(qat_req, inst, &areq->base);
304 		qat_bl_free_bufl(inst->accel_dev, &qat_req->buf);