mgt/ibmf/ibmf_msg.c

42 ibmf_i_client_add_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp)
46 	    "ibmf_i_client_add_msg(): clientp = 0x%p, msgp = 0x%p\n",
47 	    tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp);
51 	mutex_enter(&clientp->ic_msg_mutex);
63 		if (clientp->ic_term_msg_list == NULL) {
64 			clientp->ic_term_msg_list = clientp->ic_term_msg_last =
67 			msgimplp->im_msg_prev = clientp->ic_term_msg_last;
68 			clientp->ic_term_msg_last->im_msg_next = msgimplp;
69 			clientp->ic_term_msg_last = msgimplp;
77 		clientp->ic_msgs_active++;
78 		mutex_enter(&clientp->ic_kstat_mutex);
79 		IBMF_ADD32_KSTATS(clientp, msgs_active, 1);
80 		mutex_exit(&clientp->ic_kstat_mutex);
83 		if (clientp->ic_msg_list == NULL) {
84 			clientp->ic_msg_list = clientp->ic_msg_last = msgimplp;
86 			msgimplp->im_msg_prev = clientp->ic_msg_last;
87 			clientp->ic_msg_last->im_msg_next = msgimplp;
88 			clientp->ic_msg_last = msgimplp;
99 	mutex_exit(&clientp->ic_msg_mutex);
117 ibmf_i_client_rem_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
126 	    "ibmf_i_client_rem_msg(): clientp = 0x%p, msgp = 0x%p\n",
127 	    tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp);
129 	mutex_enter(&clientp->ic_msg_mutex);
140 		tmpmsg = clientp->ic_term_msg_list;
152 			clientp->ic_term_msg_last = prevmsg;
159 			clientp->ic_term_msg_list = tmpmsg->im_msg_next;
166 		ASSERT(clientp->ic_msgs_active != 0);
167 		clientp->ic_msgs_active--;
168 		mutex_enter(&clientp->ic_kstat_mutex);
169 		IBMF_SUB32_KSTATS(clientp, msgs_active, 1);
170 		mutex_exit(&clientp->ic_kstat_mutex);
172 		tmpmsg = clientp->ic_msg_list;
184 			clientp->ic_msg_last = prevmsg;
191 			clientp->ic_msg_list = tmpmsg->im_msg_next;
200 	mutex_exit(&clientp->ic_msg_mutex);
215 ibmf_i_find_msg(ibmf_client_t *clientp, uint64_t tid, uint8_t mgt_class,
225 	    "ibmf_i_find_msg(): clientp = 0x%p, tid = 0x%p, mgmt_class = 0x%x, "
226 	    "lid = 0x%x, gidp = 0x%p\n", tnf_opaque, clientp, clientp,
232 	mutex_enter(&clientp->ic_msg_mutex);
235 		msgimplp = clientp->ic_msg_list;
237 		msgimplp = clientp->ic_term_msg_list;
498 	mutex_exit(&clientp->ic_msg_mutex);
520 	    "ibmf_i_find_msg_client(): clientp = 0x%p, msgp = 0x%p\n",
521 	    tnf_opaque, clientp, clp, tnf_opaque, msg, msgimplp);
612 	ibmf_client_t	*clientp = (ibmf_client_t *)msgimplp->im_client;
632 	mutex_enter(&clientp->ic_kstat_mutex);
633 	IBMF_ADD32_KSTATS(clientp, recv_bufs_alloced, 1);
634 	mutex_exit(&clientp->ic_kstat_mutex);