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

/*
 * Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.
 *
 * @APPLE_LICENSE_OSREFERENCE_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 
 * 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, 
 * 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.
 *
 * @APPLE_LICENSE_OSREFERENCE_HEADER_END@
 */
/*
 * @OSF_COPYRIGHT@
 */
/* 
 * Mach Operating System
 * Copyright (c) 1991,1990,1989 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.
 * 
 * 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
 * 
 *  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.
 */
/*
 */
/*
 *	File:	ipc/ipc_port.h
 *	Author:	Rich Draves
 *	Date:	1989
 *
 *	Definitions for ports.
 */

#ifndef	_IPC_IPC_PORT_H_
#define _IPC_IPC_PORT_H_

#include <norma_vm.h>
#include <mach_rt.h>
#include <mach_assert.h>
#include <mach_debug.h>

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

#include <kern/kern_types.h>

#include <ipc/ipc_types.h>
#include <ipc/ipc_object.h>
#include <ipc/ipc_mqueue.h>
#include <ipc/ipc_space.h>

/*
 *  A receive right (port) can be in four states:
 *	1) dead (not active, ip_timestamp has death time)
 *	2) in a space (ip_receiver_name != 0, ip_receiver points
 *	to the space but doesn't hold a ref for it)
 *	3) in transit (ip_receiver_name == 0, ip_destination points
 *	to the destination port and holds a ref for it)
 *	4) in limbo (ip_receiver_name == 0, ip_destination == IP_NULL)
 *
 *  If the port is active, and ip_receiver points to some space,
 *  then ip_receiver_name != 0, and that space holds receive rights.
 *  If the port is not active, then ip_timestamp contains a timestamp
 *  taken when the port was destroyed.
 */

typedef unsigned int ipc_port_timestamp_t;

struct ipc_port {

	/*
	 * Initial sub-structure in common with ipc_pset and rpc_port
	 * First element is an ipc_object
	 */
	struct ipc_object ip_object;

	union {
		struct ipc_space *receiver;
		struct ipc_port *destination;
		ipc_port_timestamp_t timestamp;
	} data;

	ipc_kobject_t ip_kobject;
	mach_port_mscount_t ip_mscount;
	mach_port_rights_t ip_srights;
	mach_port_rights_t ip_sorights;

	struct ipc_port *ip_nsrequest;
	struct ipc_port *ip_pdrequest;
	struct ipc_port_request *ip_dnrequests;

	unsigned int ip_pset_count;
	struct ipc_mqueue ip_messages;
	struct ipc_kmsg *ip_premsg;

#if	NORMA_VM
	/*
	 *	These fields are needed for the use of XMM.
	 *	Few ports need this information; it should
	 *	be kept in XMM instead (TBD).  XXX
	 */
	long		ip_norma_xmm_object_refs;
	struct ipc_port	*ip_norma_xmm_object;
#endif

#if	MACH_ASSERT
#define	IP_NSPARES		10
#define	IP_CALLSTACK_MAX	10
	queue_chain_t	ip_port_links;	/* all allocated ports */
	thread_t	ip_thread;	/* who made me?  thread context */
	unsigned long	ip_timetrack;	/* give an idea of "when" created */
	natural_t	ip_callstack[IP_CALLSTACK_MAX]; /* stack trace */
	unsigned long	ip_spares[IP_NSPARES]; /* for debugging */
#endif	/* MACH_ASSERT */
	int		alias;
};


#define ip_references		ip_object.io_references
#define ip_bits			ip_object.io_bits
#define ip_receiver_name	ip_object.io_receiver_name

#define	ip_receiver		data.receiver
#define	ip_destination		data.destination
#define	ip_timestamp		data.timestamp

#define IP_NULL			IPC_PORT_NULL
#define IP_DEAD			IPC_PORT_DEAD
#define	IP_VALID(port)		IPC_PORT_VALID(port)

#define	ip_active(port)		io_active(&(port)->ip_object)
#define	ip_lock_init(port)	io_lock_init(&(port)->ip_object)
#define	ip_lock(port)		io_lock(&(port)->ip_object)
#define	ip_lock_try(port)	io_lock_try(&(port)->ip_object)
#define	ip_unlock(port)		io_unlock(&(port)->ip_object)
#define	ip_check_unlock(port)	io_check_unlock(&(port)->ip_object)

