1 /*
2 * Copyright (c) 2004-2009 Voltaire, Inc. All rights reserved.
3 * Copyright (c) 2002-2005 Mellanox Technologies LTD. All rights reserved.
4 * Copyright (c) 1996-2003 Intel Corporation. All rights reserved.
5 * Copyright (c) 2013 Oracle and/or its affiliates. All rights reserved.
6 *
7 * This software is available to you under a choice of one of two
8 * licenses. You may choose to be licensed under the terms of the GNU
9 * General Public License (GPL) Version 2, available from the file
10 * COPYING in the main directory of this source tree, or the
11 * OpenIB.org BSD license below:
12 *
13 * Redistribution and use in source and binary forms, with or
14 * without modification, are permitted provided that the following
15 * conditions are met:
16 *
17 * - Redistributions of source code must retain the above
18 * copyright notice, this list of conditions and the following
19 * disclaimer.
20 *
21 * - Redistributions in binary form must reproduce the above
22 * copyright notice, this list of conditions and the following
23 * disclaimer in the documentation and/or other materials
24 * provided with the distribution.
25 *
26 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
27 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
28 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
29 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
30 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
31 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
32 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
33 * SOFTWARE.
34 *
35 */
36
37 /*
38 * Abstract:
39 * Implementation of osm_smir_rcv_t.
40 * This object represents the SMInfo Receiver object.
41 * This object is part of the opensm family of objects.
42 */
43
44 #if HAVE_CONFIG_H
45 # include <config.h>
46 #endif /* HAVE_CONFIG_H */
47
48 #include <string.h>
49 #include <iba/ib_types.h>
50 #include <complib/cl_qmap.h>
51 #include <complib/cl_passivelock.h>
52 #include <complib/cl_debug.h>
53 #include <complib/cl_qlist.h>
54 #include <opensm/osm_file_ids.h>
55 #define FILE_ID OSM_FILE_SA_SMINFO_RECORD_C
56 #include <vendor/osm_vendor_api.h>
57 #include <opensm/osm_madw.h>
58 #include <opensm/osm_log.h>
59 #include <opensm/osm_subnet.h>
60 #include <opensm/osm_mad_pool.h>
61 #include <opensm/osm_helper.h>
62 #include <opensm/osm_msgdef.h>
63 #include <opensm/osm_port.h>
64 #include <opensm/osm_pkey.h>
65 #include <opensm/osm_remote_sm.h>
66 #include <opensm/osm_sa.h>
67 #include <opensm/osm_opensm.h>
68
69 #define SA_SMIR_RESP_SIZE SA_ITEM_RESP_SIZE(sminfo_rec)
70
71 typedef struct osm_smir_search_ctxt {
72 const ib_sminfo_record_t *p_rcvd_rec;
73 ib_net64_t comp_mask;
74 cl_qlist_t *p_list;
75 osm_sa_t *sa;
76 const osm_physp_t *p_req_physp;
77 } osm_smir_search_ctxt_t;
78
smir_rcv_new_smir(IN osm_sa_t * sa,IN const osm_port_t * p_port,IN cl_qlist_t * p_list,IN ib_net64_t const guid,IN ib_net32_t const act_count,IN uint8_t const pri_state,IN const osm_physp_t * p_req_physp)79 static ib_api_status_t smir_rcv_new_smir(IN osm_sa_t * sa,
80 IN const osm_port_t * p_port,
81 IN cl_qlist_t * p_list,
82 IN ib_net64_t const guid,
83 IN ib_net32_t const act_count,
84 IN uint8_t const pri_state,
85 IN const osm_physp_t * p_req_physp)
86 {
87 osm_sa_item_t *p_rec_item;
88 ib_api_status_t status = IB_SUCCESS;
89
90 OSM_LOG_ENTER(sa->p_log);
91
92 p_rec_item = malloc(SA_SMIR_RESP_SIZE);
93 if (p_rec_item == NULL) {
94 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2801: "
95 "rec_item alloc failed\n");
96 status = IB_INSUFFICIENT_RESOURCES;
97 goto Exit;
98 }
99
100 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
101 "New SMInfo: GUID 0x%016" PRIx64 "\n", cl_ntoh64(guid));
102
103 memset(p_rec_item, 0, SA_SMIR_RESP_SIZE);
104
105 p_rec_item->resp.sminfo_rec.lid = osm_port_get_base_lid(p_port);
106 p_rec_item->resp.sminfo_rec.sm_info.guid = guid;
107 p_rec_item->resp.sminfo_rec.sm_info.act_count = act_count;
108 p_rec_item->resp.sminfo_rec.sm_info.pri_state = pri_state;
109
110 cl_qlist_insert_tail(p_list, &p_rec_item->list_item);
111
112 Exit:
113 OSM_LOG_EXIT(sa->p_log);
114 return status;
115 }
116
sa_smir_by_comp_mask(IN osm_sa_t * sa,IN const osm_remote_sm_t * p_rem_sm,osm_smir_search_ctxt_t * p_ctxt)117 static void sa_smir_by_comp_mask(IN osm_sa_t * sa,
118 IN const osm_remote_sm_t * p_rem_sm,
119 osm_smir_search_ctxt_t * p_ctxt)
120 {
121 const ib_sminfo_record_t *const p_rcvd_rec = p_ctxt->p_rcvd_rec;
122 const osm_physp_t *const p_req_physp = p_ctxt->p_req_physp;
123 ib_net64_t const comp_mask = p_ctxt->comp_mask;
124 osm_port_t *p_port;
125
126 OSM_LOG_ENTER(sa->p_log);
127
128 if (comp_mask & IB_SMIR_COMPMASK_GUID) {
129 if (p_rem_sm->smi.guid != p_rcvd_rec->sm_info.guid)
130 goto Exit;
131 }
132
133 if (comp_mask & IB_SMIR_COMPMASK_PRIORITY) {
134 if (ib_sminfo_get_priority(&p_rem_sm->smi) !=
135 ib_sminfo_get_priority(&p_rcvd_rec->sm_info))
136 goto Exit;
137 }
138
139 if (comp_mask & IB_SMIR_COMPMASK_SMSTATE) {
140 if (ib_sminfo_get_state(&p_rem_sm->smi) !=
141 ib_sminfo_get_state(&p_rcvd_rec->sm_info))
142 goto Exit;
143 }
144
145 /* Implement any other needed search cases */
146 p_port = osm_get_port_by_guid(sa->p_subn, p_rem_sm->smi.guid);
147
148 if (p_port == NULL) {
149 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2810: "
150 "No port for remote sm\n");
151 goto Exit;
152 }
153
154 smir_rcv_new_smir(sa, p_port, p_ctxt->p_list,
155 p_rem_sm->smi.guid, p_rem_sm->smi.act_count,
156 p_rem_sm->smi.pri_state, p_req_physp);
157
158 Exit:
159 OSM_LOG_EXIT(sa->p_log);
160 }
161
sa_smir_by_comp_mask_cb(IN cl_map_item_t * p_map_item,IN void * cxt)162 static void sa_smir_by_comp_mask_cb(IN cl_map_item_t * p_map_item, IN void *cxt)
163 {
164 const osm_remote_sm_t *p_rem_sm = (osm_remote_sm_t *) p_map_item;
165 osm_smir_search_ctxt_t *p_ctxt = cxt;
166
167 sa_smir_by_comp_mask(p_ctxt->sa, p_rem_sm, p_ctxt);
168 }
169
osm_smir_rcv_process(IN void * ctx,IN void * data)170 void osm_smir_rcv_process(IN void *ctx, IN void *data)
171 {
172 osm_sa_t *sa = ctx;
173 osm_madw_t *p_madw = data;
174 const ib_sa_mad_t *sad_mad;
175 const ib_sminfo_record_t *p_rcvd_rec;
176 const osm_port_t *p_port = NULL;
177 const ib_sm_info_t *p_smi;
178 cl_qlist_t rec_list;
179 osm_smir_search_ctxt_t context;
180 ib_api_status_t status = IB_SUCCESS;
181 ib_net64_t comp_mask;
182 ib_net64_t port_guid;
183 osm_physp_t *p_req_physp;
184 osm_port_t *local_port;
185 osm_remote_sm_t *p_rem_sm;
186 cl_qmap_t *p_sm_guid_tbl;
187 uint8_t pri_state;
188
189 CL_ASSERT(sa);
190
191 OSM_LOG_ENTER(sa->p_log);
192
193 CL_ASSERT(p_madw);
194
195 sad_mad = osm_madw_get_sa_mad_ptr(p_madw);
196 p_rcvd_rec = (ib_sminfo_record_t *) ib_sa_mad_get_payload_ptr(sad_mad);
197 comp_mask = sad_mad->comp_mask;
198
199 CL_ASSERT(sad_mad->attr_id == IB_MAD_ATTR_SMINFO_RECORD);
200
201 /* we only support SubnAdmGet and SubnAdmGetTable methods */
202 if (sad_mad->method != IB_MAD_METHOD_GET &&
203 sad_mad->method != IB_MAD_METHOD_GETTABLE) {
204 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2804: "
205 "Unsupported Method (%s) for SMInfoRecord request\n",
206 ib_get_sa_method_str(sad_mad->method));
207 osm_sa_send_error(sa, p_madw, IB_MAD_STATUS_UNSUP_METHOD_ATTR);
208 goto Exit;
209 }
210
211 cl_plock_acquire(sa->p_lock);
212
213 /* update the requester physical port */
214 p_req_physp = osm_get_physp_by_mad_addr(sa->p_log, sa->p_subn,
215 osm_madw_get_mad_addr_ptr
216 (p_madw));
217 if (p_req_physp == NULL) {
218 cl_plock_release(sa->p_lock);
219 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2803: "
220 "Cannot find requester physical port\n");
221 goto Exit;
222 }
223
224 if (OSM_LOG_IS_ACTIVE_V2(sa->p_log, OSM_LOG_DEBUG)) {
225 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
226 "Requester port GUID 0x%" PRIx64 "\n",
227 cl_ntoh64(osm_physp_get_port_guid(p_req_physp)));
228 osm_dump_sm_info_record_v2(sa->p_log, p_rcvd_rec, FILE_ID, OSM_LOG_DEBUG);
229 }
230
231 p_smi = &p_rcvd_rec->sm_info;
232
233 cl_qlist_init(&rec_list);
234
235 context.p_rcvd_rec = p_rcvd_rec;
236 context.p_list = &rec_list;
237 context.comp_mask = sad_mad->comp_mask;
238 context.sa = sa;
239 context.p_req_physp = p_req_physp;
240
241 /*
242 If the user specified a LID, it obviously narrows our
243 work load, since we don't have to search every port
244 */
245 if (comp_mask & IB_SMIR_COMPMASK_LID) {
246 p_port = osm_get_port_by_lid(sa->p_subn, p_rcvd_rec->lid);
247 if (!p_port) {
248 status = IB_NOT_FOUND;
249 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2806: "
250 "No port found with LID %u\n",
251 cl_ntoh16(p_rcvd_rec->lid));
252 }
253 }
254
255 if (status == IB_SUCCESS) {
256 /* Handle our own SM first */
257 local_port = osm_get_port_by_guid(sa->p_subn,
258 sa->p_subn->sm_port_guid);
259 if (!local_port) {
260 cl_plock_release(sa->p_lock);
261 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2809: "
262 "No port found with GUID 0x%016" PRIx64 "\n",
263 cl_ntoh64(sa->p_subn->sm_port_guid));
264 goto Exit;
265 }
266
267 if (!p_port || local_port == p_port) {
268 if (FALSE ==
269 osm_physp_share_pkey(sa->p_log, p_req_physp,
270 local_port->p_physp,
271 sa->p_subn->opt.allow_both_pkeys)) {
272 cl_plock_release(sa->p_lock);
273 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 2805: "
274 "Cannot get SMInfo record due to pkey violation\n");
275 goto Exit;
276 }
277
278 /* Check that other search components specified match */
279 if ((comp_mask & IB_SMIR_COMPMASK_GUID) &&
280 sa->p_subn->sm_port_guid != p_smi->guid)
281 goto Remotes;
282 if ((comp_mask & IB_SMIR_COMPMASK_PRIORITY) &&
283 sa->p_subn->opt.sm_priority !=
284 ib_sminfo_get_priority(p_smi))
285 goto Remotes;
286 if ((comp_mask & IB_SMIR_COMPMASK_SMSTATE) &&
287 sa->p_subn->sm_state != ib_sminfo_get_state(p_smi))
288 goto Remotes;
289
290 /* Now, add local SMInfo to list */
291 pri_state = sa->p_subn->sm_state & 0x0F;
292 pri_state |= (sa->p_subn->opt.sm_priority & 0x0F) << 4;
293 smir_rcv_new_smir(sa, local_port, context.p_list,
294 sa->p_subn->sm_port_guid,
295 cl_ntoh32(sa->p_subn->p_osm->stats.
296 qp0_mads_sent), pri_state,
297 p_req_physp);
298 }
299
300 Remotes:
301 if (p_port && p_port != local_port) {
302 /* Find remote SM corresponding to p_port */
303 port_guid = osm_port_get_guid(p_port);
304 p_sm_guid_tbl = &sa->p_subn->sm_guid_tbl;
305 p_rem_sm =
306 (osm_remote_sm_t *) cl_qmap_get(p_sm_guid_tbl,
307 port_guid);
308 if (p_rem_sm !=
309 (osm_remote_sm_t *) cl_qmap_end(p_sm_guid_tbl))
310 sa_smir_by_comp_mask(sa, p_rem_sm, &context);
311 else
312 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 280A: "
313 "No remote SM for GUID 0x%016" PRIx64
314 "\n", cl_ntoh64(port_guid));
315 } else if (!p_port) {
316 /* Go over all other known (remote) SMs */
317 cl_qmap_apply_func(&sa->p_subn->sm_guid_tbl,
318 sa_smir_by_comp_mask_cb, &context);
319 }
320 }
321
322 cl_plock_release(sa->p_lock);
323
324 osm_sa_respond(sa, p_madw, sizeof(ib_sminfo_record_t), &rec_list);
325
326 Exit:
327 OSM_LOG_EXIT(sa->p_log);
328 }
329