Lines Matching refs:msg
271 xpc_send_gru_msg(unsigned long mq_gpa, void *msg, size_t msg_size) in xpc_send_gru_msg() argument
277 ret = gru_send_message_gpa(mq_gpa, msg, msg_size); in xpc_send_gru_msg()
373 struct xpc_activate_mq_msg_heartbeat_req_uv *msg; in xpc_handle_activate_mq_msg_uv() local
375 msg = container_of(msg_hdr, in xpc_handle_activate_mq_msg_uv()
378 part_uv->heartbeat = msg->heartbeat; in xpc_handle_activate_mq_msg_uv()
382 struct xpc_activate_mq_msg_heartbeat_req_uv *msg; in xpc_handle_activate_mq_msg_uv() local
384 msg = container_of(msg_hdr, in xpc_handle_activate_mq_msg_uv()
387 part_uv->heartbeat = msg->heartbeat; in xpc_handle_activate_mq_msg_uv()
395 struct xpc_activate_mq_msg_heartbeat_req_uv *msg; in xpc_handle_activate_mq_msg_uv() local
397 msg = container_of(msg_hdr, in xpc_handle_activate_mq_msg_uv()
400 part_uv->heartbeat = msg->heartbeat; in xpc_handle_activate_mq_msg_uv()
408 struct xpc_activate_mq_msg_activate_req_uv *msg; in xpc_handle_activate_mq_msg_uv() local
415 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
422 part->remote_rp_pa = msg->rp_gpa; /* !!! _pa is _gpa */ in xpc_handle_activate_mq_msg_uv()
424 part_uv->remote_activate_mq_gpa = msg->activate_mq_gpa; in xpc_handle_activate_mq_msg_uv()
431 struct xpc_activate_mq_msg_deactivate_req_uv *msg; in xpc_handle_activate_mq_msg_uv() local
433 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
440 part_uv->reason = msg->reason; in xpc_handle_activate_mq_msg_uv()
447 struct xpc_activate_mq_msg_chctl_closerequest_uv *msg; in xpc_handle_activate_mq_msg_uv() local
449 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
452 args = &part->remote_openclose_args[msg->ch_number]; in xpc_handle_activate_mq_msg_uv()
453 args->reason = msg->reason; in xpc_handle_activate_mq_msg_uv()
456 part->chctl.flags[msg->ch_number] |= XPC_CHCTL_CLOSEREQUEST; in xpc_handle_activate_mq_msg_uv()
463 struct xpc_activate_mq_msg_chctl_closereply_uv *msg; in xpc_handle_activate_mq_msg_uv() local
465 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
470 part->chctl.flags[msg->ch_number] |= XPC_CHCTL_CLOSEREPLY; in xpc_handle_activate_mq_msg_uv()
477 struct xpc_activate_mq_msg_chctl_openrequest_uv *msg; in xpc_handle_activate_mq_msg_uv() local
479 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
482 args = &part->remote_openclose_args[msg->ch_number]; in xpc_handle_activate_mq_msg_uv()
483 args->entry_size = msg->entry_size; in xpc_handle_activate_mq_msg_uv()
484 args->local_nentries = msg->local_nentries; in xpc_handle_activate_mq_msg_uv()
487 part->chctl.flags[msg->ch_number] |= XPC_CHCTL_OPENREQUEST; in xpc_handle_activate_mq_msg_uv()
494 struct xpc_activate_mq_msg_chctl_openreply_uv *msg; in xpc_handle_activate_mq_msg_uv() local
496 msg = container_of(msg_hdr, struct in xpc_handle_activate_mq_msg_uv()
498 args = &part->remote_openclose_args[msg->ch_number]; in xpc_handle_activate_mq_msg_uv()
499 args->remote_nentries = msg->remote_nentries; in xpc_handle_activate_mq_msg_uv()
500 args->local_nentries = msg->local_nentries; in xpc_handle_activate_mq_msg_uv()
501 args->local_msgqueue_pa = msg->local_notify_mq_gpa; in xpc_handle_activate_mq_msg_uv()
504 part->chctl.flags[msg->ch_number] |= XPC_CHCTL_OPENREPLY; in xpc_handle_activate_mq_msg_uv()
591 xpc_send_activate_IRQ_uv(struct xpc_partition *part, void *msg, size_t msg_size, in xpc_send_activate_IRQ_uv() argument
594 struct xpc_activate_mq_msghdr_uv *msg_hdr = msg; in xpc_send_activate_IRQ_uv()
604 return xpc_send_gru_msg(part->sn.uv.remote_activate_mq_gpa, msg, in xpc_send_activate_IRQ_uv()
609 xpc_send_activate_IRQ_part_uv(struct xpc_partition *part, void *msg, in xpc_send_activate_IRQ_part_uv() argument
614 ret = xpc_send_activate_IRQ_uv(part, msg, msg_size, msg_type); in xpc_send_activate_IRQ_part_uv()
621 void *msg, size_t msg_size, int msg_type) in xpc_send_activate_IRQ_ch_uv() argument
626 ret = xpc_send_activate_IRQ_uv(part, msg, msg_size, msg_type); in xpc_send_activate_IRQ_ch_uv()
704 struct xpc_activate_mq_msg_heartbeat_req_uv msg; in xpc_send_heartbeat_uv() local
713 msg.heartbeat = atomic64_inc_return(&xpc_heartbeat_uv); in xpc_send_heartbeat_uv()
721 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_send_heartbeat_uv()
786 struct xpc_activate_mq_msg_activate_req_uv msg; in xpc_request_partition_activation_uv() local
797 msg.rp_gpa = uv_gpa(xpc_rsvd_page); in xpc_request_partition_activation_uv()
798 msg.activate_mq_gpa = xpc_rsvd_page->sn.activate_mq_gpa; in xpc_request_partition_activation_uv()
799 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_request_partition_activation_uv()
816 struct xpc_activate_mq_msg_deactivate_req_uv msg; in xpc_request_partition_deactivation_uv() local
825 msg.reason = part->reason; in xpc_request_partition_deactivation_uv()
826 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_request_partition_deactivation_uv()
922 struct xpc_activate_mq_msg_uv msg; in xpc_make_first_contact_uv() local
929 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_make_first_contact_uv()
1076 struct xpc_activate_mq_msg_chctl_closerequest_uv msg; in xpc_send_chctl_closerequest_uv() local
1078 msg.ch_number = ch->number; in xpc_send_chctl_closerequest_uv()
1079 msg.reason = ch->reason; in xpc_send_chctl_closerequest_uv()
1080 xpc_send_activate_IRQ_ch_uv(ch, irq_flags, &msg, sizeof(msg), in xpc_send_chctl_closerequest_uv()
1087 struct xpc_activate_mq_msg_chctl_closereply_uv msg; in xpc_send_chctl_closereply_uv() local
1089 msg.ch_number = ch->number; in xpc_send_chctl_closereply_uv()
1090 xpc_send_activate_IRQ_ch_uv(ch, irq_flags, &msg, sizeof(msg), in xpc_send_chctl_closereply_uv()
1097 struct xpc_activate_mq_msg_chctl_openrequest_uv msg; in xpc_send_chctl_openrequest_uv() local
1099 msg.ch_number = ch->number; in xpc_send_chctl_openrequest_uv()
1100 msg.entry_size = ch->entry_size; in xpc_send_chctl_openrequest_uv()
1101 msg.local_nentries = ch->local_nentries; in xpc_send_chctl_openrequest_uv()
1102 xpc_send_activate_IRQ_ch_uv(ch, irq_flags, &msg, sizeof(msg), in xpc_send_chctl_openrequest_uv()
1109 struct xpc_activate_mq_msg_chctl_openreply_uv msg; in xpc_send_chctl_openreply_uv() local
1111 msg.ch_number = ch->number; in xpc_send_chctl_openreply_uv()
1112 msg.local_nentries = ch->local_nentries; in xpc_send_chctl_openreply_uv()
1113 msg.remote_nentries = ch->remote_nentries; in xpc_send_chctl_openreply_uv()
1114 msg.local_notify_mq_gpa = uv_gpa(xpc_notify_mq_uv); in xpc_send_chctl_openreply_uv()
1115 xpc_send_activate_IRQ_ch_uv(ch, irq_flags, &msg, sizeof(msg), in xpc_send_chctl_openreply_uv()
1141 struct xpc_activate_mq_msg_uv msg; in xpc_indicate_partition_engaged_uv() local
1143 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_indicate_partition_engaged_uv()
1150 struct xpc_activate_mq_msg_uv msg; in xpc_indicate_partition_disengaged_uv() local
1152 xpc_send_activate_IRQ_part_uv(part, &msg, sizeof(msg), in xpc_indicate_partition_disengaged_uv()
1249 struct xpc_notify_mq_msg_uv *msg) in xpc_handle_notify_mq_ack_uv() argument
1252 int entry = msg->hdr.msg_slot_number % ch->local_nentries; in xpc_handle_notify_mq_ack_uv()
1256 BUG_ON(msg_slot->msg_slot_number != msg->hdr.msg_slot_number); in xpc_handle_notify_mq_ack_uv()
1267 struct xpc_notify_mq_msg_uv *msg) in xpc_handle_notify_mq_msg_uv() argument
1274 int ch_number = msg->hdr.ch_number; in xpc_handle_notify_mq_msg_uv()
1302 if (msg->hdr.size == 0) { in xpc_handle_notify_mq_msg_uv()
1303 xpc_handle_notify_mq_ack_uv(ch, msg); in xpc_handle_notify_mq_msg_uv()
1312 (msg->hdr.msg_slot_number % ch->remote_nentries) * ch->entry_size; in xpc_handle_notify_mq_msg_uv()
1314 BUG_ON(msg->hdr.msg_slot_number != msg_slot->hdr.msg_slot_number); in xpc_handle_notify_mq_msg_uv()
1317 memcpy(msg_slot, msg, msg->hdr.size); in xpc_handle_notify_mq_msg_uv()
1338 struct xpc_notify_mq_msg_uv *msg; in xpc_handle_notify_IRQ_uv() local
1342 while ((msg = gru_get_next_message(xpc_notify_mq_uv)) != NULL) { in xpc_handle_notify_IRQ_uv()
1344 partid = msg->hdr.partid; in xpc_handle_notify_IRQ_uv()
1352 xpc_handle_notify_mq_msg_uv(part, msg); in xpc_handle_notify_IRQ_uv()
1357 gru_free_message(xpc_notify_mq_uv, msg); in xpc_handle_notify_IRQ_uv()
1396 struct xpc_notify_mq_msg_uv *msg; in xpc_send_payload_uv() local
1434 msg = (struct xpc_notify_mq_msg_uv *)&msg_buffer; in xpc_send_payload_uv()
1435 msg->hdr.partid = xp_partition_id; in xpc_send_payload_uv()
1436 msg->hdr.ch_number = ch->number; in xpc_send_payload_uv()
1437 msg->hdr.size = msg_size; in xpc_send_payload_uv()
1438 msg->hdr.msg_slot_number = msg_slot->msg_slot_number; in xpc_send_payload_uv()
1439 memcpy(&msg->payload, payload, payload_size); in xpc_send_payload_uv()
1441 ret = xpc_send_gru_msg(ch->sn.uv.remote_notify_mq_gpa, msg, msg_size); in xpc_send_payload_uv()
1505 struct xpc_notify_mq_msg_uv *msg; in xpc_get_deliverable_payload_uv() local
1511 msg = container_of(entry, struct xpc_notify_mq_msg_uv, in xpc_get_deliverable_payload_uv()
1513 payload = &msg->payload; in xpc_get_deliverable_payload_uv()
1522 struct xpc_notify_mq_msg_uv *msg; in xpc_received_payload_uv() local
1525 msg = container_of(payload, struct xpc_notify_mq_msg_uv, payload); in xpc_received_payload_uv()
1529 msg->hdr.partid = xp_partition_id; in xpc_received_payload_uv()
1530 msg->hdr.size = 0; /* size of zero indicates this is an ACK */ in xpc_received_payload_uv()
1532 ret = xpc_send_gru_msg(ch->sn.uv.remote_notify_mq_gpa, msg, in xpc_received_payload_uv()
1537 msg->hdr.msg_slot_number += ch->remote_nentries; in xpc_received_payload_uv()