#define	ip_reference(port)	io_reference(&(port)->ip_object)
#define	ip_release(port)	io_release(&(port)->ip_object)

#define	ip_kotype(port)		io_kotype(&(port)->ip_object)

/*
 * JMM - Preallocation flag
 * This flag indicates that there is a message buffer preallocated for this
 * port and we should use that when sending (from the kernel) rather than
 * allocate a new one.  This avoids deadlocks during notification message
 * sends by critical system threads (which may be needed to free memory and
 * therefore cannot be blocked waiting for memory themselves).
 */
#define	IP_BIT_PREALLOC		0x00008000	/* preallocated mesg */
#define IP_PREALLOC(port)	((port)->ip_bits & IP_BIT_PREALLOC)

#define IP_SET_PREALLOC(port, kmsg)				 	\
MACRO_BEGIN								\
	(port)->ip_bits |= IP_BIT_PREALLOC;				\
	(port)->ip_premsg = (kmsg);					\
MACRO_END

#define IP_CLEAR_PREALLOC(port, kmsg)				 	\
MACRO_BEGIN								\
	assert((port)->ip_premsg == kmsg);				\
	(port)->ip_bits &= ~IP_BIT_PREALLOC;				\
	(port)->ip_premsg = IKM_NULL;					\
MACRO_END


struct ipc_port_request {
	union {
		struct ipc_port *port;
		ipc_port_request_index_t index;
	} notify;

	union {
		mach_port_name_t name;
		struct ipc_table_size *size;
	} name;
};

#define	ipr_next		notify.index
#define	ipr_size		name.size

#define	ipr_soright		notify.port
#define	ipr_name		name.name

/*
 *	Taking the ipc_port_multiple lock grants the privilege
 *	to lock multiple ports at once.  No ports must locked
 *	when it is taken.
 */

decl_mutex_data(extern,ipc_port_multiple_lock_data)

#define	ipc_port_multiple_lock_init()					\
		mutex_init(&ipc_port_multiple_lock_data, 0)

#define	ipc_port_multiple_lock()					\
		mutex_lock(&ipc_port_multiple_lock_data)

#define	ipc_port_multiple_unlock()					\
		mutex_unlock(&ipc_port_multiple_lock_data)

/*
 *	The port timestamp facility provides timestamps
 *	for port destruction.  It is used to serialize
 *	mach_port_names with port death.
 */

decl_mutex_data(extern,ipc_port_timestamp_lock_data)
extern ipc_port_timestamp_t ipc_port_timestamp_data;

#define	ipc_port_timestamp_lock_init()					\
		mutex_init(&ipc_port_timestamp_lock_data, 0)

#define	ipc_port_timestamp_lock()					\
		mutex_lock(&ipc_port_timestamp_lock_data)

#define	ipc_port_timestamp_unlock()					\
		mutex_unlock(&ipc_port_timestamp_lock_data)

/* Retrieve a port timestamp value */
extern ipc_port_timestamp_t ipc_port_timestamp(void);

/*
 *	Compares two timestamps, and returns TRUE if one
 *	happened before two.  Note that this formulation
 *	works when the timestamp wraps around at 2^32,
 *	as long as one and two aren't too far apart.
 */

#define	IP_TIMESTAMP_ORDER(one, two)	((int) ((one) - (two)) < 0)

#define	ipc_port_translate_receive(space, name, portp)			\
		ipc_object_translate((space), (name),			\
				     MACH_PORT_RIGHT_RECEIVE,		\
				     (ipc_object_t *) (portp))

#define	ipc_port_translate_send(space, name, portp)			\
		ipc_object_translate((space), (name),			\
				     MACH_PORT_RIGHT_SEND,		\
				     (ipc_object_t *) (portp))

/* Allocate a dead-name request slot */
extern kern_return_t
ipc_port_dnrequest(
	ipc_port_t			port,
	mach_port_name_t		name,
	ipc_port_t			soright,
	ipc_port_request_index_t	*indexp);

/* Grow a port's table of dead-name requests */
extern kern_return_t ipc_port_dngrow(
	ipc_port_t			port,
	ipc_table_elems_t		target_size);

/* Cancel a dead-name request and return the send-once right */
extern ipc_port_t ipc_port_dncancel(
	ipc_port_t			port,
	mach_port_name_t		name,
	ipc_port_request_index_t	index);

