nvmf/controller/ctl_frontend_nvmf.c

77 	struct nvmft_controller *ctrlr;
82 	TAILQ_FOREACH(ctrlr, &np->controllers, link) {
83 		nvmft_printf(ctrlr,
85 		nvmft_controller_error(ctrlr, NULL, ENODEV);
97 	struct nvmft_controller *ctrlr;
139 	TAILQ_FOREACH(ctrlr, &np->controllers, link) {
140 		nvmft_controller_lun_changed(ctrlr, lun_id);
153 	struct nvmft_controller *ctrlr;
179 	TAILQ_FOREACH(ctrlr, &np->controllers, link) {
180 		nvmft_controller_lun_changed(ctrlr, lun_id);
211 	struct nvmft_controller *ctrlr = nvmft_qpair_ctrlr(qp);
213 	struct nvmft_port *np = ctrlr->np;
224 	mtx_lock(&ctrlr->lock);
225 	if (ctrlr->pending_commands == 0)
226 		ctrlr->start_busy = sbinuptime();
227 	ctrlr->pending_commands++;
228 	mtx_unlock(&ctrlr->lock);
234 	io->io_hdr.nexus.initid = ctrlr->cntlid;
240 		nvmft_printf(ctrlr, "ctl_run failed for command on %s: %d\n",
246 		nvmft_controller_error(ctrlr, qp, ENXIO);
251 nvmft_terminate_commands(struct nvmft_controller *ctrlr)
253 	struct nvmft_port *np = ctrlr->np;
257 	mtx_lock(&ctrlr->lock);
258 	if (ctrlr->pending_commands == 0)
259 		ctrlr->start_busy = sbinuptime();
260 	ctrlr->pending_commands++;
261 	mtx_unlock(&ctrlr->lock);
264 	NVMFT_QP(io) = ctrlr->admin;
266 	io->io_hdr.nexus.initid = ctrlr->cntlid;
273 		nvmft_printf(ctrlr, "failed to terminate tasks: %d\n", error);
496 	struct nvmft_controller *ctrlr;
508 	ctrlr = nvmft_qpair_ctrlr(qp);
523 		mtx_lock(&ctrlr->lock);
524 		hip_add(ctrlr->hip.host_write_commands, 1);
525 		len += ctrlr->partial_duw;
527 			hip_add(ctrlr->hip.data_units_written, len / 1000);
528 		ctrlr->partial_duw = len % 1000;
529 		mtx_unlock(&ctrlr->lock);
534 		mtx_lock(&ctrlr->lock);
536 			hip_add(ctrlr->hip.host_read_commands, 1);
537 		len += ctrlr->partial_dur;
539 			hip_add(ctrlr->hip.data_units_read, len / 1000);
540 		ctrlr->partial_dur = len % 1000;
541 		mtx_unlock(&ctrlr->lock);
554 	mtx_lock(&ctrlr->lock);
555 	ctrlr->pending_commands--;
556 	if (ctrlr->pending_commands == 0)
557 		ctrlr->busy_total += sbinuptime() - ctrlr->start_busy;
558 	mtx_unlock(&ctrlr->lock);
963 	struct nvmft_controller *ctrlr;
983 		TAILQ_FOREACH(ctrlr, &np->controllers, link) {
989 			    ctrlr->cntlid,
990 			    ctrlr->hostnqn,
992 			    ctrlr->trtype);
1023 	struct nvmft_controller *ctrlr;
1033 		TAILQ_FOREACH(ctrlr, &np->controllers, link) {
1037 				match = tp->cntlid == ctrlr->cntlid;
1039 				match = strncmp(tp->hostnqn, ctrlr->hostnqn,
1045 			nvmft_printf(ctrlr,
1047 			nvmft_controller_error(ctrlr, NULL, ECONNABORTED);