Lines Matching refs:ctrlr
82 struct nvmft_controller *ctrlr; in nvmft_offline() local
87 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_offline()
88 nvmft_printf(ctrlr, in nvmft_offline()
90 nvmft_controller_error(ctrlr, NULL, ENODEV); in nvmft_offline()
102 struct nvmft_controller *ctrlr; in nvmft_info() local
111 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_info()
113 ctrlr->cntlid, ctrlr->hostnqn); in nvmft_info()
126 struct nvmft_controller *ctrlr; in nvmft_lun_enable() local
176 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_lun_enable()
177 nvmft_controller_lun_changed(ctrlr, lun_id); in nvmft_lun_enable()
190 struct nvmft_controller *ctrlr; in nvmft_lun_disable() local
216 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_lun_disable()
217 nvmft_controller_lun_changed(ctrlr, lun_id); in nvmft_lun_disable()
248 struct nvmft_controller *ctrlr = nvmft_qpair_ctrlr(qp); in nvmft_dispatch_command() local
250 struct nvmft_port *np = ctrlr->np; in nvmft_dispatch_command()
261 mtx_lock(&ctrlr->lock); in nvmft_dispatch_command()
262 if (ctrlr->pending_commands == 0) in nvmft_dispatch_command()
263 ctrlr->start_busy = sbinuptime(); in nvmft_dispatch_command()
264 ctrlr->pending_commands++; in nvmft_dispatch_command()
265 mtx_unlock(&ctrlr->lock); in nvmft_dispatch_command()
271 io->io_hdr.nexus.initid = ctrlr->cntlid; in nvmft_dispatch_command()
277 nvmft_printf(ctrlr, "ctl_run failed for command on %s: %d\n", in nvmft_dispatch_command()
283 nvmft_controller_error(ctrlr, qp, ENXIO); in nvmft_dispatch_command()
288 nvmft_terminate_commands(struct nvmft_controller *ctrlr) in nvmft_terminate_commands() argument
290 struct nvmft_port *np = ctrlr->np; in nvmft_terminate_commands()
294 mtx_lock(&ctrlr->lock); in nvmft_terminate_commands()
295 if (ctrlr->pending_commands == 0) in nvmft_terminate_commands()
296 ctrlr->start_busy = sbinuptime(); in nvmft_terminate_commands()
297 ctrlr->pending_commands++; in nvmft_terminate_commands()
298 mtx_unlock(&ctrlr->lock); in nvmft_terminate_commands()
301 NVMFT_QP(io) = ctrlr->admin; in nvmft_terminate_commands()
303 io->io_hdr.nexus.initid = ctrlr->cntlid; in nvmft_terminate_commands()
310 nvmft_printf(ctrlr, "failed to terminate tasks: %d\n", error); in nvmft_terminate_commands()
562 struct nvmft_controller *ctrlr; in nvmft_done() local
574 ctrlr = nvmft_qpair_ctrlr(qp); in nvmft_done()
589 mtx_lock(&ctrlr->lock); in nvmft_done()
590 hip_add(ctrlr->hip.host_write_commands, 1); in nvmft_done()
591 len += ctrlr->partial_duw; in nvmft_done()
593 hip_add(ctrlr->hip.data_units_written, len / 1000); in nvmft_done()
594 ctrlr->partial_duw = len % 1000; in nvmft_done()
595 mtx_unlock(&ctrlr->lock); in nvmft_done()
600 mtx_lock(&ctrlr->lock); in nvmft_done()
602 hip_add(ctrlr->hip.host_read_commands, 1); in nvmft_done()
603 len += ctrlr->partial_dur; in nvmft_done()
605 hip_add(ctrlr->hip.data_units_read, len / 1000); in nvmft_done()
606 ctrlr->partial_dur = len % 1000; in nvmft_done()
607 mtx_unlock(&ctrlr->lock); in nvmft_done()
620 mtx_lock(&ctrlr->lock); in nvmft_done()
621 ctrlr->pending_commands--; in nvmft_done()
622 if (ctrlr->pending_commands == 0) in nvmft_done()
623 ctrlr->busy_total += sbinuptime() - ctrlr->start_busy; in nvmft_done()
624 mtx_unlock(&ctrlr->lock); in nvmft_done()
1076 struct nvmft_controller *ctrlr; in nvmft_list() local
1096 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_list()
1102 ctrlr->cntlid, in nvmft_list()
1103 ctrlr->hostnqn, in nvmft_list()
1105 ctrlr->trtype); in nvmft_list()
1136 struct nvmft_controller *ctrlr; in nvmft_terminate() local
1146 TAILQ_FOREACH(ctrlr, &np->controllers, link) { in nvmft_terminate()
1150 match = tp->cntlid == ctrlr->cntlid; in nvmft_terminate()
1152 match = strncmp(tp->hostnqn, ctrlr->hostnqn, in nvmft_terminate()
1158 nvmft_printf(ctrlr, in nvmft_terminate()
1160 nvmft_controller_error(ctrlr, NULL, ECONNABORTED); in nvmft_terminate()