Lines Matching refs:msg
376 consms_msg_t *msg; in consmsuwput() local
413 if ((msg = consms_mux_find_msg(iocbp->ioc_id)) != NULL) { in consmsuwput()
414 consms_mux_iocdata(msg, mp); in consmsuwput()
531 consms_msg_t *msg; in consmslrput() local
581 if ((msg = consms_mux_find_msg(iocbp->ioc_id)) != NULL) { in consmslrput()
582 consms_mux_ack(msg, mp); in consmslrput()
591 if ((msg = consms_mux_find_msg(copyreq->cq_id)) != NULL) { in consmslrput()
592 consms_mux_copyreq(q, msg, mp); in consmslrput()
991 consms_mux_link_msg(consms_msg_t *msg) in consms_mux_link_msg() argument
994 msg->msg_next = consms_mux_msg; in consms_mux_link_msg()
995 consms_mux_msg = msg; in consms_mux_link_msg()
1002 consms_msg_t *msg; in consms_mux_unlink_msg() local
1007 for (msg = consms_mux_msg; msg != NULL; in consms_mux_unlink_msg()
1008 prev_msg = msg, msg = msg->msg_next) { in consms_mux_unlink_msg()
1009 if (msg->msg_id == msg_id) in consms_mux_unlink_msg()
1013 if (msg != NULL) { in consms_mux_unlink_msg()
1015 prev_msg->msg_next = msg->msg_next; in consms_mux_unlink_msg()
1019 msg->msg_next = NULL; in consms_mux_unlink_msg()
1023 return (msg); in consms_mux_unlink_msg()
1029 consms_msg_t *msg; in consms_mux_find_msg() local
1032 for (msg = consms_mux_msg; msg != NULL; msg = msg->msg_next) { in consms_mux_find_msg()
1033 if (msg->msg_id == msg_id) in consms_mux_find_msg()
1038 return (msg); in consms_mux_find_msg()
1055 consms_mux_ack(consms_msg_t *msg, mblk_t *mp) in consms_mux_ack() argument
1060 msg->msg_num_responses++; in consms_mux_ack()
1072 ASSERT(msg->msg_rsp_list == NULL); in consms_mux_ack()
1073 if (msg->msg_ack_mp == NULL) { in consms_mux_ack()
1074 msg->msg_ack_mp = mp; in consms_mux_ack()
1083 if (msg->msg_num_responses == msg->msg_num_requests) { in consms_mux_ack()
1084 if ((msg->msg_ack_mp == NULL) && in consms_mux_ack()
1085 (msg->msg_rsp_list == NULL)) { in consms_mux_ack()
1091 } else if (msg->msg_rsp_list == NULL) { in consms_mux_ack()
1095 ack_mp = msg->msg_ack_mp; in consms_mux_ack()
1096 consms_mux_cache_states(msg->msg_request); in consms_mux_ack()
1108 ack_mp = msg->msg_rsp_list->rsp_mp; in consms_mux_ack()
1112 qreply(msg->msg_queue, ack_mp); in consms_mux_ack()
1114 if (msg->msg_rsp_list == NULL) { in consms_mux_ack()
1118 if (msg->msg_request) in consms_mux_ack()
1119 freemsg(msg->msg_request); in consms_mux_ack()
1120 (void) consms_mux_unlink_msg(msg->msg_id); in consms_mux_ack()
1121 kmem_free(msg, sizeof (*msg)); in consms_mux_ack()
1141 consms_mux_copyreq(queue_t *q, consms_msg_t *msg, mblk_t *mp) in consms_mux_copyreq() argument
1148 if (msg->msg_rsp_list) { in consms_mux_copyreq()
1149 rsp->rsp_next = msg->msg_rsp_list; in consms_mux_copyreq()
1151 msg->msg_rsp_list = rsp; in consms_mux_copyreq()
1152 msg->msg_num_responses++; in consms_mux_copyreq()
1154 if (msg->msg_num_responses == msg->msg_num_requests) { in consms_mux_copyreq()
1155 consms_mux_max_wheel_report(msg->msg_rsp_list->rsp_mp); in consms_mux_copyreq()
1156 qreply(msg->msg_queue, msg->msg_rsp_list->rsp_mp); in consms_mux_copyreq()
1207 consms_mux_iocdata(consms_msg_t *msg, mblk_t *mp) in consms_mux_iocdata() argument
1215 ASSERT(msg->msg_rsp_list != NULL); in consms_mux_iocdata()
1226 freemsg(msg->msg_request); in consms_mux_iocdata()
1227 msg->msg_request = copymsg(mp); in consms_mux_iocdata()
1233 msg->msg_num_requests = msg->msg_num_responses; in consms_mux_iocdata()
1234 msg->msg_num_responses = 0; in consms_mux_iocdata()
1242 first = msg->msg_rsp_list; in consms_mux_iocdata()
1244 msg->msg_rsp_list = NULL; in consms_mux_iocdata()
1255 msg->msg_num_requests = request_nums; in consms_mux_iocdata()
1344 consms_msg_t *msg; in consms_mux_disp_ioctl() local
1350 msg = (consms_msg_t *)kmem_zalloc(sizeof (*msg), KM_SLEEP); in consms_mux_disp_ioctl()
1351 msg->msg_id = iocp->ioc_id; in consms_mux_disp_ioctl()
1352 msg->msg_request = mp; in consms_mux_disp_ioctl()
1353 msg->msg_queue = q; in consms_mux_disp_ioctl()
1354 msg->msg_num_requests = consms_state.consms_num_lqs; in consms_mux_disp_ioctl()
1355 consms_mux_link_msg(msg); in consms_mux_disp_ioctl()
1368 msg->msg_num_requests--; in consms_mux_disp_ioctl()
1372 if (msg->msg_num_requests <= 0) { in consms_mux_disp_ioctl()
1376 (void) consms_mux_unlink_msg(msg->msg_id); in consms_mux_disp_ioctl()
1377 kmem_free(msg, sizeof (*msg)); in consms_mux_disp_ioctl()