#define	ipc_port_dnrename(port, index, oname, nname)			\
MACRO_BEGIN								\
	ipc_port_request_t ipr, table;					\
									\
	assert(ip_active(port));					\
									\
	table = port->ip_dnrequests;					\
	assert(table != IPR_NULL);					\
									\
	ipr = &table[index];						\
	assert(ipr->ipr_name == oname);					\
									\
	ipr->ipr_name = nname;						\
MACRO_END

/* Make a port-deleted request */
extern void ipc_port_pdrequest(
	ipc_port_t	port,
	ipc_port_t	notify,
	ipc_port_t	*previousp);

/* Make a no-senders request */
extern void ipc_port_nsrequest(
	ipc_port_t		port,
	mach_port_mscount_t	sync,
	ipc_port_t		notify,
	ipc_port_t		*previousp);

#define	ipc_port_set_mscount(port, mscount)				\
MACRO_BEGIN								\
	assert(ip_active(port));					\
									\
	(port)->ip_mscount = (mscount);					\
MACRO_END

/* Prepare a receive right for transmission/destruction */
extern void ipc_port_clear_receiver(
	ipc_port_t		port);

/* Initialize a newly-allocated port */
extern void ipc_port_init(
	ipc_port_t		port,
	ipc_space_t		space,
	mach_port_name_t	name);

/* Allocate a port */
extern kern_return_t ipc_port_alloc(
	ipc_space_t		space,
	mach_port_name_t	*namep,
	ipc_port_t		*portp);

/* Allocate a port, with a specific name */
extern kern_return_t ipc_port_alloc_name(
	ipc_space_t		space,
	mach_port_name_t	name,
	ipc_port_t		*portp);

/* Generate dead name notifications */
extern void ipc_port_dnnotify(
	ipc_port_t		port,
	ipc_port_request_t	dnrequests);

/* Destroy a port */
extern void ipc_port_destroy(
	ipc_port_t	port);

/* Check if queueing "port" in a message for "dest" would create a circular 
   group of ports and messages */
extern boolean_t
ipc_port_check_circularity(
	ipc_port_t	port,
	ipc_port_t	dest);

/* Make a send-once notify port from a receive right */
extern ipc_port_t ipc_port_lookup_notify(
	ipc_space_t		space, 
	mach_port_name_t 	name);

/* Make a naked send right from a receive right - port locked and active */
extern ipc_port_t ipc_port_make_send_locked(
	ipc_port_t	port);

/* Make a naked send right from a receive right */
extern ipc_port_t ipc_port_make_send(
	ipc_port_t	port);

/* Make a naked send right from another naked send right */
extern ipc_port_t ipc_port_copy_send(
	ipc_port_t	port);

/* Copyout a naked send right */
extern mach_port_name_t ipc_port_copyout_send(
	ipc_port_t	sright,
	ipc_space_t	space);

/* Release a (valid) naked send right */
extern void ipc_port_release_send(
	ipc_port_t	port);

/* Make a naked send-once right from a receive right */
extern ipc_port_t ipc_port_make_sonce(
	ipc_port_t	port);

/* Release a naked send-once right */
extern void ipc_port_release_sonce(
	ipc_port_t	port);

/* Release a naked (in limbo or in transit) receive right */
extern void ipc_port_release_receive(
	ipc_port_t	port);

/* Allocate a port in a special space */
extern ipc_port_t ipc_port_alloc_special(
	ipc_space_t	space);

/* Deallocate a port in a special space */
extern void ipc_port_dealloc_special(
	ipc_port_t	port,
	ipc_space_t	space);

#if	MACH_ASSERT
/* Track low-level port deallocation */
extern void ipc_port_track_dealloc(
	ipc_port_t	port);

/* Initialize general port debugging state */
extern void ipc_port_debug_init(void);
#endif	/* MACH_ASSERT */

#define	ipc_port_alloc_kernel()		\
		ipc_port_alloc_special(ipc_space_kernel)
#define	ipc_port_dealloc_kernel(port)	\
		ipc_port_dealloc_special((port), ipc_space_kernel)

#define	ipc_port_alloc_reply()		\
		ipc_port_alloc_special(ipc_space_reply)
#define	ipc_port_dealloc_reply(port)	\
		ipc_port_dealloc_special((port), ipc_space_reply)

#define	ipc_port_reference(port)	\
		ipc_object_reference(&(port)->ip_object)

#define	ipc_port_release(port)		\
		ipc_object_release(&(port)->ip_object)

