mgt/ibmf/ibmf.c

32 #define	IBMF_SET_CLIENT_SIGNATURE(clientp) {			\
33 		(clientp)->ic_client_sig = (void *)0xf00DdEaD;	\
36 #define	IBMF_VERIFY_CLIENT_SIGNATURE(clientp)			\
37 	(((clientp) != NULL && (clientp)->ic_client_sig ==	\
205 	/* Setup ibmf_handlep -- handle is last allocated clientp */
228 	ibmf_client_t	*clientp;
234 	clientp = (ibmf_client_t *)*ibmf_handlep;
259 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
272 	mutex_enter(&clientp->ic_mutex);
273 	while (clientp->ic_recv_cb == NULL && clientp->ic_msgs_alloced != 0 &&
275 		mutex_exit(&clientp->ic_mutex);
278 		mutex_enter(&clientp->ic_mutex);
281 	if (clientp->ic_recv_cb != NULL || clientp->ic_msgs_alloced != 0) {
287 		    clientp->ic_flags, tnf_opaque, recv_cb, clientp->ic_recv_cb,
288 		    tnf_uint, msgs_allocd, clientp->ic_msgs_alloced);
291 		mutex_exit(&clientp->ic_mutex);
295 	mutex_exit(&clientp->ic_mutex);
297 	cip = clientp->ic_myci;
300 	ibmf_i_delete_client(cip, clientp);
303 	ibmf_i_release_qp(cip, &clientp->ic_qp);
305 	_NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*clientp))
308 	ibmf_i_free_client(clientp);
339 	ibmf_client_t	*clientp;
344 	clientp = (ibmf_client_t *)ibmf_handle;
380 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
387 	ASSERT(clientp->ic_myci != NULL);
396 		mutex_enter(&clientp->ic_mutex);
399 		if (clientp->ic_recv_cb != NULL) {
400 			mutex_exit(&clientp->ic_mutex);
407 		clientp->ic_recv_cb = async_msg_cb;
408 		clientp->ic_recv_cb_arg = async_msg_cb_args;
409 		mutex_exit(&clientp->ic_mutex);
455 	ibmf_client_t	*clientp;
460 	clientp = (ibmf_client_t *)ibmf_handle;
495 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
502 	ASSERT(clientp->ic_myci != NULL);
507 		mutex_enter(&clientp->ic_mutex);
510 		if (clientp->ic_recv_cb == NULL) {
511 			mutex_exit(&clientp->ic_mutex);
522 		while (clientp->ic_flags & IBMF_CLIENT_RECV_CB_ACTIVE) {
523 			clientp->ic_flags |= IBMF_CLIENT_TEAR_DOWN_CB;
524 			cv_wait(&clientp->ic_recv_cb_teardown_cv,
525 			    &clientp->ic_mutex);
526 			clientp->ic_flags &= ~IBMF_CLIENT_TEAR_DOWN_CB;
529 		_NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(clientp->ic_recv_cb,
530 		     clientp->ic_recv_cb_arg))
536 		clientp->ic_recv_cb = NULL;
537 		clientp->ic_recv_cb_arg = NULL;
539 		ASSERT((clientp->ic_flags & IBMF_CLIENT_RECV_CB_ACTIVE) == 0);
541 		mutex_exit(&clientp->ic_mutex);
597 	ibmf_client_t	*clientp;
603 	clientp = (ibmf_client_t *)ibmf_handle;
628 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
649 	status = ibmf_i_alloc_msg(clientp, &ibmf_msg_impl, km_flags);
651 		mutex_enter(&clientp->ic_kstat_mutex);
652 		IBMF_ADD32_KSTATS(clientp, msg_allocs_failed, 1);
653 		mutex_exit(&clientp->ic_kstat_mutex);
660 	mutex_enter(&clientp->ic_mutex);
661 	clientp->ic_msgs_alloced++;
662 	mutex_exit(&clientp->ic_mutex);
663 	mutex_enter(&clientp->ic_kstat_mutex);
664 	IBMF_ADD32_KSTATS(clientp, msgs_alloced, 1);
665 	mutex_exit(&clientp->ic_kstat_mutex);
668 	ibmf_msg_impl->im_client = clientp;
692 	ibmf_client_t	*clientp;
776 	clientp = (ibmf_client_t *)ibmf_handle;
779 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
807 	mutex_enter(&clientp->ic_mutex);
808 	clientp->ic_msgs_alloced--;
809 	mutex_exit(&clientp->ic_mutex);
810 	mutex_enter(&clientp->ic_kstat_mutex);
811 	IBMF_SUB32_KSTATS(clientp, msgs_alloced, 1);
812 	mutex_exit(&clientp->ic_kstat_mutex);
843 	ibmf_client_t	*clientp;
886 	clientp = (ibmf_client_t *)ibmf_handle;
889 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
903 	    ((clientp->ic_client_info.client_class != SUBN_AGENT) &&
904 	    (clientp->ic_client_info.client_class != SUBN_ADM_AGENT) &&
905 	    (clientp->ic_client_info.client_class != SUBN_MANAGER))) {
953 	ASSERT(msgimplp->im_client == clientp);
1050 	status = ibmf_i_msg_transport(clientp, ibmf_qp_handle, msgimplp,
1080 	ibmf_client_t	*clientp = (ibmf_client_t *)ibmf_handle;
1111 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
1138 	status = ibmf_i_alloc_qp(clientp, p_key, q_key, alloc_flags,
1141 		mutex_enter(&clientp->ic_kstat_mutex);
1142 		IBMF_ADD32_KSTATS(clientp, alt_qp_allocs_failed, 1);
1143 		mutex_exit(&clientp->ic_kstat_mutex);
1189 	ibmf_client_t	*clientp = (ibmf_client_t *)ibmf_handle;
1239 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
1247 	if (qp_ctx->isq_client_hdl != clientp) {
1286 	ibmf_client_t	*clientp = (ibmf_client_t *)ibmf_handle;
1335 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
1350 	if (qp_ctx->isq_client_hdl != clientp) {
1385 	ibmf_client_t	*clientp = (ibmf_client_t *)ibmf_handle;
1433 	if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) {
1441 	if (qp_ctx->isq_client_hdl != clientp) {