Lines Matching refs:fmsg

225 	mnl_msg_t fmsg = mnl_msg_alloc(fsize, 0);  in mnl_msg_from_kmsg()  local
227 if (fmsg == MNL_MSG_NULL) { in mnl_msg_from_kmsg()
232 fmsg->sub = MACH_NODE_SUB_FLIPC; in mnl_msg_from_kmsg()
233 fmsg->cmd = FLIPC_CMD_IPCMESSAGE; in mnl_msg_from_kmsg()
234 fmsg->node_id = localnode_id; // Message is from us in mnl_msg_from_kmsg()
235 fmsg->qos = 0; // not used in mnl_msg_from_kmsg()
236 fmsg->size = fsize; // Payload size (does NOT include mnl_msg header) in mnl_msg_from_kmsg()
237 fmsg->object = ikm_header(kmsg)->msgh_remote_port->ip_messages.imq_fport->obj.name; in mnl_msg_from_kmsg()
240 bcopy((const void*)ikm_header(kmsg), (void*)MNL_MSG_PAYLOAD(fmsg), fsize); in mnl_msg_from_kmsg()
243 mach_msg_header_t *mmsg = (mach_msg_header_t*)MNL_MSG_PAYLOAD(fmsg); in mnl_msg_from_kmsg()
244 mmsg->msgh_remote_port = (mach_port_t)fmsg->object; in mnl_msg_from_kmsg()
249 *fmsgp = (mnl_msg_t)fmsg; in mnl_msg_from_kmsg()
292 flipc_cmd_ipc(mnl_msg_t fmsg, in flipc_cmd_ipc() argument
299 mmsg = (mach_msg_header_t*)MNL_MSG_PAYLOAD(fmsg); in flipc_cmd_ipc()
300 mmsg->msgh_size = fmsg->size; in flipc_cmd_ipc()
301 mmsg->msgh_remote_port = mnl_name_to_port(fmsg->object); in flipc_cmd_ipc()
307 return mach_msg_send_from_remote_kernel(mmsg, fmsg->size, node); in flipc_cmd_ipc()
316 flipc_cmd_ack(flipc_ack_msg_t fmsg, in flipc_cmd_ack() argument
320 unsigned int msg_count = fmsg->msg_count; in flipc_cmd_ack()
324 flipc_port_t fport = (flipc_port_t)mnl_obj_lookup(fmsg->mnl.object); in flipc_cmd_ack()
416 mnl_msg_t fmsg = MNL_MSG_NULL; in flipc_msg_to_remote_node() local
461 mnl_msg_from_kmsg(kmsg, (mnl_msg_t*)&fmsg); in flipc_msg_to_remote_node()
479 fmsg = (mnl_msg_t)(&hdr[1]); in flipc_msg_to_remote_node()
481 *(ipc_kmsg_t*)((vm_offset_t)fmsg - sizeof(vm_offset_t)) = kmsg; in flipc_msg_to_remote_node()
484 if (MNL_MSG_VALID(fmsg)) { in flipc_msg_to_remote_node()
488 assert(MNL_MSG_VALID(fmsg)); in flipc_msg_to_remote_node()
489 return fmsg; in flipc_msg_to_remote_node()
611 flipc_ack_msg_t fmsg = (flipc_ack_msg_t)(&msg[1]); in flipc_msg_ack() local
612 fmsg->resend_to = HOST_LOCAL_NODE; in flipc_msg_ack()
613 fmsg->msg_count = 1; // Might want to coalesce acks to a node/name pair in flipc_msg_ack()
616 fmsg->mnl.sub = MACH_NODE_SUB_FLIPC; in flipc_msg_ack()
617 fmsg->mnl.cmd = delivered ? FLIPC_CMD_ACKMESSAGE : FLIPC_CMD_NAKMESSAGE; in flipc_msg_ack()
618 fmsg->mnl.qos = 0; // Doesn't do anything yet in flipc_msg_ack()
619 fmsg->mnl.flags = 0; in flipc_msg_ack()
620 fmsg->mnl.node_id = nid; in flipc_msg_ack()
621 fmsg->mnl.object = name; in flipc_msg_ack()
622 fmsg->mnl.options = 0; in flipc_msg_ack()
623 fmsg->mnl.size = sizeof(struct flipc_ack_msg) - sizeof(struct mnl_msg); in flipc_msg_ack()