xnu-6153.81.5.tar.gz

[apple/xnu.git] / osfmk / kern / exception.c

diff --git a/osfmk/kern/exception.c b/osfmk/kern/exception.c
index a9dff5bccba3491c3c22a72680cc5e0cae30584f..c059f1c50f5075e52d11f6b7dd02a5dc57030ff3 100644 (file)
--- a/osfmk/kern/exception.c
+++ b/osfmk/kern/exception.c
@@ -1,15 +1,20 @@
 /*
  * Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.
  *
 /*
  * Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.
  *

- * @APPLE_LICENSE_HEADER_START@
- * 
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
+ *

  * This file contains Original Code and/or Modifications of Original Code
  * as defined in and that are subject to the Apple Public Source License
  * Version 2.0 (the 'License'). You may not use this file except in
  * This file contains Original Code and/or Modifications of Original Code
  * as defined in and that are subject to the Apple Public Source License
  * Version 2.0 (the 'License'). You may not use this file except in

- * compliance with the License. Please obtain a copy of the License at
- * http://www.opensource.apple.com/apsl/ and read it before using this
- * file.
- * 
+ * compliance with the License. The rights granted to you under the License
+ * may not be used to create, or enable the creation or redistribution of,
+ * unlawful or unlicensed copies of an Apple operating system, or to
+ * circumvent, violate, or enable the circumvention or violation of, any
+ * terms of an Apple operating system software license agreement.
+ *
+ * Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this file.
+ *

  * The Original Code and all software distributed under the License are
  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * The Original Code and all software distributed under the License are
  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,


@@ -17,42 +22,40 @@
  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
  * Please see the License for the specific language governing rights and
  * limitations under the License.
  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
  * Please see the License for the specific language governing rights and
  * limitations under the License.

- * 
- * @APPLE_LICENSE_HEADER_END@
+ *
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_END@

  */
 /*
  * @OSF_COPYRIGHT@
  */
  */
 /*
  * @OSF_COPYRIGHT@
  */

-/* 
+/*

  * Mach Operating System
  * Copyright (c) 1991,1990,1989,1988,1987 Carnegie Mellon University
  * All Rights Reserved.
  * Mach Operating System
  * Copyright (c) 1991,1990,1989,1988,1987 Carnegie Mellon University
  * All Rights Reserved.

- * 
+ *

  * Permission to use, copy, modify and distribute this software and its
  * documentation is hereby granted, provided that both the copyright
  * notice and this permission notice appear in all copies of the
  * software, derivative works or modified versions, and any portions
  * thereof, and that both notices appear in supporting documentation.
  * Permission to use, copy, modify and distribute this software and its
  * documentation is hereby granted, provided that both the copyright
  * notice and this permission notice appear in all copies of the
  * software, derivative works or modified versions, and any portions
  * thereof, and that both notices appear in supporting documentation.

- * 
+ *

  * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
  * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR
  * ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
  * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
  * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR
  * ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.

- * 
+ *

  * Carnegie Mellon requests users of this software to return to
  * Carnegie Mellon requests users of this software to return to

- * 
+ *

  *  Software Distribution Coordinator  or  Software.Distribution@CS.CMU.EDU
  *  School of Computer Science
  *  Carnegie Mellon University
  *  Pittsburgh PA 15213-3890
  *  Software Distribution Coordinator  or  Software.Distribution@CS.CMU.EDU
  *  School of Computer Science
  *  Carnegie Mellon University
  *  Pittsburgh PA 15213-3890

- * 
+ *

  * any improvements or extensions that they make and grant Carnegie Mellon
  * the rights to redistribute these changes.
  */
 /*
  */
 
  * any improvements or extensions that they make and grant Carnegie Mellon
  * the rights to redistribute these changes.
  */
 /*
  */
 

-#include <mach_kdb.h>
-

 #include <mach/mach_types.h>
 #include <mach/boolean.h>
 #include <mach/kern_return.h>
 #include <mach/mach_types.h>
 #include <mach/boolean.h>
 #include <mach/kern_return.h>


@@ -62,6 +65,9 @@
 #include <mach/task.h>
 #include <mach/thread_status.h>
 #include <mach/exception_types.h>
 #include <mach/task.h>
 #include <mach/thread_status.h>
 #include <mach/exception_types.h>

