lib/libnvmf/nvmf_controller.c

43 nvmf_controller_receive_capsule(struct nvmf_qpair *qp,
51 	error = nvmf_receive_capsule(qp, &nc);
69 	struct nvmf_qpair *qp = nc->nc_qpair;
72 	if (qp->nq_flow_control) {
73 		qp->nq_sqhd = (qp->nq_sqhd + 1) % qp->nq_qsize;
74 		nc->nc_cqe.sqhd = htole16(qp->nq_sqhd);
143 	struct nvmf_qpair *qp;
150 	qp = NULL;
160 	qp = nvmf_allocate_qpair(na, params);
161 	if (qp == NULL)
165 	error = nvmf_receive_capsule(qp, &cc);
208 		qp->nq_admin = true;
236 		qp->nq_admin = false;
238 	qp->nq_qsize = qsize;
316 		qp->nq_flow_control = true;
318 		qp->nq_flow_control = false;
319 	qp->nq_sqhd = 0;
320 	qp->nq_kato = le32toh(cmd->kato);
322 	return (qp);
330 	if (qp != NULL)
331 		nvmf_free_qpair(qp);
339 	struct nvmf_qpair *qp = cc->nc_qpair;
344 	if (qp->nq_flow_control)
345 		rsp.sqhd = htole16(qp->nq_sqhd);
349 	rc = nvmf_allocate_response(qp, &rsp);
355 		qp->nq_cntlid = cntlid;
360 nvmf_controller_cap(struct nvmf_qpair *qp)
362 	const struct nvmf_association *na = qp->nq_association;
369 nvmf_validate_cc(struct nvmf_qpair *qp, uint64_t cap, uint32_t old_cc,
372 	const struct nvmf_association *na = qp->nq_association;
379 nvmf_init_discovery_controller_data(struct nvmf_qpair *qp,
382 	const struct nvmf_association *na = qp->nq_association;
400 	cdata->ctrlr_id = htole16(qp->nq_cntlid);
419 nvmf_init_io_controller_data(struct nvmf_qpair *qp, const char *serial,
423 	const struct nvmf_association *na = qp->nq_association;
428 	_nvmf_init_io_controller_data(qp->nq_cntlid, na->na_params.max_io_qsize,
458 nvmf_handoff_controller_qpair(struct nvmf_qpair *qp,
461 	h->trtype = qp->nq_association->na_trtype;
462 	return (nvmf_kernel_handoff_params(qp, &h->params));