mach_msg_destroy.c [plain text]
#include <mach/mach.h>
#include <mach/message.h>
#include <mach/mach_init.h>
static void mach_msg_destroy_port(mach_port_t, mach_msg_type_name_t);
static void mach_msg_destroy_memory(vm_offset_t, vm_size_t);
void
mach_msg_destroy(mach_msg_header_t *msg)
{
mach_msg_bits_t mbits = msg->msgh_bits;
mach_msg_destroy_port(msg->msgh_remote_port, MACH_MSGH_BITS_REMOTE(mbits));
if (mbits & MACH_MSGH_BITS_COMPLEX) {
mach_msg_body_t *body;
mach_msg_descriptor_t *saddr, *eaddr;
body = (mach_msg_body_t *) (msg + 1);
saddr = (mach_msg_descriptor_t *)
((mach_msg_base_t *) msg + 1);
eaddr = saddr + body->msgh_descriptor_count;
for ( ; saddr < eaddr; saddr++) {
switch (saddr->type.type) {
case MACH_MSG_PORT_DESCRIPTOR: {
mach_msg_port_descriptor_t *dsc;
dsc = &saddr->port;
mach_msg_destroy_port(dsc->name, dsc->disposition);
break;
}
case MACH_MSG_OOL_DESCRIPTOR : {
mach_msg_ool_descriptor_t *dsc;
dsc = &saddr->out_of_line;
if (dsc->deallocate) {
mach_msg_destroy_memory((vm_offset_t)dsc->address,
dsc->size);
}
break;
}
case MACH_MSG_OOL_PORTS_DESCRIPTOR : {
mach_port_t *ports;
mach_msg_ool_ports_descriptor_t *dsc;
mach_msg_type_number_t j;
dsc = &saddr->ool_ports;
ports = (mach_port_t *) dsc->address;
for (j = 0; j < dsc->count; j++, ports++) {
mach_msg_destroy_port(*ports, dsc->disposition);
}
if (dsc->deallocate) {
mach_msg_destroy_memory((vm_offset_t)dsc->address,
dsc->count * sizeof(mach_port_t));
}
break;
}
}
}
}
}
static void
mach_msg_destroy_port(mach_port_t port, mach_msg_type_name_t type)
{
if (MACH_PORT_VALID(port)) switch (type) {
case MACH_MSG_TYPE_MOVE_SEND:
case MACH_MSG_TYPE_MOVE_SEND_ONCE:
(void) mach_port_deallocate(mach_task_self(), port);
break;
case MACH_MSG_TYPE_MOVE_RECEIVE:
(void) mach_port_mod_refs(mach_task_self(), port,
MACH_PORT_RIGHT_RECEIVE, -1);
break;
case MACH_MSG_TYPE_MAKE_SEND:
(void) mach_port_insert_right(mach_task_self(), port,
port, MACH_MSG_TYPE_MAKE_SEND);
(void) mach_port_deallocate(mach_task_self(), port);
break;
case MACH_MSG_TYPE_MAKE_SEND_ONCE:
(void) mach_port_extract_right(mach_task_self(), port,
MACH_MSG_TYPE_MAKE_SEND_ONCE,
&port, &type);
(void) mach_port_deallocate(mach_task_self(), port);
break;
}
}
static void
mach_msg_destroy_memory(vm_offset_t addr, vm_size_t size)
{
if (size != 0)
(void) vm_deallocate(mach_task_self(), addr, size);
}