+#include <mach/exc.h>
+#include <mach/mach_exc.h>
+

 #include <ipc/port.h>
 #include <ipc/ipc_entry.h>
 #include <ipc/ipc_object.h>
 #include <ipc/port.h>
 #include <ipc/ipc_entry.h>
 #include <ipc/ipc_object.h>


@@ -69,6 +75,7 @@
 #include <ipc/ipc_space.h>
 #include <ipc/ipc_pset.h>
 #include <ipc/ipc_machdep.h>
 #include <ipc/ipc_space.h>
 #include <ipc/ipc_pset.h>
 #include <ipc/ipc_machdep.h>

+

 #include <kern/counters.h>
 #include <kern/ipc_tt.h>
 #include <kern/task.h>
 #include <kern/counters.h>
 #include <kern/ipc_tt.h>
 #include <kern/task.h>


@@ -78,24 +85,14 @@
 #include <kern/sched_prim.h>
 #include <kern/host.h>
 #include <kern/misc_protos.h>
 #include <kern/sched_prim.h>
 #include <kern/host.h>
 #include <kern/misc_protos.h>

-#include <string.h>
-#include <mach/exc.h>
-
-#if    MACH_KDB
-#include <ddb/db_trap.h>
-#endif /* MACH_KDB */
+#include <kern/ux_handler.h>

 
 

-#if    MACH_KDB
-
-#include <ddb/db_output.h>
+#include <security/mac_mach_internal.h>
+#include <string.h>

 
 

-#if iPSC386 || iPSC860
-boolean_t debug_user_with_kdb = TRUE;
-#else
-boolean_t debug_user_with_kdb = FALSE;
-#endif
+#include <pexpert/pexpert.h>

 
 

-#endif /* MACH_KDB */
+bool panic_on_exception_triage = false;

 
 unsigned long c_thr_exc_raise = 0;
 unsigned long c_thr_exc_raise_state = 0;
 
 unsigned long c_thr_exc_raise = 0;
 unsigned long c_thr_exc_raise_state = 0;


@@ -105,20 +102,44 @@ unsigned long c_tsk_exc_raise_state = 0;
 unsigned long c_tsk_exc_raise_state_id = 0;
 
 /* forward declarations */
 unsigned long c_tsk_exc_raise_state_id = 0;
 
 /* forward declarations */

-void exception_deliver(
-       exception_type_t        exception,
-       exception_data_t        code,
+kern_return_t exception_deliver(
+       thread_t                thread,
+       exception_type_t        exception,
+       mach_exception_data_t   code,

        mach_msg_type_number_t  codeCnt,
        struct exception_action *excp,
        mach_msg_type_number_t  codeCnt,
        struct exception_action *excp,

-       mutex_t                 *mutex);
+       lck_mtx_t                       *mutex);
+
+static kern_return_t
+check_exc_receiver_dependency(
+       exception_type_t exception,
+       struct exception_action *excp,
+       lck_mtx_t *mutex);

 
 #ifdef MACH_BSD
 kern_return_t bsd_exception(
 
 #ifdef MACH_BSD
 kern_return_t bsd_exception(

-       exception_type_t        exception,
-       exception_data_t        code,
+       exception_type_t        exception,
+       mach_exception_data_t   code,

        mach_msg_type_number_t  codeCnt);
 #endif /* MACH_BSD */
 
        mach_msg_type_number_t  codeCnt);
 #endif /* MACH_BSD */
 

+/*
+ * Routine: exception_init
+ * Purpose:
+ *   Global initialization of state for exceptions.
+ * Conditions:
+ *   None.
+ */
+void
+exception_init(void)
+{
+       int tmp = 0;
+
+       if (PE_parse_boot_argn("-panic_on_exception_triage", &tmp, sizeof(tmp))) {
+               panic_on_exception_triage = true;
+       }
+}
+

 /*
  *     Routine:        exception_deliver
  *     Purpose:
 /*
  *     Routine:        exception_deliver
  *     Purpose:


@@ -129,28 +150,48 @@ kern_return_t bsd_exception(
  *             thread_exception_return and thread_kdb_return
  *             are possible.
  *     Returns:
  *             thread_exception_return and thread_kdb_return
  *             are possible.
  *     Returns:

- *             If the exception was not handled by this handler
+ *             KERN_SUCCESS if the exception was handled

  */
  */

