1*9e39c5baSBill Taylor /*
2*9e39c5baSBill Taylor * CDDL HEADER START
3*9e39c5baSBill Taylor *
4*9e39c5baSBill Taylor * The contents of this file are subject to the terms of the
5*9e39c5baSBill Taylor * Common Development and Distribution License (the "License").
6*9e39c5baSBill Taylor * You may not use this file except in compliance with the License.
7*9e39c5baSBill Taylor *
8*9e39c5baSBill Taylor * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9*9e39c5baSBill Taylor * or http://www.opensolaris.org/os/licensing.
10*9e39c5baSBill Taylor * See the License for the specific language governing permissions
11*9e39c5baSBill Taylor * and limitations under the License.
12*9e39c5baSBill Taylor *
13*9e39c5baSBill Taylor * When distributing Covered Code, include this CDDL HEADER in each
14*9e39c5baSBill Taylor * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15*9e39c5baSBill Taylor * If applicable, add the following below this CDDL HEADER, with the
16*9e39c5baSBill Taylor * fields enclosed by brackets "[]" replaced with your own identifying
17*9e39c5baSBill Taylor * information: Portions Copyright [yyyy] [name of copyright owner]
18*9e39c5baSBill Taylor *
19*9e39c5baSBill Taylor * CDDL HEADER END
20*9e39c5baSBill Taylor */
21*9e39c5baSBill Taylor
22*9e39c5baSBill Taylor /*
23*9e39c5baSBill Taylor * Copyright (c) 2002-2003, Network Appliance, Inc. All rights reserved.
24*9e39c5baSBill Taylor */
25*9e39c5baSBill Taylor
26*9e39c5baSBill Taylor /*
27*9e39c5baSBill Taylor * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
28*9e39c5baSBill Taylor * Use is subject to license terms.
29*9e39c5baSBill Taylor */
30*9e39c5baSBill Taylor
31*9e39c5baSBill Taylor /*
32*9e39c5baSBill Taylor *
33*9e39c5baSBill Taylor * MODULE: dapl_evd_create.c
34*9e39c5baSBill Taylor *
35*9e39c5baSBill Taylor * PURPOSE: EVENT management
36*9e39c5baSBill Taylor *
37*9e39c5baSBill Taylor * Description: Interfaces in this file are completely defined in
38*9e39c5baSBill Taylor * the uDAPL 1.1 API, Chapter 6, section 3
39*9e39c5baSBill Taylor *
40*9e39c5baSBill Taylor * $Id: dapl_evd_create.c,v 1.12 2003/08/06 14:04:27 sjs2 Exp $
41*9e39c5baSBill Taylor */
42*9e39c5baSBill Taylor
43*9e39c5baSBill Taylor #include "dapl.h"
44*9e39c5baSBill Taylor #include "dapl_evd_util.h"
45*9e39c5baSBill Taylor
46*9e39c5baSBill Taylor /*
47*9e39c5baSBill Taylor * dapl_evd_create
48*9e39c5baSBill Taylor *
49*9e39c5baSBill Taylor * DAPL Requirements Version xxx, 6.3.2.1
50*9e39c5baSBill Taylor *
51*9e39c5baSBill Taylor * Create and instance of Event Dispatcher.
52*9e39c5baSBill Taylor *
53*9e39c5baSBill Taylor * Input:
54*9e39c5baSBill Taylor * ia_handle
55*9e39c5baSBill Taylor * cno_handle
56*9e39c5baSBill Taylor * evd_min_qlen
57*9e39c5baSBill Taylor * evd_flags
58*9e39c5baSBill Taylor *
59*9e39c5baSBill Taylor * Output:
60*9e39c5baSBill Taylor * evd_handle
61*9e39c5baSBill Taylor *
62*9e39c5baSBill Taylor * Returns:
63*9e39c5baSBill Taylor * DAT_SUCCESS
64*9e39c5baSBill Taylor * DAT_INSUFFICIENT_RESOURCES
65*9e39c5baSBill Taylor * DAT_INVALID_PARAMETER
66*9e39c5baSBill Taylor */
67*9e39c5baSBill Taylor
68*9e39c5baSBill Taylor /*
69*9e39c5baSBill Taylor * ** REVISIT **
70*9e39c5baSBill Taylor *
71*9e39c5baSBill Taylor * Selecting the cqe handing domain must still be done.
72*9e39c5baSBill Taylor * We *probably* want one per hca, but we could have one
73*9e39c5baSBill Taylor * per provider or one per consumer.
74*9e39c5baSBill Taylor */
75*9e39c5baSBill Taylor /*
76*9e39c5baSBill Taylor * Note that if there already is a cq, it is not deleted
77*9e39c5baSBill Taylor * even if it is not required. However, it will not be armed.
78*9e39c5baSBill Taylor */
79*9e39c5baSBill Taylor
dapl_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)80*9e39c5baSBill Taylor DAT_RETURN dapl_evd_create(
81*9e39c5baSBill Taylor IN DAT_IA_HANDLE ia_handle,
82*9e39c5baSBill Taylor IN DAT_COUNT evd_min_qlen,
83*9e39c5baSBill Taylor IN DAT_CNO_HANDLE cno_handle,
84*9e39c5baSBill Taylor IN DAT_EVD_FLAGS evd_flags,
85*9e39c5baSBill Taylor OUT DAT_EVD_HANDLE *evd_handle)
86*9e39c5baSBill Taylor {
87*9e39c5baSBill Taylor DAPL_IA *ia_ptr;
88*9e39c5baSBill Taylor DAPL_EVD *evd_ptr;
89*9e39c5baSBill Taylor DAPL_CNO *cno_ptr;
90*9e39c5baSBill Taylor DAT_RETURN dat_status;
91*9e39c5baSBill Taylor DAT_PROVIDER_ATTR provider_attr = {0};
92*9e39c5baSBill Taylor int i;
93*9e39c5baSBill Taylor int j;
94*9e39c5baSBill Taylor DAT_EVD_FLAGS mask[6] = {DAT_EVD_SOFTWARE_FLAG,
95*9e39c5baSBill Taylor DAT_EVD_CR_FLAG, DAT_EVD_DTO_FLAG, DAT_EVD_CONNECTION_FLAG,
96*9e39c5baSBill Taylor DAT_EVD_RMR_BIND_FLAG, DAT_EVD_ASYNC_FLAG};
97*9e39c5baSBill Taylor
98*9e39c5baSBill Taylor dapl_dbg_log(DAPL_DBG_TYPE_API,
99*9e39c5baSBill Taylor "dapl_evd_create (%p, %d, %p, 0x%x, %p)\n",
100*9e39c5baSBill Taylor ia_handle,
101*9e39c5baSBill Taylor evd_min_qlen,
102*9e39c5baSBill Taylor cno_handle,
103*9e39c5baSBill Taylor evd_flags,
104*9e39c5baSBill Taylor evd_handle);
105*9e39c5baSBill Taylor
106*9e39c5baSBill Taylor ia_ptr = (DAPL_IA *)ia_handle;
107*9e39c5baSBill Taylor cno_ptr = (DAPL_CNO *)cno_handle;
108*9e39c5baSBill Taylor evd_ptr = NULL;
109*9e39c5baSBill Taylor *evd_handle = NULL;
110*9e39c5baSBill Taylor dat_status = DAT_SUCCESS;
111*9e39c5baSBill Taylor
112*9e39c5baSBill Taylor if (DAPL_BAD_HANDLE(ia_handle, DAPL_MAGIC_IA)) {
113*9e39c5baSBill Taylor dat_status = DAT_ERROR(DAT_INVALID_HANDLE,
114*9e39c5baSBill Taylor DAT_INVALID_HANDLE_IA);
115*9e39c5baSBill Taylor goto bail;
116*9e39c5baSBill Taylor }
117*9e39c5baSBill Taylor
118*9e39c5baSBill Taylor if (evd_min_qlen <= 0) {
119*9e39c5baSBill Taylor dat_status = DAT_ERROR(DAT_INVALID_PARAMETER, DAT_INVALID_ARG2);
120*9e39c5baSBill Taylor goto bail;
121*9e39c5baSBill Taylor }
122*9e39c5baSBill Taylor if (evd_min_qlen > ia_ptr->hca_ptr->ia_attr.max_evd_qlen) {
123*9e39c5baSBill Taylor dat_status = DAT_ERROR(DAT_INSUFFICIENT_RESOURCES,
124*9e39c5baSBill Taylor DAT_RESOURCE_TEVD);
125*9e39c5baSBill Taylor goto bail;
126*9e39c5baSBill Taylor }
127*9e39c5baSBill Taylor
128*9e39c5baSBill Taylor if ((cno_handle != DAT_HANDLE_NULL) &&
129*9e39c5baSBill Taylor DAPL_BAD_HANDLE(cno_handle, DAPL_MAGIC_CNO)) {
130*9e39c5baSBill Taylor dat_status = DAT_ERROR(DAT_INVALID_HANDLE,
131*9e39c5baSBill Taylor DAT_INVALID_HANDLE_CNO);
132*9e39c5baSBill Taylor goto bail;
133*9e39c5baSBill Taylor }
134*9e39c5baSBill Taylor
135*9e39c5baSBill Taylor /*
136*9e39c5baSBill Taylor * Check the merging attributes to ensure the combination of
137*9e39c5baSBill Taylor * flags requested is supported.
138*9e39c5baSBill Taylor */
139*9e39c5baSBill Taylor (void) dapl_ia_query(ia_handle, NULL,
140*9e39c5baSBill Taylor 0, NULL,
141*9e39c5baSBill Taylor DAT_PROVIDER_FIELD_ALL, &provider_attr);
142*9e39c5baSBill Taylor
143*9e39c5baSBill Taylor
144*9e39c5baSBill Taylor for (i = 0; i < 6; i++) {
145*9e39c5baSBill Taylor if (mask[i] & evd_flags) {
146*9e39c5baSBill Taylor for (j = i; j < 6; j++) {
147*9e39c5baSBill Taylor if (mask[j] & evd_flags) {
148*9e39c5baSBill Taylor if (provider_attr.
149*9e39c5baSBill Taylor evd_stream_merging_supported[i][j]
150*9e39c5baSBill Taylor == DAT_FALSE) {
151*9e39c5baSBill Taylor dat_status = DAT_ERROR(
152*9e39c5baSBill Taylor DAT_INVALID_PARAMETER,
153*9e39c5baSBill Taylor DAT_INVALID_ARG4);
154*9e39c5baSBill Taylor goto bail;
155*9e39c5baSBill Taylor }
156*9e39c5baSBill Taylor }
157*9e39c5baSBill Taylor } /* end for j */
158*9e39c5baSBill Taylor }
159*9e39c5baSBill Taylor } /* end for i */
160*9e39c5baSBill Taylor
161*9e39c5baSBill Taylor dat_status = dapls_evd_internal_create(ia_ptr,
162*9e39c5baSBill Taylor cno_ptr,
163*9e39c5baSBill Taylor evd_min_qlen,
164*9e39c5baSBill Taylor evd_flags,
165*9e39c5baSBill Taylor &evd_ptr);
166*9e39c5baSBill Taylor if (dat_status != DAT_SUCCESS) {
167*9e39c5baSBill Taylor goto bail;
168*9e39c5baSBill Taylor }
169*9e39c5baSBill Taylor
170*9e39c5baSBill Taylor evd_ptr->evd_state = DAPL_EVD_STATE_OPEN;
171*9e39c5baSBill Taylor
172*9e39c5baSBill Taylor *evd_handle = (DAT_EVD_HANDLE) evd_ptr;
173*9e39c5baSBill Taylor
174*9e39c5baSBill Taylor bail:
175*9e39c5baSBill Taylor if (dat_status != DAT_SUCCESS) {
176*9e39c5baSBill Taylor if (evd_ptr) {
177*9e39c5baSBill Taylor (void) dapl_evd_free(evd_ptr);
178*9e39c5baSBill Taylor }
179*9e39c5baSBill Taylor }
180*9e39c5baSBill Taylor
181*9e39c5baSBill Taylor dapl_dbg_log(DAPL_DBG_TYPE_RTN,
182*9e39c5baSBill Taylor "dapl_evd_create () returns 0x%x\n",
183*9e39c5baSBill Taylor dat_status);
184*9e39c5baSBill Taylor
185*9e39c5baSBill Taylor return (dat_status);
186*9e39c5baSBill Taylor }
187