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 #pragma ident	"%Z%%M%	%I%	%E% SMI"
32 
33 
34 /*
35  *
36  * MODULE: udat_api.c
37  *
38  * PURPOSE: DAT Provider and Consumer registry functions.
39  *
40  */
41 
42 #include "dat_osd.h"
43 #include <dat/dat_registry.h>
44 
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)45 DAT_RETURN dat_lmr_create(
46 	IN	DAT_IA_HANDLE		ia_handle,
47 	IN	DAT_MEM_TYPE		mem_type,
48 	IN	DAT_REGION_DESCRIPTION	region_description,
49 	IN	DAT_VLEN		length,
50 	IN	DAT_PZ_HANDLE		pz_handle,
51 	IN	DAT_MEM_PRIV_FLAGS	privileges,
52 	OUT	DAT_LMR_HANDLE		*lmr_handle,
53 	OUT	DAT_LMR_CONTEXT		*lmr_context,
54 	OUT	DAT_RMR_CONTEXT		*rmr_context,
55 	OUT	DAT_VLEN 		*registered_length,
56 	OUT	DAT_VADDR 		*registered_address)
57 {
58 	if (DAT_BAD_HANDLE(ia_handle)) {
59 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
60 	}
61 	return DAT_LMR_CREATE(ia_handle,
62 			    mem_type,
63 			    region_description,
64 			    length,
65 			    pz_handle,
66 			    privileges,
67 			    lmr_handle,
68 			    lmr_context,
69 			    rmr_context,
70 			    registered_length,
71 			    registered_address);
72 }
73 
74 
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)75 DAT_RETURN dat_evd_create(
76 	IN	DAT_IA_HANDLE		ia_handle,
77 	IN	DAT_COUNT		evd_min_qlen,
78 	IN	DAT_CNO_HANDLE		cno_handle,
79 	IN	DAT_EVD_FLAGS		evd_flags,
80 	OUT	DAT_EVD_HANDLE		*evd_handle)
81 {
82 	if (DAT_BAD_HANDLE(ia_handle)) {
83 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
84 	}
85 	return DAT_EVD_CREATE(ia_handle,
86 			    evd_min_qlen,
87 			    cno_handle,
88 			    evd_flags,
89 			    evd_handle);
90 }
91 
92 
dat_evd_modify_cno(IN DAT_EVD_HANDLE evd_handle,IN DAT_CNO_HANDLE cno_handle)93 DAT_RETURN dat_evd_modify_cno(
94 	IN	DAT_EVD_HANDLE		evd_handle,
95 	IN	DAT_CNO_HANDLE		cno_handle)
96 {
97 	if (DAT_BAD_HANDLE(evd_handle)) {
98 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
99 	}
100 	return DAT_EVD_MODIFY_CNO(evd_handle,
101 				cno_handle);
102 }
103 
104 
dat_cno_create(IN DAT_IA_HANDLE ia_handle,IN DAT_OS_WAIT_PROXY_AGENT agent,OUT DAT_CNO_HANDLE * cno_handle)105 DAT_RETURN dat_cno_create(
106 	IN 	DAT_IA_HANDLE		ia_handle,
107 	IN 	DAT_OS_WAIT_PROXY_AGENT agent,
108 	OUT	DAT_CNO_HANDLE		*cno_handle)
109 {
110 	if (DAT_BAD_HANDLE(ia_handle)) {
111 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
112 	}
113 	return DAT_CNO_CREATE(ia_handle,
114 			    agent,
115 			    cno_handle);
116 }
117 
118 
dat_cno_modify_agent(IN DAT_CNO_HANDLE cno_handle,IN DAT_OS_WAIT_PROXY_AGENT agent)119 DAT_RETURN dat_cno_modify_agent(
120 	IN 	DAT_CNO_HANDLE		 cno_handle,
121 	IN 	DAT_OS_WAIT_PROXY_AGENT	 agent)
122 {
123 	if (DAT_BAD_HANDLE(cno_handle)) {
124 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
125 	}
126 	return DAT_CNO_MODIFY_AGENT(cno_handle,
127 				agent);
128 }
129 
130 
dat_cno_query(IN DAT_CNO_HANDLE cno_handle,IN DAT_CNO_PARAM_MASK cno_param_mask,OUT DAT_CNO_PARAM * cno_param)131 DAT_RETURN dat_cno_query(
132 	IN	DAT_CNO_HANDLE		cno_handle,
133 	IN	DAT_CNO_PARAM_MASK	cno_param_mask,
134 	OUT	DAT_CNO_PARAM		*cno_param)
135 {
136 	if (DAT_BAD_HANDLE(cno_handle)) {
137 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
138 	}
139 	return DAT_CNO_QUERY(cno_handle,
140 			cno_param_mask,
141 			cno_param);
142 }
143 
144 
dat_cno_free(IN DAT_CNO_HANDLE cno_handle)145 DAT_RETURN dat_cno_free(
146 	IN DAT_CNO_HANDLE		cno_handle)
147 {
148 	if (DAT_BAD_HANDLE(cno_handle)) {
149 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
150 	}
151 	return (DAT_CNO_FREE(cno_handle));
152 }
153 
154 
dat_cno_wait(IN DAT_CNO_HANDLE cno_handle,IN DAT_TIMEOUT timeout,OUT DAT_EVD_HANDLE * evd_handle)155 DAT_RETURN dat_cno_wait(
156 	IN  	DAT_CNO_HANDLE		cno_handle,
157 	IN  	DAT_TIMEOUT		timeout,
158 	OUT 	DAT_EVD_HANDLE		*evd_handle)
159 {
160 	if (DAT_BAD_HANDLE(cno_handle)) {
161 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CNO));
162 	}
163 	return DAT_CNO_WAIT(cno_handle,
164 			timeout,
165 			evd_handle);
166 }
167 
168 
dat_evd_enable(IN DAT_EVD_HANDLE evd_handle)169 DAT_RETURN dat_evd_enable(
170 	IN	DAT_EVD_HANDLE		evd_handle)
171 {
172 	if (DAT_BAD_HANDLE(evd_handle)) {
173 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
174 	}
175 	return (DAT_EVD_ENABLE(evd_handle));
176 }
177 
178 
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)179 DAT_RETURN dat_evd_wait(
180 	IN  	DAT_EVD_HANDLE		evd_handle,
181 	IN  	DAT_TIMEOUT		Timeout,
182 	IN  	DAT_COUNT		Threshold,
183 	OUT 	DAT_EVENT		*event,
184 	OUT 	DAT_COUNT		*n_more_events)
185 {
186 	if (DAT_BAD_HANDLE(evd_handle)) {
187 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
188 	}
189 	return DAT_EVD_WAIT(evd_handle,
190 			Timeout,
191 			Threshold,
192 			event,
193 			n_more_events);
194 }
195 
196 
dat_evd_disable(IN DAT_EVD_HANDLE evd_handle)197 DAT_RETURN dat_evd_disable(
198 	IN	DAT_EVD_HANDLE		evd_handle)
199 {
200 	if (DAT_BAD_HANDLE(evd_handle)) {
201 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
202 	}
203 	return (DAT_EVD_DISABLE(evd_handle));
204 }
205 
206 
dat_evd_set_unwaitable(IN DAT_EVD_HANDLE evd_handle)207 DAT_RETURN dat_evd_set_unwaitable(
208 	IN 	DAT_EVD_HANDLE		 evd_handle)
209 {
210 	if (DAT_BAD_HANDLE(evd_handle)) {
211 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
212 	}
213 	return (DAT_EVD_SET_UNWAITABLE(evd_handle));
214 }
215 
dat_evd_clear_unwaitable(IN DAT_EVD_HANDLE evd_handle)216 DAT_RETURN dat_evd_clear_unwaitable(
217 	IN 	DAT_EVD_HANDLE		 evd_handle)
218 {
219 	if (DAT_BAD_HANDLE(evd_handle)) {
220 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
221 	}
222 	return (DAT_EVD_CLEAR_UNWAITABLE(evd_handle));
223 }
224 
dat_cr_handoff(IN DAT_CR_HANDLE cr_handle,IN DAT_CONN_QUAL handoff)225 DAT_RETURN dat_cr_handoff(
226 	IN	DAT_CR_HANDLE		cr_handle,
227 	IN	DAT_CONN_QUAL		handoff)
228 {
229 	if (DAT_BAD_HANDLE(cr_handle)) {
230 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_CR));
231 	}
232 	return DAT_CR_HANDOFF(cr_handle,
233 			handoff);
234 }
235 
236 
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)237 DAT_RETURN dat_psp_create_any(
238 	IN	DAT_IA_HANDLE		ia_handle,
239 	OUT	DAT_CONN_QUAL		*conn_qual,
240 	IN	DAT_EVD_HANDLE		evd_handle,
241 	IN	DAT_PSP_FLAGS		psp_flags,
242 	OUT	DAT_PSP_HANDLE		*psp_handle)
243 {
244 	if (DAT_BAD_HANDLE(ia_handle)) {
245 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
246 	}
247 	return DAT_PSP_CREATE_ANY(ia_handle,
248 			    conn_qual,
249 			    evd_handle,
250 			    psp_flags,
251 			    psp_handle);
252 }
253 
254 
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)255 DAT_RETURN dat_ia_query(
256 	IN	DAT_IA_HANDLE		ia_handle,
257 	OUT	DAT_EVD_HANDLE		*async_evd_handle,
258 	IN	DAT_IA_ATTR_MASK	ia_attr_mask,
259 	OUT	DAT_IA_ATTR		*ia_attr,
260 	IN	DAT_PROVIDER_ATTR_MASK	provider_attr_mask,
261 	OUT	DAT_PROVIDER_ATTR 	*provider_attr)
262 {
263 	if (DAT_BAD_HANDLE(ia_handle)) {
264 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_IA));
265 	}
266 	return DAT_IA_QUERY(ia_handle,
267 			async_evd_handle,
268 			ia_attr_mask,
269 			ia_attr,
270 			provider_attr_mask,
271 			provider_attr);
272 }
273 
274 
dat_evd_query(IN DAT_EVD_HANDLE evd_handle,IN DAT_EVD_PARAM_MASK evd_param_mask,OUT DAT_EVD_PARAM * evd_param)275 DAT_RETURN dat_evd_query(
276 	IN	DAT_EVD_HANDLE		evd_handle,
277 	IN	DAT_EVD_PARAM_MASK	evd_param_mask,
278 	OUT	DAT_EVD_PARAM		*evd_param)
279 {
280 	if (DAT_BAD_HANDLE(evd_handle)) {
281 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE1));
282 	}
283 	return DAT_EVD_QUERY(evd_handle,
284 			evd_param_mask,
285 			evd_param);
286 }
287 
288 
dat_lmr_query(IN DAT_LMR_HANDLE lmr_handle,IN DAT_LMR_PARAM_MASK lmv_param_mask,OUT DAT_LMR_PARAM * lmr_param)289 DAT_RETURN dat_lmr_query(
290 	IN	DAT_LMR_HANDLE		lmr_handle,
291 	IN	DAT_LMR_PARAM_MASK	lmv_param_mask,
292 	OUT	DAT_LMR_PARAM		*lmr_param)
293 {
294 	if (DAT_BAD_HANDLE(lmr_handle)) {
295 		return (DAT_ERROR(DAT_INVALID_HANDLE, DAT_INVALID_HANDLE_LMR));
296 	}
297 	return DAT_LMR_QUERY(lmr_handle,
298 		    lmv_param_mask,
299 		    lmr_param);
300 }
301