-void
+kern_return_t

 exception_deliver(
 exception_deliver(

-       exception_type_t        exception,
-       exception_data_t        code,
+       thread_t                thread,
+       exception_type_t        exception,
+       mach_exception_data_t   code,

        mach_msg_type_number_t  codeCnt,
        struct exception_action *excp,
        mach_msg_type_number_t  codeCnt,
        struct exception_action *excp,

-       mutex_t                 *mutex)
+       lck_mtx_t                       *mutex)

 {
 {

-       thread_t                self = current_thread();
-       ipc_port_t              exc_port;
-       int                     behavior;
-       int                     flavor;
-       kern_return_t           kr;
+       ipc_port_t              exc_port = IPC_PORT_NULL;
+       exception_data_type_t   small_code[EXCEPTION_CODE_MAX];
+       int                     code64;
+       int                     behavior;
+       int                     flavor;
+       kern_return_t           kr;
+       task_t task;
+       ipc_port_t thread_port = IPC_PORT_NULL, task_port = IPC_PORT_NULL;

 
        /*
         *  Save work if we are terminating.
         *  Just go back to our AST handler.
         */
 
        /*
         *  Save work if we are terminating.
         *  Just go back to our AST handler.
         */

-       if (!self->active)
-               thread_exception_return();
+       if (!thread->active && !thread->inspection) {
+               return KERN_SUCCESS;
+       }
+
+       /*
+        * If there are no exception actions defined for this entity,
+        * we can't deliver here.
+        */
+       if (excp == NULL) {
+               return KERN_FAILURE;
+       }
+
+       assert(exception < EXC_TYPES_COUNT);
+       if (exception >= EXC_TYPES_COUNT) {
+               return KERN_FAILURE;
+       }
+
+       excp = &excp[exception];

 
        /*
         * Snapshot the exception action data under lock for consistency.
 
        /*
         * Snapshot the exception action data under lock for consistency.


@@ -159,25 +200,60 @@ exception_deliver(
         * the port from disappearing between now and when
         * ipc_object_copyin_from_kernel is finally called.
         */
         * the port from disappearing between now and when
         * ipc_object_copyin_from_kernel is finally called.
         */

-       mutex_lock(mutex);
+       lck_mtx_lock(mutex);

        exc_port = excp->port;
        if (!IP_VALID(exc_port)) {
        exc_port = excp->port;
        if (!IP_VALID(exc_port)) {

-               mutex_unlock(mutex);
-               return;
+               lck_mtx_unlock(mutex);
+               return KERN_FAILURE;

        }
        ip_lock(exc_port);
        if (!ip_active(exc_port)) {
                ip_unlock(exc_port);
        }
        ip_lock(exc_port);
        if (!ip_active(exc_port)) {
                ip_unlock(exc_port);

-               mutex_unlock(mutex);
-               return;
+               lck_mtx_unlock(mutex);
+               return KERN_FAILURE;

        }
        }

-       ip_reference(exc_port); 
+       ip_reference(exc_port);

        exc_port->ip_srights++;
        ip_unlock(exc_port);
 
        flavor = excp->flavor;
        behavior = excp->behavior;
        exc_port->ip_srights++;
        ip_unlock(exc_port);
 
        flavor = excp->flavor;
        behavior = excp->behavior;

-       mutex_unlock(mutex);
+       lck_mtx_unlock(mutex);
+
+       code64 = (behavior & MACH_EXCEPTION_CODES);
+       behavior &= ~MACH_EXCEPTION_MASK;
+
+       if (!code64) {
+               small_code[0] = CAST_DOWN_EXPLICIT(exception_data_type_t, code[0]);
+               small_code[1] = CAST_DOWN_EXPLICIT(exception_data_type_t, code[1]);
+       }
+
+       task = thread->task;
+
+#if CONFIG_MACF
+       /* Now is a reasonably good time to check if the exception action is
+        * permitted for this process, because after this point we will send
+        * the message out almost certainly.
+        * As with other failures, exception_triage_thread will go on
+        * to the next level.
+        */
+
+       /* The global exception-to-signal translation port is safe to be an exception handler. */
+       if (is_ux_handler_port(exc_port) == FALSE &&
+           mac_exc_action_check_exception_send(task, excp) != 0) {
+               kr = KERN_FAILURE;
+               goto out_release_right;
+       }
+#endif
+
+       if (behavior != EXCEPTION_STATE) {
+               task_reference(task);
+               task_port = convert_task_to_port(task);
+               /* task ref consumed */
+               thread_reference(thread);
+               thread_port = convert_thread_to_port(thread);
+               /* thread ref consumed */
+       }

 
        switch (behavior) {
        case EXCEPTION_STATE: {
 
        switch (behavior) {
        case EXCEPTION_STATE: {


@@ -186,39 +262,58 @@ exception_deliver(
 
                c_thr_exc_raise_state++;
                state_cnt = _MachineStateCount[flavor];
 
                c_thr_exc_raise_state++;
                state_cnt = _MachineStateCount[flavor];

-               kr = thread_getstatus(self, flavor, 
-                                     (thread_state_t)state,
-                                     &state_cnt);
+               kr = thread_getstatus_to_user(thread, flavor,
+                   (thread_state_t)state,
+                   &state_cnt);

                if (kr == KERN_SUCCESS) {
                if (kr == KERN_SUCCESS) {

-                       kr = exception_raise_state(exc_port, exception,
-                                                  code, codeCnt,
-                                                  &flavor,
-                                                  state, state_cnt,
-                                                  state, &state_cnt);
-                       if (kr == MACH_MSG_SUCCESS)
-                               kr = thread_setstatus(self, flavor, 
-                                                     (thread_state_t)state,
-                                                     state_cnt);
+                       if (code64) {
+                               kr = mach_exception_raise_state(exc_port,
+                                   exception,
+                                   code,
+                                   codeCnt,
+                                   &flavor,
+                                   state, state_cnt,
+                                   state, &state_cnt);
+                       } else {
+                               kr = exception_raise_state(exc_port, exception,
+                                   small_code,
+                                   codeCnt,
+                                   &flavor,
+                                   state, state_cnt,
+                                   state, &state_cnt);
+                       }
+                       if (kr == KERN_SUCCESS) {
+                               if (exception != EXC_CORPSE_NOTIFY) {
+                                       kr = thread_setstatus_from_user(thread, flavor,
+                                           (thread_state_t)state,
+                                           state_cnt);
+                               }
+                               goto out_release_right;
+                       }

                }
 
                }
 

-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       thread_exception_return();
-                       /*NOTREACHED*/
-               return;
+               goto out_release_right;

        }
 
        case EXCEPTION_DEFAULT:
                c_thr_exc_raise++;
        }
 
        case EXCEPTION_DEFAULT:
                c_thr_exc_raise++;

-               kr = exception_raise(exc_port,
-                               retrieve_thread_self_fast(self),
-                               retrieve_task_self_fast(self->task),
-                               exception,
-                               code, codeCnt);
+               if (code64) {
+                       kr = mach_exception_raise(exc_port,
+                           thread_port,
+                           task_port,
+                           exception,
+                           code,
+                           codeCnt);
+               } else {
+                       kr = exception_raise(exc_port,
+                           thread_port,
+                           task_port,
+                           exception,
+                           small_code,
+                           codeCnt);
+               }

 
 

-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       thread_exception_return();
-                       /*NOTREACHED*/
-               return;
+               goto out_release_right;

 
        case EXCEPTION_STATE_IDENTITY: {
                mach_msg_type_number_t state_cnt;
 
        case EXCEPTION_STATE_IDENTITY: {
                mach_msg_type_number_t state_cnt;


@@ -226,39 +321,111 @@ exception_deliver(
 
                c_thr_exc_raise_state_id++;
                state_cnt = _MachineStateCount[flavor];
 
                c_thr_exc_raise_state_id++;
                state_cnt = _MachineStateCount[flavor];

-               kr = thread_getstatus(self, flavor,
-                                     (thread_state_t)state,
-                                     &state_cnt);
+               kr = thread_getstatus_to_user(thread, flavor,
+                   (thread_state_t)state,
+                   &state_cnt);

                if (kr == KERN_SUCCESS) {
                if (kr == KERN_SUCCESS) {

-                   kr = exception_raise_state_identity(exc_port,
-                               retrieve_thread_self_fast(self),
-                               retrieve_task_self_fast(self->task),
-                               exception,
-                               code, codeCnt,
-                               &flavor,
-                               state, state_cnt,
-                               state, &state_cnt);
-                   if (kr == MACH_MSG_SUCCESS)
-                       kr = thread_setstatus(self, flavor,
-                                             (thread_state_t)state,
-                                             state_cnt);
+                       if (code64) {
+                               kr = mach_exception_raise_state_identity(
+                                       exc_port,
+                                       thread_port,
+                                       task_port,
+                                       exception,
+                                       code,
+                                       codeCnt,
+                                       &flavor,
+                                       state, state_cnt,
+                                       state, &state_cnt);
+                       } else {
+                               kr = exception_raise_state_identity(exc_port,
+                                   thread_port,
+                                   task_port,
+                                   exception,
+                                   small_code,
+                                   codeCnt,
+                                   &flavor,
+                                   state, state_cnt,
+                                   state, &state_cnt);
+                       }
+
+                       if (kr == KERN_SUCCESS) {
+                               if (exception != EXC_CORPSE_NOTIFY) {
+                                       kr = thread_setstatus_from_user(thread, flavor,
+                                           (thread_state_t)state,
+                                           state_cnt);
+                               }
+                               goto out_release_right;
+                       }

                }
 
                }
 

-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       thread_exception_return();
-                       /*NOTREACHED*/
-               return;
+               goto out_release_right;

        }
        }

-       
+

        default:
        default:

-               panic ("bad exception behavior!");
+               panic("bad exception behavior!");
+               return KERN_FAILURE;

        }/* switch */
        }/* switch */

+
+out_release_right:
+
+       if (task_port) {
+               ipc_port_release_send(task_port);
+       }
+
+       if (thread_port) {
+               ipc_port_release_send(thread_port);
+       }
+
+       if (exc_port) {
+               ipc_port_release_send(exc_port);
+       }
+
+       return kr;

 }
 
 /*
 }
 
 /*

- *     Routine:        exception
+ * Routine: check_exc_receiver_dependency
+ * Purpose:
+ *      Verify that the port destined for receiving this exception is not
+ *      on the current task. This would cause hang in kernel for
+ *      EXC_CRASH primarily. Note: If port is transferred
+ *      between check and delivery then deadlock may happen.
+ *
+ * Conditions:
+ *             Nothing locked and no resources held.
+ *             Called from an exception context.
+ * Returns:
+ *      KERN_SUCCESS if its ok to send exception message.
+ */
+kern_return_t
+check_exc_receiver_dependency(
+       exception_type_t exception,
+       struct exception_action *excp,
+       lck_mtx_t *mutex)
+{
+       kern_return_t retval = KERN_SUCCESS;
+
+       if (excp == NULL || exception != EXC_CRASH) {
+               return retval;
+       }
+
+       task_t task = current_task();
+       lck_mtx_lock(mutex);
+       ipc_port_t xport = excp[exception].port;
+       if (IP_VALID(xport)
+           && ip_active(xport)
+           && task->itk_space == xport->ip_receiver) {
+               retval = KERN_FAILURE;
+       }
+       lck_mtx_unlock(mutex);
+       return retval;
+}
+
+
+/*
+ *     Routine:        exception_triage_thread

  *     Purpose:
  *     Purpose:

- *             The current thread caught an exception.
+ *             The thread caught an exception.

  *             We make an up-call to the thread's exception server.
  *     Conditions:
  *             Nothing locked and no resources held.
  *             We make an up-call to the thread's exception server.
  *     Conditions:
  *             Nothing locked and no resources held.


@@ -266,260 +433,185 @@ exception_deliver(
  *             thread_exception_return and thread_kdb_return
  *             are possible.
  *     Returns:
  *             thread_exception_return and thread_kdb_return
  *             are possible.
  *     Returns:

- *             Doesn't return.
+ *             KERN_SUCCESS if exception is handled by any of the handlers.

  */
  */

-void
-exception_triage(
-       exception_type_t        exception,
-       exception_data_t        code,
-       mach_msg_type_number_t  codeCnt)
+kern_return_t
+exception_triage_thread(
+       exception_type_t        exception,
+       mach_exception_data_t   code,
+       mach_msg_type_number_t  codeCnt,
+       thread_t                thread)

 {
 {

-       thread_t                thread;
-       task_t                  task;
-       host_priv_t             host_priv;
-       struct exception_action *excp;
-       mutex_t                 *mutex;
+       task_t                  task;
+       host_priv_t             host_priv;
+       lck_mtx_t               *mutex;
+       kern_return_t   kr = KERN_FAILURE;

 
        assert(exception != EXC_RPC_ALERT);
 
 
        assert(exception != EXC_RPC_ALERT);
 

-       if (exception == KERN_SUCCESS)
-               panic("exception");
+       /*
+        * If this behavior has been requested by the the kernel
+        * (due to the boot environment), we should panic if we
+        * enter this function.  This is intended as a debugging
+        * aid; it should allow us to debug why we caught an
+        * exception in environments where debugging is especially
+        * difficult.
+        */
+       if (panic_on_exception_triage) {
+               panic("called exception_triage when it was forbidden by the boot environment");
+       }

 
        /*
         * Try to raise the exception at the activation level.
         */
 
        /*
         * Try to raise the exception at the activation level.
         */

-       thread = current_thread();
-       mutex = mutex_addr(thread->mutex);
-       excp = &thread->exc_actions[exception];
-       exception_deliver(exception, code, codeCnt, excp, mutex);
+       mutex = &thread->mutex;
+       if (KERN_SUCCESS == check_exc_receiver_dependency(exception, thread->exc_actions, mutex)) {
+               kr = exception_deliver(thread, exception, code, codeCnt, thread->exc_actions, mutex);
+               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED) {
+                       goto out;
+               }
+       }

 
        /*
         * Maybe the task level will handle it.
         */
 
        /*
         * Maybe the task level will handle it.
         */

-       task = current_task();
-       mutex = mutex_addr(task->lock);
-       excp = &task->exc_actions[exception];
-       exception_deliver(exception, code, codeCnt, excp, mutex);
+       task = thread->task;
+       mutex = &task->itk_lock_data;
+       if (KERN_SUCCESS == check_exc_receiver_dependency(exception, task->exc_actions, mutex)) {
+               kr = exception_deliver(thread, exception, code, codeCnt, task->exc_actions, mutex);
+               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED) {
+                       goto out;
+               }
+       }

 
        /*
         * How about at the host level?
         */
        host_priv = host_priv_self();
 
        /*
         * How about at the host level?
         */
        host_priv = host_priv_self();

-       mutex = mutex_addr(host_priv->lock);
-       excp = &host_priv->exc_actions[exception];
-       exception_deliver(exception, code, codeCnt, excp, mutex);
+       mutex = &host_priv->lock;

 
 

-       /*
-        * Nobody handled it, terminate the task.
-        */
+       if (KERN_SUCCESS == check_exc_receiver_dependency(exception, host_priv->exc_actions, mutex)) {
+               kr = exception_deliver(thread, exception, code, codeCnt, host_priv->exc_actions, mutex);
+               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED) {
+                       goto out;
+               }
+       }

 
 

-#if    MACH_KDB
-       if (debug_user_with_kdb) {
-               /*
-                *      Debug the exception with kdb.
-                *      If kdb handles the exception,
-                *      then thread_kdb_return won't return.
-                */
-               db_printf("No exception server, calling kdb...\n");
-               thread_kdb_return();
+out:
+       if ((exception != EXC_CRASH) && (exception != EXC_RESOURCE) &&
+           (exception != EXC_GUARD) && (exception != EXC_CORPSE_NOTIFY)) {
+               thread_exception_return();

        }
        }

-#endif /* MACH_KDB */
+       return kr;
+}

 
 

-       (void) task_terminate(task);
-       thread_exception_return();
-       /*NOTREACHED*/
+/*
+ *     Routine:        exception_triage
+ *     Purpose:
+ *             The current thread caught an exception.
+ *             We make an up-call to the thread's exception server.
+ *     Conditions:
+ *             Nothing locked and no resources held.
+ *             Called from an exception context, so
+ *             thread_exception_return and thread_kdb_return
+ *             are possible.
+ *     Returns:
+ *             KERN_SUCCESS if exception is handled by any of the handlers.
+ */
+kern_return_t
+exception_triage(
+       exception_type_t        exception,
+       mach_exception_data_t   code,
+       mach_msg_type_number_t  codeCnt)
+{
+       thread_t thread = current_thread();
+       return exception_triage_thread(exception, code, codeCnt, thread);

 }
 
 kern_return_t
 bsd_exception(
 }
 
 kern_return_t
 bsd_exception(

-       exception_type_t        exception,
-       exception_data_t        code,
+       exception_type_t        exception,
+       mach_exception_data_t   code,

        mach_msg_type_number_t  codeCnt)
 {
        mach_msg_type_number_t  codeCnt)
 {

-       task_t                  task;
-       struct exception_action *excp;
-       mutex_t                 *mutex;
-       thread_t                self = current_thread();
-       ipc_port_t              exc_port;
-       int                     behavior;
-       int                     flavor;
-       kern_return_t           kr;
+       task_t                  task;
+       lck_mtx_t               *mutex;
+       thread_t                self = current_thread();
+       kern_return_t           kr;

 
        /*
         * Maybe the task level will handle it.
         */
        task = current_task();
 
        /*
         * Maybe the task level will handle it.
         */
        task = current_task();

-       mutex = mutex_addr(task->lock);
-       excp = &task->exc_actions[exception];
-
-       /*
-        *  Save work if we are terminating.
-        *  Just go back to our AST handler.
-        */
-       if (!self->active) {
-               return(KERN_FAILURE);
-       }
-
-       /*
-        * Snapshot the exception action data under lock for consistency.
-        * Hold a reference to the port over the exception_raise_* calls
-        * so it can't be destroyed.  This seems like overkill, but keeps
-        * the port from disappearing between now and when
-        * ipc_object_copyin_from_kernel is finally called.
-        */
-       mutex_lock(mutex);
-       exc_port = excp->port;
-       if (!IP_VALID(exc_port)) {
-               mutex_unlock(mutex);
-               return(KERN_FAILURE);
-       }
-       ip_lock(exc_port);
-       if (!ip_active(exc_port)) {
-               ip_unlock(exc_port);
-               mutex_unlock(mutex);
-               return(KERN_FAILURE);
-       }
-       ip_reference(exc_port); 
-       exc_port->ip_srights++;
-       ip_unlock(exc_port);
-
-       flavor = excp->flavor;
-       behavior = excp->behavior;
-       mutex_unlock(mutex);
-
-       switch (behavior) {
-       case EXCEPTION_STATE: {
-               mach_msg_type_number_t state_cnt;
-               thread_state_data_t state;
+       mutex = &task->itk_lock_data;

 
 

-               c_thr_exc_raise_state++;
-               state_cnt = _MachineStateCount[flavor];
-               kr = thread_getstatus(self, flavor, 
-                                     (thread_state_t)state,
-                                     &state_cnt);
-               if (kr == KERN_SUCCESS) {
-                       kr = exception_raise_state(exc_port, exception,
-                                                  code, codeCnt,
-                                                  &flavor,
-                                                  state, state_cnt,
-                                                  state, &state_cnt);
-                       if (kr == MACH_MSG_SUCCESS)
-                               kr = thread_setstatus(self, flavor, 
-                                                     (thread_state_t)state,
-                                                     state_cnt);
-               }
+       kr = exception_deliver(self, exception, code, codeCnt, task->exc_actions, mutex);

 
 

-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       return(KERN_SUCCESS);
-
-               return(KERN_FAILURE);
+       if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED) {
+               return KERN_SUCCESS;

        }
        }

+       return KERN_FAILURE;
+}

 
 

-       case EXCEPTION_DEFAULT:
-               c_thr_exc_raise++;
-               kr = exception_raise(exc_port,
-                               retrieve_thread_self_fast(self),
-                               retrieve_task_self_fast(self->task),
-                               exception,
-                               code, codeCnt);
-
-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       return(KERN_SUCCESS);
-               return(KERN_FAILURE);

 
 

-       case EXCEPTION_STATE_IDENTITY: {
-               mach_msg_type_number_t state_cnt;
-               thread_state_data_t state;
+/*
+ * Raise an exception on a task.
+ * This should tell launchd to launch Crash Reporter for this task.
+ */
+kern_return_t
+task_exception_notify(exception_type_t exception,
+    mach_exception_data_type_t exccode, mach_exception_data_type_t excsubcode)
+{
+       mach_exception_data_type_t      code[EXCEPTION_CODE_MAX];
+       wait_interrupt_t                wsave;
+       kern_return_t kr = KERN_SUCCESS;

 
 

-               c_thr_exc_raise_state_id++;
-               state_cnt = _MachineStateCount[flavor];
-               kr = thread_getstatus(self, flavor,
-                                     (thread_state_t)state,
-                                     &state_cnt);
-               if (kr == KERN_SUCCESS) {
-                   kr = exception_raise_state_identity(exc_port,
-                               retrieve_thread_self_fast(self),
-                               retrieve_task_self_fast(self->task),
-                               exception,
-                               code, codeCnt,
-                               &flavor,
-                               state, state_cnt,
-                               state, &state_cnt);
-                   if (kr == MACH_MSG_SUCCESS)
-                       kr = thread_setstatus(self, flavor,
-                                             (thread_state_t)state,
-                                             state_cnt);
-               }
+       code[0] = exccode;
+       code[1] = excsubcode;

 
 

-               if (kr == KERN_SUCCESS || kr == MACH_RCV_PORT_DIED)
-                       return(KERN_SUCCESS);
-               return(KERN_FAILURE);
-       }
-       
-       default:
-               
-               return(KERN_FAILURE);
-       }/* switch */
-       return(KERN_FAILURE);
+       wsave = thread_interrupt_level(THREAD_UNINT);
+       kr = exception_triage(exception, code, EXCEPTION_CODE_MAX);
+       (void) thread_interrupt_level(wsave);
+       return kr;

 }
 
 
 }
 
 

