xnu-792.tar.gz

[apple/xnu.git] / osfmk / ipc / ipc_port.c

diff --git a/osfmk/ipc/ipc_port.c b/osfmk/ipc/ipc_port.c
index bddaecf3da5caa5f43c01798b6c1c5a048767eb2..8c5d894b5e4615f9a0b35c2c698ff30dcec3631f 100644 (file)
--- a/osfmk/ipc/ipc_port.c
+++ b/osfmk/ipc/ipc_port.c
@@ -1,24 +1,21 @@
 /*
 /*

- * Copyright (c) 2002,2000 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.

  *
  * @APPLE_LICENSE_HEADER_START@
  * 
  *
  * @APPLE_LICENSE_HEADER_START@
  * 

- * Copyright (c) 1999-2003 Apple Computer, Inc.  All Rights Reserved.
+ * The contents of this file constitute Original Code as defined in and
+ * are subject to the Apple Public Source License Version 1.1 (the
+ * "License").  You may not use this file except in compliance with the
+ * License.  Please obtain a copy of the License at
+ * http://www.apple.com/publicsource and read it before using this file.

  * 
  * 

- * 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.
- * 
- * The Original Code and all software distributed under the License are
- * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
+ * This 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,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,

- * 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 OR NON-INFRINGEMENT.  Please see the
+ * License for the specific language governing rights and limitations
+ * under the License.

  * 
  * @APPLE_LICENSE_HEADER_END@
  */
  * 
  * @APPLE_LICENSE_HEADER_END@
  */


@@ -188,8 +185,8 @@ ipc_port_dnrequest(
 
 kern_return_t
 ipc_port_dngrow(
 
 kern_return_t
 ipc_port_dngrow(

-       ipc_port_t      port,
-       int             target_size)
+       ipc_port_t              port,
+       ipc_table_elems_t       target_size)

 {
        ipc_table_size_t its;
        ipc_port_request_t otable, ntable;
 {
        ipc_table_size_t its;
        ipc_port_request_t otable, ntable;


@@ -255,6 +252,7 @@ ipc_port_dngrow(
                              (osize - 1) * sizeof(struct ipc_port_request));
                } else {
                        osize = 1;
                              (osize - 1) * sizeof(struct ipc_port_request));
                } else {
                        osize = 1;

+                       oits = 0;

                        free = 0;
                }
 
                        free = 0;
                }
 