#endif	/* _IPC_IPC_PORT_H_ */
Commit	Line	Data
1c79356b	1	/*
91447636	2	* Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.
1c79356b	3	*
8ad349bb	4	* @APPLE_LICENSE_OSREFERENCE_HEADER_START@
1c79356b	5	*
8ad349bb A	6	* This file contains Original Code and/or Modifications of Original Code
	7	* as defined in and that are subject to the Apple Public Source License
	8	* Version 2.0 (the 'License'). You may not use this file except in
	9	* compliance with the License. The rights granted to you under the
	10	* License may not be used to create, or enable the creation or
	11	* redistribution of, unlawful or unlicensed copies of an Apple operating
	12	* system, or to circumvent, violate, or enable the circumvention or
	13	* violation of, any terms of an Apple operating system software license
	14	* agreement.
	15	*
	16	* Please obtain a copy of the License at
	17	* http://www.opensource.apple.com/apsl/ and read it before using this
	18	* file.
	19	*
	20	* The Original Code and all software distributed under the License are
	21	* distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
	22	* EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
	23	* INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
	24	* FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
	25	* Please see the License for the specific language governing rights and
	26	* limitations under the License.
	27	*
	28	* @APPLE_LICENSE_OSREFERENCE_HEADER_END@
1c79356b A	29	*/
	30	/*
	31	* @OSF_COPYRIGHT@
	32	*/
	33	/*
	34	* Mach Operating System
	35	* Copyright (c) 1991,1990,1989 Carnegie Mellon University
	36	* All Rights Reserved.
	37	*
	38	* Permission to use, copy, modify and distribute this software and its
	39	* documentation is hereby granted, provided that both the copyright
	40	* notice and this permission notice appear in all copies of the
	41	* software, derivative works or modified versions, and any portions
	42	* thereof, and that both notices appear in supporting documentation.
	43	*
	44	* CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
	45	* CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR
	46	* ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
	47	*
	48	* Carnegie Mellon requests users of this software to return to
	49	*
	50	* Software Distribution Coordinator or Software.Distribution@CS.CMU.EDU
	51	* School of Computer Science
	52	* Carnegie Mellon University
	53	* Pittsburgh PA 15213-3890
	54	*
	55	* any improvements or extensions that they make and grant Carnegie Mellon
	56	* the rights to redistribute these changes.
	57	*/
	58	/*
	59	*/
	60	/*
	61	* File: ipc/ipc_port.h
	62	* Author: Rich Draves
	63	* Date: 1989
	64	*
	65	* Definitions for ports.
	66	*/
	67
	68	#ifndef _IPC_IPC_PORT_H_
	69	#define _IPC_IPC_PORT_H_
	70
	71	#include <norma_vm.h>
	72	#include <mach_rt.h>
	73	#include <mach_assert.h>
	74	#include <mach_debug.h>
	75
91447636	76	#include <mach/mach_types.h>
1c79356b A	77	#include <mach/boolean.h>
1c79356b A	78	#include <mach/kern_return.h>
1c79356b	79	#include <mach/port.h>
1c79356b	80
91447636 A	81	#include <kern/kern_types.h>
	82
	83	#include <ipc/ipc_types.h>
1c79356b A	84	#include <ipc/ipc_object.h>
1c79356b A	85	#include <ipc/ipc_mqueue.h>
1c79356b A	86	#include <ipc/ipc_space.h>
	87
	88	/*
	89	* A receive right (port) can be in four states:
	90	* 1) dead (not active, ip_timestamp has death time)
	91	* 2) in a space (ip_receiver_name != 0, ip_receiver points
	92	* to the space but doesn't hold a ref for it)
	93	* 3) in transit (ip_receiver_name == 0, ip_destination points
	94	* to the destination port and holds a ref for it)
	95	* 4) in limbo (ip_receiver_name == 0, ip_destination == IP_NULL)
	96	*
	97	* If the port is active, and ip_receiver points to some space,
	98	* then ip_receiver_name != 0, and that space holds receive rights.
	99	* If the port is not active, then ip_timestamp contains a timestamp
	100	* taken when the port was destroyed.
	101	*/
	102
	103	typedef unsigned int ipc_port_timestamp_t;
	104