-
-

 /*
 /*

- *     Handle interface for special perfomance monitoring
+ *     Handle interface for special performance monitoring

  *     This is a special case of the host exception handler
  */
  *     This is a special case of the host exception handler
  */

-
-kern_return_t sys_perf_notify(struct task *task,
-       exception_data_t code,
-       mach_msg_type_number_t codeCnt)
+kern_return_t
+sys_perf_notify(thread_t thread, int pid)

 {
 {

-       host_priv_t             hostp;
-       struct exception_action *excp;
-       thread_t                thread = current_thread();
-       ipc_port_t              xport;
-       kern_return_t   ret;
-       wait_interrupt_t        wsave;
-
-       hostp = host_priv_self();                               /* Get the host privileged ports */
-       excp = &hostp->exc_actions[EXC_RPC_ALERT];      /* Point to the RPC_ALERT action */
-
-       mutex_lock(&hostp->lock);                               /* Lock the priv port */
-       xport = excp->port;                                             /* Get the port for this exception */
-       if (!IP_VALID(xport)) {                                 /* Is it valid? */
-               mutex_unlock(&hostp->lock);                     /* Unlock */
-               return(KERN_FAILURE);                           /* Go away... */
+       host_priv_t             hostp;
+       ipc_port_t              xport;
+       wait_interrupt_t        wsave;
+       kern_return_t           ret;
+
+       hostp = host_priv_self();       /* Get the host privileged ports */
+       mach_exception_data_type_t      code[EXCEPTION_CODE_MAX];
+       code[0] = 0xFF000001;           /* Set terminate code */
+       code[1] = pid;          /* Pass out the pid */
+
+       struct task *task = thread->task;
+       xport = hostp->exc_actions[EXC_RPC_ALERT].port;
+
+       /* Make sure we're not catching our own exception */
+       if (!IP_VALID(xport) ||
+           !ip_active(xport) ||
+           task->itk_space == xport->data.receiver) {
+               return KERN_FAILURE;

        }
 
        }
 

-       ip_lock(xport);                                                 /* Lock the exception port */
-       if (!ip_active(xport)) {                                /* and is it active? */
-               ip_unlock(xport);                                       /* Nope, fail */
-               mutex_unlock(&hostp->lock);                     /* Unlock */
-               return(KERN_FAILURE);                           /* Go away... */
-       }
-
-       if (task->itk_space == xport->data.receiver) {  /* Are we trying to send to ourselves? */
-               ip_unlock(xport);                                       /* Yes, fail */
-               mutex_unlock(&hostp->lock);                     /* Unlock */
-               return(KERN_FAILURE);                           /* Go away... */
-       }
-       
-       ip_reference(xport);                                    /* Bump reference so it doesn't go away */
-       xport->ip_srights++;                                    /* Bump send rights */
-       ip_unlock(xport);                                               /* We can unlock it now */
-
-       mutex_unlock(&hostp->lock);                             /* All done with the lock */
-
-       wsave = thread_interrupt_level(THREAD_UNINT);   /* Make sure we aren't aborted here */
-       
-       ret = exception_raise(xport,                    /* Send the exception to the perf handler */
-               retrieve_thread_self_fast(thread),              /* Not always the dying guy */
-               retrieve_task_self_fast(thread->task),  /* Not always the dying guy */
-               EXC_RPC_ALERT,                                          /* Unused exception type until now */
-               code, codeCnt); 
-               
-       (void)thread_interrupt_level(wsave);    /* Restore interrupt level */                   
-
-       return(ret);                                                    /* Tell caller how it went */
+       wsave = thread_interrupt_level(THREAD_UNINT);
+       ret = exception_deliver(
+               thread,
+               EXC_RPC_ALERT,
+               code,
+               2,
+               hostp->exc_actions,
+               &hostp->lock);
+       (void)thread_interrupt_level(wsave);
+
+       return ret;

 }
 }