struct lnet_handle_md *md_handle_out);
int LNetMDUnlink(struct lnet_handle_md md_in);
+
+void lnet_assert_handler_unused(lnet_handler_t handler);
/** @} lnet_md */
/** \defgroup lnet_data Data movement operations
the_lnet.ln_mt_zombie_rstqs = NULL;
}
+ lnet_assert_handler_unused(the_lnet.ln_mt_handler);
the_lnet.ln_mt_handler = NULL;
lnet_portals_destroy();
lnet_ping_md_unlink(the_lnet.ln_ping_target,
&the_lnet.ln_ping_target_md);
+ lnet_assert_handler_unused(the_lnet.ln_ping_target_handler);
lnet_ping_target_destroy();
}
the_lnet.ln_push_target_nnis = 0;
LNetClearLazyPortal(LNET_RESERVED_PORTAL);
+ lnet_assert_handler_unused(the_lnet.ln_push_target_handler);
the_lnet.ln_push_target_handler = NULL;
}
return 0;
}
+void lnet_assert_handler_unused(lnet_handler_t handler)
+{
+ struct lnet_res_container *container;
+ int cpt;
+
+ if (!handler)
+ return;
+ cfs_percpt_for_each(container, cpt, the_lnet.ln_md_containers) {
+ struct lnet_libmd *md;
+
+ lnet_res_lock(cpt);
+ list_for_each_entry(md, &container->rec_active, md_list)
+ LASSERT(md->md_handler != handler);
+ lnet_res_unlock(cpt);
+ }
+}
+EXPORT_SYMBOL(lnet_assert_handler_unused);
+
/* must be called with lnet_res_lock held */
void
lnet_md_deconstruct(struct lnet_libmd *lmd, struct lnet_event *ev)
}
lnet_net_unlock(LNET_LOCK_EX);
+ lnet_assert_handler_unused(the_lnet.ln_dc_handler);
the_lnet.ln_dc_handler = NULL;
the_lnet.ln_dc_state = LNET_DC_STATE_SHUTDOWN;
rc = LNetClearLazyPortal(SRPC_FRAMEWORK_REQUEST_PORTAL);
rc = LNetClearLazyPortal(SRPC_REQUEST_PORTAL);
LASSERT(rc == 0);
+ lnet_assert_handler_unused(srpc_data.rpc_lnet_handler);
/* fallthrough */
case SRPC_STATE_NI_INIT:
percpu_ref_kill(&ptlrpc_pending);
wait_for_completion(&ptlrpc_done);
+ lnet_assert_handler_unused(ptlrpc_handler);
LNetNIFini();
}