1c79356b A	105	struct ipc_port {
	106
	107	/*
	108	* Initial sub-structure in common with ipc_pset and rpc_port
	109	* First element is an ipc_object
	110	*/
	111	struct ipc_object ip_object;
	112
	113	union {
	114	struct ipc_space *receiver;
	115	struct ipc_port *destination;
	116	ipc_port_timestamp_t timestamp;
	117	} data;
	118
	119	ipc_kobject_t ip_kobject;
1c79356b A	120	mach_port_mscount_t ip_mscount;
	121	mach_port_rights_t ip_srights;
	122	mach_port_rights_t ip_sorights;
	123
	124	struct ipc_port *ip_nsrequest;
	125	struct ipc_port *ip_pdrequest;
	126	struct ipc_port_request *ip_dnrequests;
	127
	128	unsigned int ip_pset_count;
	129	struct ipc_mqueue ip_messages;
	130	struct ipc_kmsg *ip_premsg;
	131
	132	#if NORMA_VM
	133	/*
	134	* These fields are needed for the use of XMM.
	135	* Few ports need this information; it should
	136	* be kept in XMM instead (TBD). XXX
	137	*/
	138	long ip_norma_xmm_object_refs;
	139	struct ipc_port *ip_norma_xmm_object;
	140	#endif
	141
	142	#if MACH_ASSERT
	143	#define IP_NSPARES 10
	144	#define IP_CALLSTACK_MAX 10
	145	queue_chain_t ip_port_links; /* all allocated ports */
91447636	146	thread_t ip_thread; /* who made me? thread context */
1c79356b A	147	unsigned long ip_timetrack; /* give an idea of "when" created */
	148	natural_t ip_callstack[IP_CALLSTACK_MAX]; /* stack trace */
	149	unsigned long ip_spares[IP_NSPARES]; /* for debugging */
	150	#endif /* MACH_ASSERT */
	151	int alias;
	152	};
	153
	154
	155	#define ip_references ip_object.io_references
	156	#define ip_bits ip_object.io_bits
	157	#define ip_receiver_name ip_object.io_receiver_name
	158
1c79356b A	159	#define ip_receiver data.receiver
	160	#define ip_destination data.destination
	161	#define ip_timestamp data.timestamp
	162
	163	#define IP_NULL IPC_PORT_NULL
	164	#define IP_DEAD IPC_PORT_DEAD
	165	#define IP_VALID(port) IPC_PORT_VALID(port)
	166
	167	#define ip_active(port) io_active(&(port)->ip_object)
	168	#define ip_lock_init(port) io_lock_init(&(port)->ip_object)
	169	#define ip_lock(port) io_lock(&(port)->ip_object)
	170	#define ip_lock_try(port) io_lock_try(&(port)->ip_object)
	171	#define ip_unlock(port) io_unlock(&(port)->ip_object)
	172	#define ip_check_unlock(port) io_check_unlock(&(port)->ip_object)
	173
	174	#define ip_reference(port) io_reference(&(port)->ip_object)
	175	#define ip_release(port) io_release(&(port)->ip_object)
	176
	177	#define ip_kotype(port) io_kotype(&(port)->ip_object)
	178
	179	/*
	180	* JMM - Preallocation flag
	181	* This flag indicates that there is a message buffer preallocated for this
	182	* port and we should use that when sending (from the kernel) rather than
	183	* allocate a new one. This avoids deadlocks during notification message
	184	* sends by critical system threads (which may be needed to free memory and
	185	* therefore cannot be blocked waiting for memory themselves).
	186	*/
	187	#define IP_BIT_PREALLOC 0x00008000 /* preallocated mesg */
	188	#define IP_PREALLOC(port) ((port)->ip_bits & IP_BIT_PREALLOC)
	189
	190	#define IP_SET_PREALLOC(port, kmsg) \
	191	MACRO_BEGIN \
	192	(port)->ip_bits \|= IP_BIT_PREALLOC; \
	193	(port)->ip_premsg = (kmsg); \
	194	MACRO_END
	195
	196	#define IP_CLEAR_PREALLOC(port, kmsg) \
	197	MACRO_BEGIN \
	198	assert((port)->ip_premsg == kmsg); \
	199	(port)->ip_bits &= ~IP_BIT_PREALLOC; \
	200	(port)->ip_premsg = IKM_NULL; \
	201	MACRO_END
	202
