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 (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
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: dapl_psp_create.c
34 *
35 * PURPOSE: Connection management
36 * Description: Interfaces in this file are completely described in
37 * the DAPL 1.1 API, Chapter 6, section 4
38 *
39 * $Id: dapl_psp_create_any.c,v 1.4 2003/06/23 12:28:05 sjs2 Exp $
40 */
41
42 #include "dapl.h"
43 #include "dapl_sp_util.h"
44 #include "dapl_ia_util.h"
45 #include "dapl_adapter_util.h"
46
47 /*
48 * dapl_psp_create_any
49 *
50 * uDAPL: User Direct Access Program Library Version 1.1, 6.4.3.3
51 *
52 * Create a persistent Public Service Point that can recieve multiple
53 * requests for connections and generate multiple connection request
54 * instances that wil be delivered to the specified Event Dispatcher
55 * in a notification event. Differs from dapl_psp_create() in that
56 * the conn_qual is selected by the implementation and returned to
57 * the user.
58 *
59 * Input:
60 * ia_handle
61 * evd_handle
62 * psp_flags
63 *
64 * Output:
65 * conn_qual
66 * psp_handle
67 *
68 * Returns:
69 * DAT_SUCCESS
70 * DAT_INSUFFICIENT_RESOURCES
71 * DAT_INVALID_HANDLE
72 * DAT_INVALID_PARAMETER
73 * DAT_CONN_QUAL_IN_USE
74 * DAT_MODEL_NOT_SUPPORTED
75 */
76 DAT_RETURN
dapl_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)77 dapl_psp_create_any(
78 IN DAT_IA_HANDLE ia_handle,
79 OUT DAT_CONN_QUAL *conn_qual,
80 IN DAT_EVD_HANDLE evd_handle,
81 IN DAT_PSP_FLAGS psp_flags,
82 OUT DAT_PSP_HANDLE *psp_handle)
83 {
84 DAPL_IA *ia_ptr;
85 DAPL_SP *sp_ptr;
86 DAPL_EVD *evd_ptr;
87 DAT_RETURN dat_status;
88
89 ia_ptr = (DAPL_IA *)ia_handle;
90 dat_status = DAT_SUCCESS;
91
92 if (DAPL_BAD_HANDLE(ia_ptr, DAPL_MAGIC_IA)) {
93 dat_status = DAT_ERROR(DAT_INVALID_HANDLE,
94 DAT_INVALID_HANDLE_IA);
95 goto bail;
96 }
97
98 if (DAPL_BAD_HANDLE(evd_handle, DAPL_MAGIC_EVD)) {
99 dat_status = DAT_ERROR(DAT_INVALID_HANDLE,
100 DAT_INVALID_HANDLE_EVD_CR);
101 goto bail;
102 }
103
104 if (psp_handle == NULL) {
105 dat_status = DAT_ERROR(DAT_INVALID_PARAMETER, DAT_INVALID_ARG5);
106 goto bail;
107 }
108
109 if (conn_qual == NULL) {
110 dat_status = DAT_ERROR(DAT_INVALID_PARAMETER, DAT_INVALID_ARG2);
111 goto bail;
112 }
113
114 /* check for invalid psp flags */
115 if ((psp_flags != DAT_PSP_CONSUMER_FLAG) &&
116 (psp_flags != DAT_PSP_PROVIDER_FLAG)) {
117 dat_status = DAT_ERROR(DAT_INVALID_PARAMETER, DAT_INVALID_ARG4);
118 goto bail;
119 }
120
121 evd_ptr = (DAPL_EVD *)evd_handle;
122 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
123 dat_status = DAT_ERROR(DAT_INVALID_HANDLE,
124 DAT_INVALID_HANDLE_EVD_CR);
125 goto bail;
126 }
127
128 /* Allocate PSP */
129 sp_ptr = dapls_sp_alloc(ia_ptr, DAT_TRUE);
130 if (sp_ptr == NULL) {
131 dat_status = DAT_ERROR(DAT_INSUFFICIENT_RESOURCES,
132 DAT_RESOURCE_MEMORY);
133 goto bail;
134 }
135
136 /*
137 * Fill out the args for a PSP
138 */
139 sp_ptr->ia_handle = ia_handle;
140 sp_ptr->evd_handle = evd_handle;
141 sp_ptr->psp_flags = psp_flags;
142 sp_ptr->ep_handle = NULL;
143
144 /*
145 * Take a reference on the EVD handle
146 */
147 dapl_os_atomic_inc(&((DAPL_EVD *)evd_handle)->evd_ref_count);
148
149 /* Link it onto the IA */
150 dapl_ia_link_psp(ia_ptr, sp_ptr);
151
152 /*
153 * Set up a listener for a connection. Connections can arrive
154 * even before this call returns!
155 */
156 sp_ptr->state = DAPL_SP_STATE_PSP_LISTENING;
157 sp_ptr->listening = DAT_TRUE;
158
159 dat_status = dapls_ib_setup_conn_listener(ia_ptr, 0, sp_ptr);
160
161 if (dat_status != DAT_SUCCESS) {
162 /*
163 * Have a problem setting up the connection, something wrong!
164 */
165 dapl_os_atomic_dec(&((DAPL_EVD *)evd_handle)->evd_ref_count);
166 sp_ptr->state = DAPL_SP_STATE_FREE;
167 sp_ptr->listening = DAT_FALSE;
168 (void) dapl_psp_free((DAT_PSP_HANDLE)sp_ptr);
169
170 dapl_dbg_log(DAPL_DBG_TYPE_ERR,
171 "--> dapl_psp_create cannot set up conn listener: %x\n",
172 dat_status);
173
174 goto bail;
175 }
176
177 /*
178 * Return handle to the user
179 */
180 *conn_qual = sp_ptr->conn_qual;
181 *psp_handle = (DAT_PSP_HANDLE)sp_ptr;
182
183 bail:
184 return (dat_status);
185 }
186