]>
Commit | Line | Data |
---|---|---|
1 | /* | |
2 | * Copyright (c) 2000 Apple Computer, Inc. All rights reserved. | |
3 | * | |
4 | * @APPLE_LICENSE_HEADER_START@ | |
5 | * | |
6 | * The contents of this file constitute Original Code as defined in and | |
7 | * are subject to the Apple Public Source License Version 1.1 (the | |
8 | * "License"). You may not use this file except in compliance with the | |
9 | * License. Please obtain a copy of the License at | |
10 | * http://www.apple.com/publicsource and read it before using this file. | |
11 | * | |
12 | * This Original Code and all software distributed under the License are | |
13 | * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER | |
14 | * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, | |
15 | * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, | |
16 | * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT. Please see the | |
17 | * License for the specific language governing rights and limitations | |
18 | * under the License. | |
19 | * | |
20 | * @APPLE_LICENSE_HEADER_END@ | |
21 | */ | |
22 | /* | |
23 | * @OSF_COPYRIGHT@ | |
24 | * | |
25 | */ | |
26 | /* | |
27 | * File: kern/sync_lock.h | |
28 | * Author: Joseph CaraDonna | |
29 | * | |
30 | * Contains RT distributed lock synchronization service definitions. | |
31 | */ | |
32 | ||
33 | #ifndef _KERN_SYNC_LOCK_H_ | |
34 | #define _KERN_SYNC_LOCK_H_ | |
35 | ||
36 | #include <mach/mach_types.h> | |
37 | ||
38 | #ifdef MACH_KERNEL_PRIVATE | |
39 | ||
40 | #include <kern/wait_queue.h> | |
41 | #include <kern/macro_help.h> | |
42 | #include <kern/queue.h> | |
43 | #include <kern/lock.h> | |
44 | ||
45 | typedef struct ulock { | |
46 | queue_chain_t thread_link; /* ulocks owned by a thread */ | |
47 | queue_chain_t held_link; /* ulocks held in the lock set */ | |
48 | queue_chain_t handoff_link; /* ulocks w/ active handoffs */ | |
49 | ||
50 | decl_mutex_data(,lock) /* ulock lock */ | |
51 | ||
52 | struct lock_set *lock_set; /* the retaining lock set */ | |
53 | thread_act_t holder; /* thread_act that holds the lock */ | |
54 | unsigned int /* flags */ | |
55 | /* boolean_t */ blocked:1, /* did threads block waiting? */ | |
56 | /* boolean_t */ unstable:1, /* unstable? (holder died) */ | |
57 | /* boolean_t */ ho_wait:1, /* handoff thread waiting? */ | |
58 | /* boolean_t */ accept_wait:1, /* accepting thread waiting? */ | |
59 | :0; /* force to long boundary */ | |
60 | ||
61 | struct wait_queue wait_queue; /* queue of blocked threads */ | |
62 | } Ulock; | |
63 | ||
64 | typedef struct ulock *ulock_t; | |
65 | ||
66 | typedef struct lock_set { | |
67 | queue_chain_t task_link; /* chain of lock sets owned by a task */ | |
68 | decl_mutex_data(,lock) /* lock set lock */ | |
69 | task_t owner; /* task that owns the lock set */ | |
70 | ipc_port_t port; /* lock set port */ | |
71 | int ref_count; /* reference count */ | |
72 | ||
73 | boolean_t active; /* active status */ | |
74 | int n_ulocks; /* number of ulocks in the lock set */ | |
75 | ||
76 | struct ulock ulock_list[1]; /* ulock group list place holder */ | |
77 | } Lock_Set; | |
78 | ||
79 | #define ULOCK_NULL ((ulock_t) 0) | |
80 | ||
81 | #define ULOCK_FREE 0 | |
82 | #define ULOCK_HELD 1 | |
83 | ||
84 | #define LOCK_OPERATION_ABORTED(th) ((th)->wait_link.prev != (queue_entry_t) 0) | |
85 | #define LOCK_OPERATION_COMPLETE(th) ((th)->wait_link.prev = (queue_entry_t) 0) | |
86 | ||
87 | /* | |
88 | * Data structure internal lock macros | |
89 | */ | |
90 | ||
91 | #define lock_set_lock_init(ls) mutex_init(&(ls)->lock, \ | |
92 | ETAP_THREAD_LOCK_SET) | |
93 | #define lock_set_lock(ls) mutex_lock(&(ls)->lock) | |
94 | #define lock_set_unlock(ls) mutex_unlock(&(ls)->lock) | |
95 | ||
96 | #define ulock_lock_init(ul) mutex_init(&(ul)->lock, \ | |
97 | ETAP_THREAD_ULOCK) | |
98 | #define ulock_lock(ul) mutex_lock(&(ul)->lock) | |
99 | #define ulock_unlock(ul) mutex_unlock(&(ul)->lock) | |
100 | ||
101 | extern void lock_set_init(void); | |
102 | ||
103 | #endif /* MACH_KERNEL_PRIVATE */ | |
104 | ||
105 | /* | |
106 | * Forward Declarations | |
107 | */ | |
108 | ||
109 | extern kern_return_t lock_set_create (task_t task, | |
110 | lock_set_t *new_lock_set, | |
111 | int n_ulocks, | |
112 | int policy); | |
113 | ||
114 | extern kern_return_t lock_set_destroy (task_t task, | |
115 | lock_set_t lock_set); | |
116 | ||
117 | extern kern_return_t lock_acquire (lock_set_t lock_set, | |
118 | int lock_id); | |
119 | ||
120 | extern kern_return_t lock_release (lock_set_t lock_set, | |
121 | int lock_id); | |
122 | ||
123 | extern kern_return_t lock_try (lock_set_t lock_set, | |
124 | int lock_id); | |
125 | ||
126 | extern kern_return_t lock_make_stable (lock_set_t lock_set, | |
127 | int lock_id); | |
128 | ||
129 | extern kern_return_t lock_make_unstable (ulock_t ulock, | |
130 | thread_act_t thr_act); | |
131 | ||
132 | extern kern_return_t lock_release_internal (ulock_t ulock, | |
133 | thread_act_t thr_act); | |
134 | ||
135 | extern kern_return_t lock_handoff (lock_set_t lock_set, | |
136 | int lock_id); | |
137 | ||
138 | extern kern_return_t lock_handoff_accept (lock_set_t lock_set, | |
139 | int lock_id); | |
140 | ||
141 | extern void lock_set_reference (lock_set_t lock_set); | |
142 | extern void lock_set_dereference (lock_set_t lock_set); | |
143 | ||
144 | #endif /* _KERN_SYNC_LOCK_H_ */ |