1c79356b	203
91447636	204	struct ipc_port_request {
1c79356b A	205	union {
	206	struct ipc_port *port;
	207	ipc_port_request_index_t index;
	208	} notify;
	209
	210	union {
	211	mach_port_name_t name;
	212	struct ipc_table_size *size;
	213	} name;
91447636	214	};
1c79356b A	215
	216	#define ipr_next notify.index
	217	#define ipr_size name.size
	218
	219	#define ipr_soright notify.port
	220	#define ipr_name name.name
	221
1c79356b A	222	/*
	223	* Taking the ipc_port_multiple lock grants the privilege
	224	* to lock multiple ports at once. No ports must locked
	225	* when it is taken.
	226	*/
	227
	228	decl_mutex_data(extern,ipc_port_multiple_lock_data)
	229
	230	#define ipc_port_multiple_lock_init() \
91447636	231	mutex_init(&ipc_port_multiple_lock_data, 0)
1c79356b A	232
	233	#define ipc_port_multiple_lock() \
	234	mutex_lock(&ipc_port_multiple_lock_data)
	235
	236	#define ipc_port_multiple_unlock() \
	237	mutex_unlock(&ipc_port_multiple_lock_data)
	238
	239	/*
	240	* The port timestamp facility provides timestamps
	241	* for port destruction. It is used to serialize
	242	* mach_port_names with port death.
	243	*/
	244
	245	decl_mutex_data(extern,ipc_port_timestamp_lock_data)
	246	extern ipc_port_timestamp_t ipc_port_timestamp_data;
	247
	248	#define ipc_port_timestamp_lock_init() \
91447636	249	mutex_init(&ipc_port_timestamp_lock_data, 0)
1c79356b A	250
	251	#define ipc_port_timestamp_lock() \
	252	mutex_lock(&ipc_port_timestamp_lock_data)
	253
	254	#define ipc_port_timestamp_unlock() \
	255	mutex_unlock(&ipc_port_timestamp_lock_data)
	256
	257	/* Retrieve a port timestamp value */
	258	extern ipc_port_timestamp_t ipc_port_timestamp(void);
	259
	260	/*
	261	* Compares two timestamps, and returns TRUE if one
	262	* happened before two. Note that this formulation
	263	* works when the timestamp wraps around at 2^32,
	264	* as long as one and two aren't too far apart.
	265	*/
	266
	267	#define IP_TIMESTAMP_ORDER(one, two) ((int) ((one) - (two)) < 0)
	268
	269	#define ipc_port_translate_receive(space, name, portp) \
	270	ipc_object_translate((space), (name), \
	271	MACH_PORT_RIGHT_RECEIVE, \
	272	(ipc_object_t *) (portp))
	273
	274	#define ipc_port_translate_send(space, name, portp) \
	275	ipc_object_translate((space), (name), \
	276	MACH_PORT_RIGHT_SEND, \
	277	(ipc_object_t *) (portp))
	278
	279	/* Allocate a dead-name request slot */
	280	extern kern_return_t
	281	ipc_port_dnrequest(
	282	ipc_port_t port,
	283	mach_port_name_t name,
	284	ipc_port_t soright,
	285	ipc_port_request_index_t *indexp);
	286
	287	/* Grow a port's table of dead-name requests */
	288	extern kern_return_t ipc_port_dngrow(
91447636 A	289	ipc_port_t port,
91447636 A	290	ipc_table_elems_t target_size);
1c79356b A	291
	292	/* Cancel a dead-name request and return the send-once right */
	293	extern ipc_port_t ipc_port_dncancel(
	294	ipc_port_t port,
	295	mach_port_name_t name,
	296	ipc_port_request_index_t index);
	297
	298	#define ipc_port_dnrename(port, index, oname, nname) \
	299	MACRO_BEGIN \
	300	ipc_port_request_t ipr, table; \
	301	\
	302	assert(ip_active(port)); \
	303	\
	304	table = port->ip_dnrequests; \
	305	assert(table != IPR_NULL); \
	306	\
	307	ipr = &table[index]; \
	308	assert(ipr->ipr_name == oname); \
	309	\
	310	ipr->ipr_name = nname; \
	311	MACRO_END
	312
	313	/* Make a port-deleted request */
	314	extern void ipc_port_pdrequest(
	315	ipc_port_t port,
	316	ipc_port_t notify,
	317	ipc_port_t *previousp);
	318
	319	/* Make a no-senders request */
	320	extern void ipc_port_nsrequest(
	321	ipc_port_t port,
	322	mach_port_mscount_t sync,
	323	ipc_port_t notify,
	324	ipc_port_t *previousp);
	325
	326	#define ipc_port_set_mscount(port, mscount) \
	327	MACRO_BEGIN \
	328	assert(ip_active(port)); \
	329	\
	330	(port)->ip_mscount = (mscount); \
	331	MACRO_END
	332
	333	/* Prepare a receive right for transmission/destruction */
	334	extern void ipc_port_clear_receiver(
	335	ipc_port_t port);
	336
	337	/* Initialize a newly-allocated port */
	338	extern void ipc_port_init(
	339	ipc_port_t port,
	340	ipc_space_t space,
	341	mach_port_name_t name);
	342
	343	/* Allocate a port */
	344	extern kern_return_t ipc_port_alloc(
	345	ipc_space_t space,
	346	mach_port_name_t *namep,
	347	ipc_port_t *portp);
	348
	349	/* Allocate a port, with a specific name */
	350	extern kern_return_t ipc_port_alloc_name(
	351	ipc_space_t space,
	352	mach_port_name_t name,
	353	ipc_port_t *portp);
	354