@@ -297,9 +295,9 @@ ipc_port_dngrow(
 
 ipc_port_t
 ipc_port_dncancel(
 
 ipc_port_t
 ipc_port_dncancel(

-       ipc_port_t                      port,
-       mach_port_name_t                name,
-       ipc_port_request_index_t        index)
+       ipc_port_t                              port,
+       __assert_only mach_port_name_t  name,
+       ipc_port_request_index_t                index)

 {
        ipc_port_request_t ipr, table;
        ipc_port_t dnrequest;
 {
        ipc_port_request_t ipr, table;
        ipc_port_t dnrequest;


@@ -501,10 +499,6 @@ ipc_port_alloc(
 
        ipc_port_init(port, space, name);
 
 
        ipc_port_init(port, space, name);
 

-       if (task_is_classic(current_task())) {
-               IP_SET_CLASSIC(port);
-       }
-

        *namep = name;
        *portp = port;
 
        *namep = name;
        *portp = port;
 


@@ -544,10 +538,6 @@ ipc_port_alloc_name(
 
        ipc_port_init(port, space, name);
 
 
        ipc_port_init(port, space, name);
 

-       if (task_is_classic(current_task())) {
-               IP_SET_CLASSIC(port);
-       }
-

        *portp = port;
 
        return KERN_SUCCESS;
        *portp = port;
 
        return KERN_SUCCESS;


@@ -561,7 +551,7 @@ ipc_port_alloc_name(
  */
 void
 ipc_port_dnnotify(
  */
 void
 ipc_port_dnnotify(

-       ipc_port_t              port,
+       __unused ipc_port_t     port,

        ipc_port_request_t      dnrequests)
 {
        ipc_table_size_t        its = dnrequests->ipr_size;
        ipc_port_request_t      dnrequests)
 {
        ipc_table_size_t        its = dnrequests->ipr_size;


@@ -570,7 +560,7 @@ ipc_port_dnnotify(
 
        for (index = 1; index < size; index++) {
                ipc_port_request_t      ipr = &dnrequests[index];
 
        for (index = 1; index < size; index++) {
                ipc_port_request_t      ipr = &dnrequests[index];

-               mach_port_name_t                name = ipr->ipr_name;
+               mach_port_name_t        name = ipr->ipr_name;

                ipc_port_t              soright;
 
                if (name == MACH_PORT_NULL)
                ipc_port_t              soright;
 
                if (name == MACH_PORT_NULL)


@@ -604,7 +594,6 @@ ipc_port_destroy(
 {
        ipc_port_t pdrequest, nsrequest;
        ipc_mqueue_t mqueue;
 {
        ipc_port_t pdrequest, nsrequest;
        ipc_mqueue_t mqueue;

-       ipc_kmsg_queue_t kmqueue;

        ipc_kmsg_t kmsg;
        ipc_port_request_t dnrequests;
 
        ipc_kmsg_t kmsg;
        ipc_port_request_t dnrequests;
 


@@ -1010,11 +999,6 @@ ipc_port_release_send(
                mscount = port->ip_mscount;
                ip_unlock(port);
                ipc_notify_no_senders(nsrequest, mscount);
                mscount = port->ip_mscount;
                ip_unlock(port);
                ipc_notify_no_senders(nsrequest, mscount);

-               /*
-                * Check that there are no other locks taken, because
-                * [norma_]ipc_notify_no_senders routines may block.
-                */
-               check_simple_locks();

        } else
                ip_unlock(port);
 }
        } else
                ip_unlock(port);
 }


@@ -1147,8 +1131,8 @@ ipc_port_alloc_special(
 
 void
 ipc_port_dealloc_special(
 
 void
 ipc_port_dealloc_special(

-       ipc_port_t      port,
-       ipc_space_t     space)
+       ipc_port_t                      port,
+       __assert_only ipc_space_t       space)

 {
        ip_lock(port);
        assert(ip_active(port));
 {
        ip_lock(port);
        assert(ip_active(port));


@@ -1172,6 +1156,8 @@ ipc_port_dealloc_special(
 
 
 #if    MACH_ASSERT
 
 
 #if    MACH_ASSERT

+#include <kern/machine.h>
+

 /*
  *     Keep a list of all allocated ports.
  *     Allocation is intercepted via ipc_port_init;
 /*
  *     Keep a list of all allocated ports.
  *     Allocation is intercepted via ipc_port_init;


@@ -1202,7 +1188,7 @@ void
 ipc_port_debug_init(void)
 {
        queue_init(&port_alloc_queue);
 ipc_port_debug_init(void)
 {
        queue_init(&port_alloc_queue);

-       mutex_init(&port_alloc_queue_lock, ETAP_IPC_PORT_ALLOCQ);
+       mutex_init(&port_alloc_queue_lock, 0);

 }
 
 
 }
 
 


@@ -1216,7 +1202,7 @@ ipc_port_init_debug(
 {
        unsigned int    i;
 
 {
        unsigned int    i;
 

-       port->ip_thread = (unsigned long) current_thread();
+       port->ip_thread = current_thread();

        port->ip_timetrack = port_timestamp++;
        for (i = 0; i < IP_CALLSTACK_MAX; ++i)
                port->ip_callstack[i] = 0;
        port->ip_timetrack = port_timestamp++;
        for (i = 0; i < IP_CALLSTACK_MAX; ++i)
                port->ip_callstack[i] = 0;


@@ -1246,18 +1232,24 @@ ipc_port_init_debug(
  *     This routine should be invoked JUST prior to
  *     deallocating the actual memory occupied by the port.
  */
  *     This routine should be invoked JUST prior to
  *     deallocating the actual memory occupied by the port.
  */

+#if 1

 void
 ipc_port_track_dealloc(
 void
 ipc_port_track_dealloc(

-       ipc_port_t      port)
+       __unused ipc_port_t     port)
+{
+}
+#else
+void
+ipc_port_track_dealloc(
+       ipc_port_t              port)

 {
 {

-#if 0

        mutex_lock(&port_alloc_queue_lock);
        assert(port_count > 0);
        --port_count;
        queue_remove(&port_alloc_queue, port, ipc_port_t, ip_port_links);
        mutex_unlock(&port_alloc_queue_lock);
        mutex_lock(&port_alloc_queue_lock);
        assert(port_count > 0);
        --port_count;
        queue_remove(&port_alloc_queue, port, ipc_port_t, ip_port_links);
        mutex_unlock(&port_alloc_queue_lock);

-#endif

 }
 }

+#endif

 
 #endif /* MACH_ASSERT */
 
 
 #endif /* MACH_ASSERT */
 


@@ -1268,29 +1260,11 @@ ipc_port_track_dealloc(
 #include <ddb/db_print.h>
 
 #define        printf  kdbprintf
 #include <ddb/db_print.h>
 
 #define        printf  kdbprintf

-extern int db_indent;

 
 int
 db_port_queue_print(
        ipc_port_t      port);
 
 
 int
 db_port_queue_print(
        ipc_port_t      port);
 

-/*
- * ipc_entry_print - pretty-print an ipc_entry
- */
-static void ipc_entry_print(struct ipc_entry *, char *); /* forward */
-
-static void ipc_entry_print(struct ipc_entry *iep, char *tag)
-{
-       ipc_entry_bits_t bits = iep->ie_bits;
-
-       iprintf("%s @", tag);
-       printf(" 0x%x, bits=%x object=%x\n", iep, bits, iep->ie_object);
-       db_indent += 2;
-       iprintf("urefs=%x ", IE_BITS_UREFS(bits));
-       printf("type=%x gen=%x\n", IE_BITS_TYPE(bits), IE_BITS_GEN(bits));
-       db_indent -= 2;
-}
-

 /*
  *     Routine:        ipc_port_print
  *     Purpose:
 /*
  *     Routine:        ipc_port_print
  *     Purpose:


@@ -1300,12 +1274,11 @@ int     ipc_port_print_long = 0;        /* set for more detail */
 
 void
 ipc_port_print(
 
 void
 ipc_port_print(

-       ipc_port_t      port,
-       boolean_t       have_addr,
-       db_expr_t       count,
-       char            *modif)
+       ipc_port_t              port,
+       __unused boolean_t      have_addr,
+       __unused db_expr_t      count,
+       char                    *modif)

 {
 {

-       extern int      db_indent;

        db_addr_t       task;
        int             task_id;
        int             nmsgs;
        db_addr_t       task;
        int             task_id;
        int             nmsgs;


@@ -1346,7 +1319,7 @@ ipc_port_print(
                        printf("reply");
                else if (port->ip_receiver == default_pager_space)
                        printf("default_pager");
                        printf("reply");
                else if (port->ip_receiver == default_pager_space)
                        printf("default_pager");

-               else if (task = db_task_from_space(port->ip_receiver, &task_id))
+               else if ((task = db_task_from_space(port->ip_receiver, &task_id)) != (db_addr_t)0)

                        printf("task%d at 0x%x", task_id, task);
                else
                        printf("unknown");
                        printf("task%d at 0x%x", task_id, task);
                else
                        printf("unknown");


@@ -1448,7 +1421,7 @@ print_type_ports(type, dead)
        for (port = (ipc_port_t)first_element(ipc_object_zones[IOT_PORT]);
             port;
             port = (ipc_port_t)next_element(ipc_object_zones[IOT_PORT], 
        for (port = (ipc_port_t)first_element(ipc_object_zones[IOT_PORT]);
             port;
             port = (ipc_port_t)next_element(ipc_object_zones[IOT_PORT], 

-                                            (vm_offset_t)port))
+                                            port))

                if (ip_kotype(port) == type &&
                    (!dead || !ip_active(port))) {
                        if (++n % 5)
                if (ip_kotype(port) == type &&
                    (!dead || !ip_active(port))) {
                        if (++n % 5)


@@ -1488,7 +1461,7 @@ print_ports(void)
        for (port = (ipc_port_t)first_element(ipc_object_zones[IOT_PORT]);
             port;
             port = (ipc_port_t)next_element(ipc_object_zones[IOT_PORT], 
        for (port = (ipc_port_t)first_element(ipc_object_zones[IOT_PORT]);
             port;
             port = (ipc_port_t)next_element(ipc_object_zones[IOT_PORT], 

-                                            (vm_offset_t)port)) {
+                                            port)) {

                total_port_count++;
                if (ip_kotype(port) >= IKOT_MAX_TYPE) {
                        port_types[IKOT_UNKNOWN].total_count++;
                total_port_count++;
                if (ip_kotype(port) >= IKOT_MAX_TYPE) {
                        port_types[IKOT_UNKNOWN].total_count++;


@@ -1559,10 +1532,10 @@ print_ports(void)
  *
  */
 
  *
  */
 

-#define        KMSG_MATCH_FIELD(kmsg)  ((unsigned int) kmsg->ikm_header.msgh_id)
+#define        KMSG_MATCH_FIELD(kmsg)  (kmsg->ikm_header->msgh_id)

 #define        DKQP_LONG(kmsg) FALSE
 #define        DKQP_LONG(kmsg) FALSE

-char   *dkqp_long_format = "(%3d) <%10d> 0x%x   %10d %10d\n";
-char   *dkqp_format = "(%3d) <%10d> 0x%x   %10d %10d\n";
+const char     *dkqp_long_format = "(%3d) <%10d> 0x%x   %10d %10d\n";
+const char     *dkqp_format = "(%3d) <%10d> 0x%x   %10d %10d\n";

 
 int
 db_kmsg_queue_print(
 
 int
 db_kmsg_queue_print(


@@ -1597,7 +1570,7 @@ db_kmsg_queue_print(
                if (DKQP_LONG(kmsg))
                        inline_total += kmsg->ikm_size;
                else
                if (DKQP_LONG(kmsg))
                        inline_total += kmsg->ikm_size;
                else

-                       inline_total += kmsg->ikm_header.msgh_size;
+                       inline_total += kmsg->ikm_header->msgh_size;

        }
        iprintf(DKQP_LONG(kmsg) ? dkqp_long_format : dkqp_format,
                icount, cur_id, ikmsg, inline_total, ool_total);
        }
        iprintf(DKQP_LONG(kmsg) ? dkqp_long_format : dkqp_format,
                icount, cur_id, ikmsg, inline_total, ool_total);


@@ -1658,7 +1631,7 @@ typedef struct port_item {
 
 #define        ITEM_MAX        400
 typedef struct port_track {
 
 #define        ITEM_MAX        400
 typedef struct port_track {

-       char            *name;
+       const char      *name;

        unsigned long   max;
        unsigned long   warning;
        port_item       items[ITEM_MAX];
        unsigned long   max;
        unsigned long   warning;
        port_item       items[ITEM_MAX];


@@ -1670,7 +1643,7 @@ port_track        port_spaces;            /* match against ipc spaces */
 
 void           port_track_init(
                        port_track      *trackp,
 
 void           port_track_init(
                        port_track      *trackp,

-                       char            *name);
+                       const char      *name);

 void           port_item_add(
                        port_track      *trackp,
                        unsigned long   item);
 void           port_item_add(
                        port_track      *trackp,
                        unsigned long   item);


@@ -1685,7 +1658,7 @@ void              port_callers_print(
 void
 port_track_init(
        port_track      *trackp,
 void
 port_track_init(
        port_track      *trackp,

-       char            *name)
+       const char      *name)

 {
        port_item       *i;
 
 {
        port_item       *i;
 


@@ -1807,7 +1780,6 @@ db_port_walk(
        unsigned int    ref_counts[MAX_REFS];
        unsigned int    inactive[MAX_REFS];
        unsigned int    ipc_ports = 0;
        unsigned int    ref_counts[MAX_REFS];
        unsigned int    inactive[MAX_REFS];
        unsigned int    ipc_ports = 0;

-       unsigned int    proxies = 0, principals = 0;

 
        iprintf("Allocated port count is %d\n", port_count);
        no_receiver = no_match = ref_overflow = 0;
 
        iprintf("Allocated port count is %d\n", port_count);
        no_receiver = no_match = ref_overflow = 0;


@@ -1825,7 +1797,7 @@ db_port_walk(
                iprintf("Walking all ports.\n");
 
        queue_iterate(&port_alloc_queue, port, ipc_port_t, ip_port_links) {
                iprintf("Walking all ports.\n");
 
        queue_iterate(&port_alloc_queue, port, ipc_port_t, ip_port_links) {

-               char    *port_type;
+               const char *port_type;

 
                port_type = " IPC port";
                if (ip_active(port))
 
                port_type = " IPC port";
                if (ip_active(port))