blob: a66e6875808144cee64bf958d1d439f62ee32217 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
/*
* Copyright (c) 1994 The University of Utah and
* the Computer Systems Laboratory (CSL). 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.
*
* THE UNIVERSITY OF UTAH AND CSL ALLOW FREE USE OF THIS SOFTWARE IN ITS "AS
* IS" CONDITION. THE UNIVERSITY OF UTAH AND CSL DISCLAIM ANY LIABILITY OF
* ANY KIND FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
*
* CSL requests users of this software to return to csl-dist@cs.utah.edu any
* improvements that they make and grant CSL redistribution rights.
*/
/*
* File: ipc_target.h
*
* Common part of IPC ports and port sets
* representing a target of messages and migrating RPCs.
*/
#ifndef _IPC_IPC_RECEIVER_H_
#define _IPC_IPC_RECEIVER_H_
#include "ipc_mqueue.h"
#include "ipc_object.h"
#include <mach/rpc.h>
typedef struct ipc_target {
struct ipc_object ipt_object;
mach_port_t ipt_name;
struct ipc_mqueue ipt_messages;
#ifdef MIGRATING_THREADS
/*** Migrating RPC stuff ***/
int ipt_type;
/* User entry info for migrating RPC */
rpc_info_t ipt_rpcinfo;
/* List of available activations, all active but not in use. */
struct Act *ipt_acts;
/* TRUE if someone is waiting for an activation from this pool. */
int ipt_waiting;
#endif /* MIGRATING_THREADS */
} *ipc_target_t;
#define IPT_TYPE_MESSAGE_RPC 1
#define IPT_TYPE_MIGRATE_RPC 2
void ipc_target_init(struct ipc_target *ipt, mach_port_t name);
void ipc_target_terminate(struct ipc_target *ipt);
#define ipt_lock(ipt) io_lock(&(ipt)->ipt_object)
#define ipt_unlock(ipt) io_unlock(&(ipt)->ipt_object)
#define ipt_reference(ipt) io_reference(&(ipt)->ipt_object)
#define ipt_release(ipt) io_release(&(ipt)->ipt_object)
#define ipt_check_unlock(ipt) io_check_unlock(&(ipt)->ipt_object)
#endif /* _IPC_IPC_RECEIVER_H_ */
|