355	/* Generate dead name notifications */
356	extern void ipc_port_dnnotify(
357	ipc_port_t port,
358	ipc_port_request_t dnrequests);
359
360	/* Destroy a port */
361	extern void ipc_port_destroy(
362	ipc_port_t port);
363
364	/* Check if queueing "port" in a message for "dest" would create a circular
365	group of ports and messages */
366	extern boolean_t
367	ipc_port_check_circularity(
368	ipc_port_t port,
369	ipc_port_t dest);
370
371	/* Make a send-once notify port from a receive right */
372	extern ipc_port_t ipc_port_lookup_notify(
373	ipc_space_t space,
374	mach_port_name_t name);
375
0b4e3aa0 A	376	/* Make a naked send right from a receive right - port locked and active */
	377	extern ipc_port_t ipc_port_make_send_locked(
	378	ipc_port_t port);
	379
1c79356b A	380	/* Make a naked send right from a receive right */
	381	extern ipc_port_t ipc_port_make_send(
	382	ipc_port_t port);
	383
	384	/* Make a naked send right from another naked send right */
	385	extern ipc_port_t ipc_port_copy_send(
	386	ipc_port_t port);
	387
	388	/* Copyout a naked send right */
	389	extern mach_port_name_t ipc_port_copyout_send(
	390	ipc_port_t sright,
	391	ipc_space_t space);
	392
	393	/* Release a (valid) naked send right */
	394	extern void ipc_port_release_send(
	395	ipc_port_t port);
	396
	397	/* Make a naked send-once right from a receive right */
	398	extern ipc_port_t ipc_port_make_sonce(
	399	ipc_port_t port);
	400
	401	/* Release a naked send-once right */
	402	extern void ipc_port_release_sonce(
	403	ipc_port_t port);
	404
	405	/* Release a naked (in limbo or in transit) receive right */
	406	extern void ipc_port_release_receive(
	407	ipc_port_t port);
	408
	409	/* Allocate a port in a special space */
	410	extern ipc_port_t ipc_port_alloc_special(
	411	ipc_space_t space);
	412
	413	/* Deallocate a port in a special space */
	414	extern void ipc_port_dealloc_special(
	415	ipc_port_t port,
	416	ipc_space_t space);
	417
	418	#if MACH_ASSERT
	419	/* Track low-level port deallocation */
	420	extern void ipc_port_track_dealloc(
	421	ipc_port_t port);
	422
	423	/* Initialize general port debugging state */
	424	extern void ipc_port_debug_init(void);
	425	#endif /* MACH_ASSERT */
	426
	427	#define ipc_port_alloc_kernel() \
	428	ipc_port_alloc_special(ipc_space_kernel)
	429	#define ipc_port_dealloc_kernel(port) \
	430	ipc_port_dealloc_special((port), ipc_space_kernel)
	431
	432	#define ipc_port_alloc_reply() \
	433	ipc_port_alloc_special(ipc_space_reply)
	434	#define ipc_port_dealloc_reply(port) \
	435	ipc_port_dealloc_special((port), ipc_space_reply)
	436
	437	#define ipc_port_reference(port) \
	438	ipc_object_reference(&(port)->ip_object)
	439
	440	#define ipc_port_release(port) \
	441	ipc_object_release(&(port)->ip_object)
	442
	443	#endif /* _IPC_IPC_PORT_H_ */