Lines Matching defs:active_proc
240 struct spdk_nvme_ctrlr_process *active_proc;
243 active_proc = nvme_ctrlr_get_current_process(ctrlr);
244 if (active_proc) {
245 TAILQ_INSERT_TAIL(&active_proc->allocated_io_qpairs, qpair, per_process_tailq);
246 qpair->active_proc = active_proc;
257 struct spdk_nvme_ctrlr_process *active_proc;
261 active_proc = nvme_ctrlr_get_current_process(ctrlr);
262 if (!active_proc) {
266 TAILQ_FOREACH_SAFE(active_qpair, &active_proc->allocated_io_qpairs,
269 TAILQ_REMOVE(&active_proc->allocated_io_qpairs,
620 if (qpair->poll_group && (qpair->active_proc == nvme_ctrlr_get_current_process(ctrlr))) {
632 if (qpair->active_proc == nvme_ctrlr_get_current_process(ctrlr)) {
1795 if (nvme_ctrlr_get_current_process(ctrlr) != qpair->active_proc ||
1849 if (nvme_ctrlr_get_current_process(ctrlr) != qpair->active_proc) {
3262 struct spdk_nvme_ctrlr_process *active_proc;
3291 active_proc = nvme_ctrlr_get_current_process(ctrlr);
3292 if (active_proc && active_proc->aer_cb_fn) {
3293 active_proc->aer_cb_fn(active_proc->aer_cb_arg, cpl);
3322 struct spdk_nvme_ctrlr_process *active_proc;
3324 active_proc = nvme_ctrlr_get_current_process(ctrlr);
3326 STAILQ_FOREACH_SAFE(nvme_event, &active_proc->async_events, link, nvme_event_tmp) {
3327 STAILQ_REMOVE(&active_proc->async_events, nvme_event,
3480 struct spdk_nvme_ctrlr_process *active_proc;
3482 TAILQ_FOREACH(active_proc, &ctrlr->active_procs, tailq) {
3483 if (active_proc->pid == pid) {
3484 return active_proc;
3615 struct spdk_nvme_ctrlr_process *active_proc, *tmp;
3618 TAILQ_FOREACH_SAFE(active_proc, &ctrlr->active_procs, tailq, tmp) {
3619 TAILQ_REMOVE(&ctrlr->active_procs, active_proc, tailq);
3621 assert(STAILQ_EMPTY(&active_proc->active_reqs));
3623 spdk_free(active_proc);
3636 struct spdk_nvme_ctrlr_process *active_proc, *tmp;
3639 TAILQ_FOREACH_SAFE(active_proc, &ctrlr->active_procs, tailq, tmp) {
3640 if ((kill(active_proc->pid, 0) == -1) && (errno == ESRCH)) {
3641 NVME_CTRLR_ERRLOG(ctrlr, "process %d terminated unexpected\n", active_proc->pid);
3643 TAILQ_REMOVE(&ctrlr->active_procs, active_proc, tailq);
3645 nvme_ctrlr_cleanup_process(active_proc);
3657 struct spdk_nvme_ctrlr_process *active_proc;
3663 active_proc = nvme_ctrlr_get_current_process(ctrlr);
3664 if (active_proc) {
3665 active_proc->ref++;
3674 struct spdk_nvme_ctrlr_process *active_proc;
3681 active_proc = nvme_ctrlr_get_current_process(ctrlr);
3682 if (active_proc) {
3683 active_proc->ref--;
3684 assert(active_proc->ref >= 0);
3690 if (active_proc->ref == 0 && proc_count != 1) {
3691 nvme_ctrlr_remove_process(ctrlr, active_proc);
3701 struct spdk_nvme_ctrlr_process *active_proc;
3708 TAILQ_FOREACH(active_proc, &ctrlr->active_procs, tailq) {
3709 ref += active_proc->ref;
3723 struct spdk_nvme_ctrlr_process *active_proc;
3728 active_proc = nvme_ctrlr_get_current_process(ctrlr);
3729 if (active_proc) {
3730 devhandle = active_proc->devhandle;
4531 struct spdk_nvme_ctrlr_process *active_proc;
4553 active_proc = nvme_ctrlr_get_current_process(ctrlr);
4554 if (active_proc) {
4796 struct spdk_nvme_ctrlr_process *active_proc;
4800 active_proc = nvme_ctrlr_get_current_process(ctrlr);
4801 if (active_proc) {
4802 active_proc->aer_cb_fn = aer_cb_fn;
4803 active_proc->aer_cb_arg = aer_cb_arg;
4820 struct spdk_nvme_ctrlr_process *active_proc;
4824 active_proc = nvme_ctrlr_get_current_process(ctrlr);
4825 if (active_proc) {
4826 active_proc->timeout_io_ticks = timeout_io_us * spdk_get_ticks_hz() / 1000000ULL;
4827 active_proc->timeout_admin_ticks = timeout_admin_us * spdk_get_ticks_hz() / 1000000ULL;
4828 active_proc->timeout_cb_fn = cb_fn;
4829 active_proc->timeout_cb_arg = cb_arg;