1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License, Version 1.0 only
6 * (the "License"). You may not use this file except in compliance
7 * with the License.
8 *
9 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10 * or http://www.opensolaris.org/os/licensing.
11 * See the License for the specific language governing permissions
12 * and limitations under the License.
13 *
14 * When distributing Covered Code, include this CDDL HEADER in each
15 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16 * If applicable, add the following below this CDDL HEADER, with the
17 * fields enclosed by brackets "[]" replaced with your own identifying
18 * information: Portions Copyright [yyyy] [name of copyright owner]
19 *
20 * CDDL HEADER END
21 */
22 /*
23 * Copyright (c) 2002-2003, Network Appliance, Inc. All rights reserved.
24 */
25
26 /*
27 * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
28 * Use is subject to license terms.
29 */
30
31 /*
32 *
33 * MODULE: udat_api.c
34 *
35 * PURPOSE: DAT Provider and Consumer registry functions.
36 *
37 */
38
39 #include "dat_osd.h"
40 #include <dat/dat_registry.h>
41
dat_lmr_create(IN DAT_IA_HANDLE ia_handle,IN DAT_MEM_TYPE mem_type,IN DAT_REGION_DESCRIPTION region_description,IN DAT_VLEN length,IN DAT_PZ_HANDLE pz_handle,IN DAT_MEM_PRIV_FLAGS privileges,OUT DAT_LMR_HANDLE * lmr_handle,OUT DAT_LMR_CONTEXT * lmr_context,OUT DAT_RMR_CONTEXT * rmr_context,OUT DAT_VLEN * registered_length,OUT DAT_VADDR * registered_address)42 DAT_RETURN dat_lmr_create(
43 IN DAT_IA_HANDLE ia_handle,
44 IN DAT_MEM_TYPE mem_type,
45 IN DAT_REGION_DESCRIPTION region_description,
46 IN DAT_VLEN length,
47 IN DAT_PZ_HANDLE pz_handle,
48 IN DAT_MEM_PRIV_FLAGS privileges,
49 OUT DAT_LMR_HANDLE *lmr_handle,
50 OUT DAT_LMR_CONTEXT *lmr_context,
51 OUT DAT_RMR_CONTEXT *rmr_context,
52 OUT DAT_VLEN *registered_length,
53 OUT DAT_VADDR *registered_address)
54 {
55 if (DAT_BAD_HANDLE(ia_handle)) {
56 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
57 }
58 return DAT_LMR_CREATE(ia_handle,
59 mem_type,
60 region_description,
61 length,
62 pz_handle,
63 privileges,
64 lmr_handle,
65 lmr_context,
66 rmr_context,
67 registered_length,
68 registered_address);
69 }
70
71
dat_evd_create(IN DAT_IA_HANDLE ia_handle,IN DAT_COUNT evd_min_qlen,IN DAT_CNO_HANDLE cno_handle,IN DAT_EVD_FLAGS evd_flags,OUT DAT_EVD_HANDLE * evd_handle)72 DAT_RETURN dat_evd_create(
73 IN DAT_IA_HANDLE ia_handle,
74 IN DAT_COUNT evd_min_qlen,
75 IN DAT_CNO_HANDLE cno_handle,
76 IN DAT_EVD_FLAGS evd_flags,
77 OUT DAT_EVD_HANDLE *evd_handle)
78 {
79 if (DAT_BAD_HANDLE(ia_handle)) {
80 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
81 }
82 return DAT_EVD_CREATE(ia_handle,
83 evd_min_qlen,
84 cno_handle,
85 evd_flags,
86 evd_handle);
87 }
88
89
dat_evd_modify_cno(IN DAT_EVD_HANDLE evd_handle,IN DAT_CNO_HANDLE cno_handle)90 DAT_RETURN dat_evd_modify_cno(
91 IN DAT_EVD_HANDLE evd_handle,
92 IN DAT_CNO_HANDLE cno_handle)
93 {
94 if (DAT_BAD_HANDLE(evd_handle)) {
95 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
96 }
97 return DAT_EVD_MODIFY_CNO(evd_handle,
98 cno_handle);
99 }
100
101
dat_cno_create(IN DAT_IA_HANDLE ia_handle,IN DAT_OS_WAIT_PROXY_AGENT agent,OUT DAT_CNO_HANDLE * cno_handle)102 DAT_RETURN dat_cno_create(
103 IN DAT_IA_HANDLE ia_handle,
104 IN DAT_OS_WAIT_PROXY_AGENT agent,
105 OUT DAT_CNO_HANDLE *cno_handle)
106 {
107 if (DAT_BAD_HANDLE(ia_handle)) {
108 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
109 }
110 return DAT_CNO_CREATE(ia_handle,
111 agent,
112 cno_handle);
113 }
114
115
dat_cno_modify_agent(IN DAT_CNO_HANDLE cno_handle,IN DAT_OS_WAIT_PROXY_AGENT agent)116 DAT_RETURN dat_cno_modify_agent(
117 IN DAT_CNO_HANDLE cno_handle,
118 IN DAT_OS_WAIT_PROXY_AGENT agent)
119 {
120 if (DAT_BAD_HANDLE(cno_handle)) {
121 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
122 }
123 return DAT_CNO_MODIFY_AGENT(cno_handle,
124 agent);
125 }
126
127
dat_cno_query(IN DAT_CNO_HANDLE cno_handle,IN DAT_CNO_PARAM_MASK cno_param_mask,OUT DAT_CNO_PARAM * cno_param)128 DAT_RETURN dat_cno_query(
129 IN DAT_CNO_HANDLE cno_handle,
130 IN DAT_CNO_PARAM_MASK cno_param_mask,
131 OUT DAT_CNO_PARAM *cno_param)
132 {
133 if (DAT_BAD_HANDLE(cno_handle)) {
134 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
135 }
136 return DAT_CNO_QUERY(cno_handle,
137 cno_param_mask,
138 cno_param);
139 }
140
141
dat_cno_free(IN DAT_CNO_HANDLE cno_handle)142 DAT_RETURN dat_cno_free(
143 IN DAT_CNO_HANDLE cno_handle)
144 {
145 if (DAT_BAD_HANDLE(cno_handle)) {
146 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
147 }
148 return (DAT_CNO_FREE(cno_handle));
149 }
150
151
dat_cno_wait(IN DAT_CNO_HANDLE cno_handle,IN DAT_TIMEOUT timeout,OUT DAT_EVD_HANDLE * evd_handle)152 DAT_RETURN dat_cno_wait(
153 IN DAT_CNO_HANDLE cno_handle,
154 IN DAT_TIMEOUT timeout,
155 OUT DAT_EVD_HANDLE *evd_handle)
156 {
157 if (DAT_BAD_HANDLE(cno_handle)) {
158 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
159 }
160 return DAT_CNO_WAIT(cno_handle,
161 timeout,
162 evd_handle);
163 }
164
165
dat_evd_enable(IN DAT_EVD_HANDLE evd_handle)166 DAT_RETURN dat_evd_enable(
167 IN DAT_EVD_HANDLE evd_handle)
168 {
169 if (DAT_BAD_HANDLE(evd_handle)) {
170 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
171 }
172 return (DAT_EVD_ENABLE(evd_handle));
173 }
174
175
dat_evd_wait(IN DAT_EVD_HANDLE evd_handle,IN DAT_TIMEOUT Timeout,IN DAT_COUNT Threshold,OUT DAT_EVENT * event,OUT DAT_COUNT * n_more_events)176 DAT_RETURN dat_evd_wait(
177 IN DAT_EVD_HANDLE evd_handle,
178 IN DAT_TIMEOUT Timeout,
179 IN DAT_COUNT Threshold,
180 OUT DAT_EVENT *event,
181 OUT DAT_COUNT *n_more_events)
182 {
183 if (DAT_BAD_HANDLE(evd_handle)) {
184 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
185 }
186 return DAT_EVD_WAIT(evd_handle,
187 Timeout,
188 Threshold,
189 event,
190 n_more_events);
191 }
192
193
dat_evd_disable(IN DAT_EVD_HANDLE evd_handle)194 DAT_RETURN dat_evd_disable(
195 IN DAT_EVD_HANDLE evd_handle)
196 {
197 if (DAT_BAD_HANDLE(evd_handle)) {
198 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
199 }
200 return (DAT_EVD_DISABLE(evd_handle));
201 }
202
203
dat_evd_set_unwaitable(IN DAT_EVD_HANDLE evd_handle)204 DAT_RETURN dat_evd_set_unwaitable(
205 IN DAT_EVD_HANDLE evd_handle)
206 {
207 if (DAT_BAD_HANDLE(evd_handle)) {
208 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
209 }
210 return (DAT_EVD_SET_UNWAITABLE(evd_handle));
211 }
212
dat_evd_clear_unwaitable(IN DAT_EVD_HANDLE evd_handle)213 DAT_RETURN dat_evd_clear_unwaitable(
214 IN DAT_EVD_HANDLE evd_handle)
215 {
216 if (DAT_BAD_HANDLE(evd_handle)) {
217 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
218 }
219 return (DAT_EVD_CLEAR_UNWAITABLE(evd_handle));
220 }
221
dat_cr_handoff(IN DAT_CR_HANDLE cr_handle,IN DAT_CONN_QUAL handoff)222 DAT_RETURN dat_cr_handoff(
223 IN DAT_CR_HANDLE cr_handle,
224 IN DAT_CONN_QUAL handoff)
225 {
226 if (DAT_BAD_HANDLE(cr_handle)) {
227 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CR));
228 }
229 return DAT_CR_HANDOFF(cr_handle,
230 handoff);
231 }
232
233
dat_psp_create_any(IN DAT_IA_HANDLE ia_handle,OUT DAT_CONN_QUAL * conn_qual,IN DAT_EVD_HANDLE evd_handle,IN DAT_PSP_FLAGS psp_flags,OUT DAT_PSP_HANDLE * psp_handle)234 DAT_RETURN dat_psp_create_any(
235 IN DAT_IA_HANDLE ia_handle,
236 OUT DAT_CONN_QUAL *conn_qual,
237 IN DAT_EVD_HANDLE evd_handle,
238 IN DAT_PSP_FLAGS psp_flags,
239 OUT DAT_PSP_HANDLE *psp_handle)
240 {
241 if (DAT_BAD_HANDLE(ia_handle)) {
242 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
243 }
244 return DAT_PSP_CREATE_ANY(ia_handle,
245 conn_qual,
246 evd_handle,
247 psp_flags,
248 psp_handle);
249 }
250
251
dat_ia_query(IN DAT_IA_HANDLE ia_handle,OUT DAT_EVD_HANDLE * async_evd_handle,IN DAT_IA_ATTR_MASK ia_attr_mask,OUT DAT_IA_ATTR * ia_attr,IN DAT_PROVIDER_ATTR_MASK provider_attr_mask,OUT DAT_PROVIDER_ATTR * provider_attr)252 DAT_RETURN dat_ia_query(
253 IN DAT_IA_HANDLE ia_handle,
254 OUT DAT_EVD_HANDLE *async_evd_handle,
255 IN DAT_IA_ATTR_MASK ia_attr_mask,
256 OUT DAT_IA_ATTR *ia_attr,
257 IN DAT_PROVIDER_ATTR_MASK provider_attr_mask,
258 OUT DAT_PROVIDER_ATTR *provider_attr)
259 {
260 if (DAT_BAD_HANDLE(ia_handle)) {
261 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
262 }
263 return DAT_IA_QUERY(ia_handle,
264 async_evd_handle,
265 ia_attr_mask,
266 ia_attr,
267 provider_attr_mask,
268 provider_attr);
269 }
270
271
dat_evd_query(IN DAT_EVD_HANDLE evd_handle,IN DAT_EVD_PARAM_MASK evd_param_mask,OUT DAT_EVD_PARAM * evd_param)272 DAT_RETURN dat_evd_query(
273 IN DAT_EVD_HANDLE evd_handle,
274 IN DAT_EVD_PARAM_MASK evd_param_mask,
275 OUT DAT_EVD_PARAM *evd_param)
276 {
277 if (DAT_BAD_HANDLE(evd_handle)) {
278 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
279 }
280 return DAT_EVD_QUERY(evd_handle,
281 evd_param_mask,
282 evd_param);
283 }
284
285
dat_lmr_query(IN DAT_LMR_HANDLE lmr_handle,IN DAT_LMR_PARAM_MASK lmv_param_mask,OUT DAT_LMR_PARAM * lmr_param)286 DAT_RETURN dat_lmr_query(
287 IN DAT_LMR_HANDLE lmr_handle,
288 IN DAT_LMR_PARAM_MASK lmv_param_mask,
289 OUT DAT_LMR_PARAM *lmr_param)
290 {
291 if (DAT_BAD_HANDLE(lmr_handle)) {
292 return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_LMR));
293 }
294 return DAT_LMR_QUERY(lmr_handle,
295 lmv_param_mask,
296 lmr_param);
297 }
298