contrib/ofed/opensm/opensm/osm_sa_informinfo.c

   1 /*
   2  * Copyright (c) 2004-2009 Voltaire, Inc. All rights reserved.
   3  * Copyright (c) 2002-2006 Mellanox Technologies LTD. All rights reserved.
   4  * Copyright (c) 1996-2003 Intel Corporation. All rights reserved.
   5  * Copyright (c) 2009 HNR Consulting. All rights reserved.
   6  * Copyright (c) 2013 Oracle and/or its affiliates. All rights reserved.
   7  *
   8  * This software is available to you under a choice of one of two
   9  * licenses.  You may choose to be licensed under the terms of the GNU
  10  * General Public License (GPL) Version 2, available from the file
  11  * COPYING in the main directory of this source tree, or the
  12  * OpenIB.org BSD license below:
  13  *
  14  *     Redistribution and use in source and binary forms, with or
  15  *     without modification, are permitted provided that the following
  16  *     conditions are met:
  17  *
  18  *      - Redistributions of source code must retain the above
  19  *        copyright notice, this list of conditions and the following
  20  *        disclaimer.
  21  *
  22  *      - Redistributions in binary form must reproduce the above
  23  *        copyright notice, this list of conditions and the following
  24  *        disclaimer in the documentation and/or other materials
  25  *        provided with the distribution.
  26  *
  27  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  28  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  29  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  30  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  31  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  32  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  33  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  34  * SOFTWARE.
  35  *
  36  */
  37
  38 /*
  39  * Abstract:
  40  *    Implementation of osm_infr_rcv_t.
  41  * This object represents the InformInfo Receiver object.
  42  * This object is part of the opensm family of objects.
  43  */
  44
  45 #if HAVE_CONFIG_H
  46 #  include <config.h>
  47 #endif                          /* HAVE_CONFIG_H */
  48
  49 #include <string.h>
  50 #include <iba/ib_types.h>
  51 #include <arpa/inet.h>
  52 #include <sys/socket.h>
  53 #include <complib/cl_qmap.h>
  54 #include <complib/cl_passivelock.h>
  55 #include <complib/cl_debug.h>
  56 #include <complib/cl_qlist.h>
  57 #include <opensm/osm_file_ids.h>
  58 #define FILE_ID OSM_FILE_SA_INFORMINFO_C
  59 #include <vendor/osm_vendor_api.h>
  60 #include <opensm/osm_port.h>
  61 #include <opensm/osm_node.h>
  62 #include <opensm/osm_switch.h>
  63 #include <opensm/osm_helper.h>
  64 #include <opensm/osm_sa.h>
  65 #include <opensm/osm_inform.h>
  66 #include <opensm/osm_pkey.h>
  67
  68 #define SA_IIR_RESP_SIZE SA_ITEM_RESP_SIZE(inform_rec)
  69 #define SA_II_RESP_SIZE SA_ITEM_RESP_SIZE(inform)
  70
  71 typedef struct osm_iir_search_ctxt {
  72         const ib_inform_info_record_t *p_rcvd_rec;
  73         ib_net64_t comp_mask;
  74         cl_qlist_t *p_list;
  75         ib_gid_t subscriber_gid;
  76         ib_net16_t subscriber_enum;
  77         osm_sa_t *sa;
  78         osm_physp_t *p_req_physp;
  79         ib_net64_t sm_key;
  80 } osm_iir_search_ctxt_t;
  81
  82 /**********************************************************************
  83 o13-14.1.1: Except for Set(InformInfo) requests with Inform-
  84 Info:LIDRangeBegin=0xFFFF, managers that support event forwarding
  85 shall, upon receiving a Set(InformInfo), verify that the requester
  86 originating the Set(InformInfo) and a Trap() source identified by Inform-
  87 can access each other - can use path record to verify that.
  88 **********************************************************************/
  89 static boolean_t validate_ports_access_rights(IN osm_sa_t * sa,
  90                                               IN osm_infr_t * p_infr_rec)
  91 {
  92         boolean_t valid = TRUE;
  93         osm_physp_t *p_requester_physp;
  94         osm_port_t *p_port;
  95         ib_net64_t portguid;
  96         uint16_t lid_range_begin, lid_range_end, lid;
  97
  98         OSM_LOG_ENTER(sa->p_log);
  99
 100         /* get the requester physp from the request address */
 101         p_requester_physp = osm_get_physp_by_mad_addr(sa->p_log, sa->p_subn,
 102                                                       &p_infr_rec->report_addr);
 103
 104         if (ib_gid_is_notzero(&p_infr_rec->inform_record.inform_info.gid)) {
 105                 /* a gid is defined */
 106                 portguid =
 107                     p_infr_rec->inform_record.inform_info.gid.unicast.
 108                     interface_id;
 109
 110                 p_port = osm_get_port_by_guid(sa->p_subn, portguid);
 111                 if (p_port == NULL) {
 112                         OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4301: "
 113                                 "Invalid port guid: 0x%016" PRIx64 "\n",
 114                                 cl_ntoh64(portguid));
 115                         valid = FALSE;
 116                         goto Exit;
 117                 }
 118
 119                 /* make sure that the requester and destination port can access
 120                    each other according to the current partitioning. */
 121                 if (!osm_physp_share_pkey
 122                     (sa->p_log, p_port->p_physp, p_requester_physp,
 123                      sa->p_subn->opt.allow_both_pkeys)) {
 124                         OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 125                                 "port and requester don't share pkey\n");
 126                         valid = FALSE;
 127                         goto Exit;
 128                 }
 129         } else {
 130                 size_t lids_size;
 131
 132                 /* gid is zero - check if LID range is defined */
 133                 lid_range_begin =
 134                     cl_ntoh16(p_infr_rec->inform_record.inform_info.
 135                               lid_range_begin);
 136                 /* if lid is 0xFFFF - meaning all endports managed by the manager */
 137                 if (lid_range_begin == 0xFFFF)
 138                         goto Exit;
 139
 140                 lid_range_end =
 141                     cl_ntoh16(p_infr_rec->inform_record.inform_info.
 142                               lid_range_end);
 143
 144                 lids_size = cl_ptr_vector_get_size(&sa->p_subn->port_lid_tbl);
 145
 146                 /* lid_range_end is set to zero if no range desired. In this
 147                    case - just make it equal to the lid_range_begin. */
 148                 if (lid_range_end == 0)
 149                         lid_range_end = lid_range_begin;
 150                 else if (lid_range_end >= lids_size)
 151                         lid_range_end = lids_size - 1;
 152
 153                 if (lid_range_begin >= lids_size) {
 154                         /* requested lids are out of range */
 155                         OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4302: "
 156                                 "Given LIDs (%u-%u) are out of range (%zu)\n",
 157                                 lid_range_begin, lid_range_end, lids_size);
 158                         valid = FALSE;
 159                         goto Exit;
 160                 }
 161
 162                 /* go over all defined lids within the range and make sure that the
 163                    requester port can access them according to current partitioning. */
 164                 for (lid = lid_range_begin; lid <= lid_range_end; lid++) {
 165                         p_port = osm_get_port_by_lid_ho(sa->p_subn, lid);
 166                         if (p_port == NULL)
 167                                 continue;
 168
 169                         /* make sure that the requester and destination port can access
 170                            each other according to the current partitioning. */
 171                         if (!osm_physp_share_pkey
 172                             (sa->p_log, p_port->p_physp, p_requester_physp,
 173                              sa->p_subn->opt.allow_both_pkeys)) {
 174                                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 175                                         "port and requester don't share pkey\n");
 176                                 valid = FALSE;
 177                                 goto Exit;
 178                         }
 179                 }
 180         }
 181
 182 Exit:
 183         OSM_LOG_EXIT(sa->p_log);
 184         return valid;
 185 }
 186
 187 static boolean_t validate_infr(IN osm_sa_t * sa, IN osm_infr_t * p_infr_rec)
 188 {
 189         boolean_t valid = TRUE;
 190
 191         OSM_LOG_ENTER(sa->p_log);
 192
 193         valid = validate_ports_access_rights(sa, p_infr_rec);
 194         if (!valid) {
 195                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 196                         "Invalid Access for InformInfo\n");
 197                 valid = FALSE;
 198         }
 199
 200         OSM_LOG_EXIT(sa->p_log);
 201         return valid;
 202 }
 203
 204 /**********************************************************************
 205 o13-12.1.1: Confirm a valid request for event subscription by responding
 206 with an InformInfo attribute that is a copy of the data in the
 207 Set(InformInfo) request.
 208 **********************************************************************/
 209 static void infr_rcv_respond(IN osm_sa_t * sa, IN osm_madw_t * p_madw)
 210 {
 211         cl_qlist_t rec_list;
 212         osm_sa_item_t *item;
 213
 214         OSM_LOG_ENTER(sa->p_log);
 215
 216         OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 217                 "Generating successful InformInfo response\n");
 218
 219         item = malloc(SA_II_RESP_SIZE);
 220         if (!item) {
 221                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4303: "
 222                         "rec_item alloc failed\n");
 223                 goto Exit;
 224         }
 225
 226         memcpy(&item->resp.inform,
 227                ib_sa_mad_get_payload_ptr(osm_madw_get_sa_mad_ptr(p_madw)),
 228                sizeof(ib_inform_info_t));
 229
 230         cl_qlist_init(&rec_list);
 231         cl_qlist_insert_tail(&rec_list, &item->list_item);
 232
 233         osm_sa_respond(sa, p_madw, sizeof(ib_inform_info_t), &rec_list);
 234
 235 Exit:
 236         OSM_LOG_EXIT(sa->p_log);
 237 }
 238
 239 static void sa_inform_info_rec_by_comp_mask(IN osm_sa_t * sa,
 240                                             IN const osm_infr_t * p_infr,
 241                                             osm_iir_search_ctxt_t * p_ctxt)
 242 {
 243         ib_net64_t comp_mask;
 244         ib_net64_t portguid;
 245         osm_port_t *p_subscriber_port;
 246         osm_physp_t *p_subscriber_physp;
 247         const osm_physp_t *p_req_physp;
 248         osm_sa_item_t *p_rec_item;
 249
 250         OSM_LOG_ENTER(sa->p_log);
 251
 252         comp_mask = p_ctxt->comp_mask;
 253         p_req_physp = p_ctxt->p_req_physp;
 254
 255         if (comp_mask & IB_IIR_COMPMASK_SUBSCRIBERGID &&
 256             memcmp(&p_infr->inform_record.subscriber_gid,
 257                    &p_ctxt->subscriber_gid,
 258                    sizeof(p_infr->inform_record.subscriber_gid)))
 259                 goto Exit;
 260
 261         if (comp_mask & IB_IIR_COMPMASK_ENUM &&
 262             p_infr->inform_record.subscriber_enum != p_ctxt->subscriber_enum)
 263                 goto Exit;
 264
 265         /* Implement any other needed search cases */
 266
 267         /* Ensure pkey is shared before returning any records */
 268         portguid = p_infr->inform_record.subscriber_gid.unicast.interface_id;
 269         p_subscriber_port = osm_get_port_by_guid(sa->p_subn, portguid);
 270         if (p_subscriber_port == NULL) {
 271                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 430D: "
 272                         "Invalid subscriber port guid: 0x%016" PRIx64 "\n",
 273                         cl_ntoh64(portguid));
 274                 goto Exit;
 275         }
 276
 277         /* get the subscriber InformInfo physical port */
 278         p_subscriber_physp = p_subscriber_port->p_physp;
 279         /* make sure that the requester and subscriber port can access each
 280            other according to the current partitioning. */
 281         if (!osm_physp_share_pkey(sa->p_log, p_req_physp, p_subscriber_physp,
 282                                   sa->p_subn->opt.allow_both_pkeys)) {
 283                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 284                         "requester and subscriber ports don't share pkey\n");
 285                 goto Exit;
 286         }
 287
 288         p_rec_item = malloc(SA_IIR_RESP_SIZE);
 289         if (p_rec_item == NULL) {
 290                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 430E: "
 291                         "rec_item alloc failed\n");
 292                 goto Exit;
 293         }
 294
 295         memcpy(&p_rec_item->resp.inform_rec, &p_infr->inform_record,
 296                sizeof(ib_inform_info_record_t));
 297
 298         /*
 299          * Per C15-0.2-1.16, InformInfoRecords shall always be
 300          * provided with the QPN set to 0, except for the case
 301          * of a trusted request, in which case the actual
 302          * subscriber QPN shall be returned.
 303          */
 304         if (p_ctxt->sm_key == 0)
 305                 ib_inform_info_set_qpn(&p_rec_item->resp.inform_rec.inform_info, 0);
 306
 307         cl_qlist_insert_tail(p_ctxt->p_list, &p_rec_item->list_item);
 308
 309 Exit:
 310         OSM_LOG_EXIT(sa->p_log);
 311 }
 312
 313 static void sa_inform_info_rec_by_comp_mask_cb(IN cl_list_item_t * p_list_item,
 314                                                IN void *context)
 315 {
 316         const osm_infr_t *p_infr = (osm_infr_t *) p_list_item;
 317         osm_iir_search_ctxt_t *p_ctxt = context;
 318
 319         sa_inform_info_rec_by_comp_mask(p_ctxt->sa, p_infr, p_ctxt);
 320 }
 321
 322 /**********************************************************************
 323 Received a Get(InformInfoRecord) or GetTable(InformInfoRecord) MAD
 324 **********************************************************************/
 325 static void infr_rcv_process_get_method(osm_sa_t * sa, IN osm_madw_t * p_madw)
 326 {
 327         char gid_str[INET6_ADDRSTRLEN];
 328         ib_sa_mad_t *p_rcvd_mad;
 329         const ib_inform_info_record_t *p_rcvd_rec;
 330         cl_qlist_t rec_list;
 331         osm_iir_search_ctxt_t context;
 332         osm_physp_t *p_req_physp;
 333         osm_sa_item_t *item;
 334
 335         OSM_LOG_ENTER(sa->p_log);
 336
 337         CL_ASSERT(p_madw);
 338         p_rcvd_mad = osm_madw_get_sa_mad_ptr(p_madw);
 339         p_rcvd_rec =
 340             (ib_inform_info_record_t *) ib_sa_mad_get_payload_ptr(p_rcvd_mad);
 341
 342         cl_plock_acquire(sa->p_lock);
 343
 344         /* update the requester physical port */
 345         p_req_physp = osm_get_physp_by_mad_addr(sa->p_log, sa->p_subn,
 346                                                 osm_madw_get_mad_addr_ptr
 347                                                 (p_madw));
 348         if (p_req_physp == NULL) {
 349                 cl_plock_release(sa->p_lock);
 350                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4309: "
 351                         "Cannot find requester physical port\n");
 352                 goto Exit;
 353         }
 354
 355         if (OSM_LOG_IS_ACTIVE_V2(sa->p_log, OSM_LOG_DEBUG)) {
 356                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 357                         "Requester port GUID 0x%" PRIx64 "\n",
 358                         cl_ntoh64(osm_physp_get_port_guid(p_req_physp)));
 359                 osm_dump_inform_info_record_v2(sa->p_log, p_rcvd_rec,
 360                                                FILE_ID, OSM_LOG_DEBUG);
 361         }
 362
 363         cl_qlist_init(&rec_list);
 364
 365         context.p_rcvd_rec = p_rcvd_rec;
 366         context.p_list = &rec_list;
 367         context.comp_mask = p_rcvd_mad->comp_mask;
 368         context.subscriber_gid = p_rcvd_rec->subscriber_gid;
 369         context.subscriber_enum = p_rcvd_rec->subscriber_enum;
 370         context.sa = sa;
 371         context.p_req_physp = p_req_physp;
 372         context.sm_key = p_rcvd_mad->sm_key;
 373
 374         OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 375                 "Query Subscriber GID:%s(%02X) Enum:0x%X(%02X)\n",
 376                 inet_ntop(AF_INET6, p_rcvd_rec->subscriber_gid.raw,
 377                           gid_str, sizeof gid_str),
 378                 (p_rcvd_mad->comp_mask & IB_IIR_COMPMASK_SUBSCRIBERGID) != 0,
 379                 cl_ntoh16(p_rcvd_rec->subscriber_enum),
 380                 (p_rcvd_mad->comp_mask & IB_IIR_COMPMASK_ENUM) != 0);
 381
 382         cl_qlist_apply_func(&sa->p_subn->sa_infr_list,
 383                             sa_inform_info_rec_by_comp_mask_cb, &context);
 384
 385         /* clear reserved and pad fields in InformInfoRecord */
 386         for (item = (osm_sa_item_t *) cl_qlist_head(&rec_list);
 387              item != (osm_sa_item_t *) cl_qlist_end(&rec_list);
 388              item = (osm_sa_item_t *) cl_qlist_next(&item->list_item)) {
 389                 memset(item->resp.inform_rec.reserved, 0, sizeof(item->resp.inform_rec.reserved));
 390                 memset(item->resp.inform_rec.pad, 0, sizeof(item->resp.inform_rec.pad));
 391         }
 392
 393         cl_plock_release(sa->p_lock);
 394
 395         osm_sa_respond(sa, p_madw, sizeof(ib_inform_info_record_t), &rec_list);
 396
 397 Exit:
 398         OSM_LOG_EXIT(sa->p_log);
 399 }
 400
 401 /*********************************************************************
 402 Received a Set(InformInfo) MAD
 403 **********************************************************************/
 404 static void infr_rcv_process_set_method(osm_sa_t * sa, IN osm_madw_t * p_madw)
 405 {
 406         ib_sa_mad_t *p_sa_mad;
 407         ib_inform_info_t *p_recvd_inform_info;
 408         osm_infr_t inform_info_rec;     /* actual inform record to be stored for reports */
 409         osm_infr_t *p_infr;
 410         ib_net32_t qpn;
 411         uint8_t resp_time_val;
 412         ib_api_status_t res;
 413
 414         OSM_LOG_ENTER(sa->p_log);
 415
 416         CL_ASSERT(p_madw);
 417
 418         p_sa_mad = osm_madw_get_sa_mad_ptr(p_madw);
 419         p_recvd_inform_info =
 420             (ib_inform_info_t *) ib_sa_mad_get_payload_ptr(p_sa_mad);
 421
 422 #if 0
 423         if (OSM_LOG_IS_ACTIVE_V2(sa->p_log, OSM_LOG_DEBUG))
 424                 osm_dump_inform_info_v2(sa->p_log, p_recvd_inform_info,
 425                                         FILE_ID, OSM_LOG_DEBUG);
 426 #endif
 427
 428         /* Grab the lock */
 429         cl_plock_excl_acquire(sa->p_lock);
 430
 431         /* define the inform record */
 432         inform_info_rec.inform_record.inform_info = *p_recvd_inform_info;
 433
 434         /* following C13-32.1.2 Tbl 120: we only copy the source address vector */
 435         inform_info_rec.report_addr = p_madw->mad_addr;
 436
 437         /* we will need to know the mad srvc to send back through */
 438         inform_info_rec.h_bind = p_madw->h_bind;
 439         inform_info_rec.sa = sa;
 440
 441         /* update the subscriber GID according to mad address */
 442         res = osm_get_gid_by_mad_addr(sa->p_log, sa->p_subn, &p_madw->mad_addr,
 443                                       &inform_info_rec.inform_record.
 444                                       subscriber_gid);
 445         if (res != IB_SUCCESS) {
 446                 cl_plock_release(sa->p_lock);
 447
 448                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4308: "
 449                         "Subscribe Request from unknown LID: %u\n",
 450                         cl_ntoh16(p_madw->mad_addr.dest_lid));
 451                 osm_sa_send_error(sa, p_madw, IB_SA_MAD_STATUS_REQ_INVALID);
 452                 goto Exit;
 453         }
 454
 455         /* HACK: enum is always 0 (currently) */
 456         inform_info_rec.inform_record.subscriber_enum = 0;
 457
 458         /* Subscribe values above 1 are undefined */
 459         if (p_recvd_inform_info->subscribe > 1) {
 460                 cl_plock_release(sa->p_lock);
 461
 462                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 430A: "
 463                         "Invalid subscribe: %d\n",
 464                         p_recvd_inform_info->subscribe);
 465                 osm_sa_send_error(sa, p_madw, IB_SA_MAD_STATUS_REQ_INVALID);
 466                 goto Exit;
 467         }
 468
 469         /*
 470          * Per C15-0.2-1.16, SubnAdmSet(InformInfo) subscriptions for
 471          * SM security traps shall be provided only if they come from a
 472          * trusted source.
 473          */
 474         if ((p_sa_mad->sm_key == 0) && p_recvd_inform_info->is_generic &&
 475             ((cl_ntoh16(p_recvd_inform_info->g_or_v.generic.trap_num) >= SM_BAD_MKEY_TRAP) &&
 476              (cl_ntoh16(p_recvd_inform_info->g_or_v.generic.trap_num) <= SM_BAD_SWITCH_PKEY_TRAP))) {
 477                 cl_plock_release(sa->p_lock);
 478
 479                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 430B "
 480                         "Request for security trap from non-trusted requester: "
 481                         "Given SM_Key:0x%016" PRIx64 "\n",
 482                         cl_ntoh64(p_sa_mad->sm_key));
 483                 osm_sa_send_error(sa, p_madw, IB_SA_MAD_STATUS_REQ_INVALID);
 484                 goto Exit;
 485         }
 486
 487         /*
 488          * MODIFICATIONS DONE ON INCOMING REQUEST:
 489          *
 490          * QPN:
 491          * Internally we keep the QPN field of the InformInfo updated
 492          * so we can simply compare it in the record - when finding such.
 493          */
 494         if (p_recvd_inform_info->subscribe) {
 495                 ib_inform_info_set_qpn(&inform_info_rec.inform_record.
 496                                        inform_info,
 497                                        inform_info_rec.report_addr.addr_type.
 498                                        gsi.remote_qp);
 499
 500                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 501                         "Subscribe Request with QPN: 0x%06X\n",
 502                         cl_ntoh32(inform_info_rec.report_addr.addr_type.gsi.
 503                                   remote_qp));
 504         } else {
 505                 ib_inform_info_get_qpn_resp_time(p_recvd_inform_info->g_or_v.
 506                                                  generic.qpn_resp_time_val,
 507                                                  &qpn, &resp_time_val);
 508
 509                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 510                         "UnSubscribe Request with QPN: 0x%06X\n",
 511                         cl_ntoh32(qpn));
 512         }
 513
 514         /* If record exists with matching InformInfo */
 515         p_infr = osm_infr_get_by_rec(sa->p_subn, sa->p_log, &inform_info_rec);
 516
 517         /* check to see if the request was for subscribe */
 518         if (p_recvd_inform_info->subscribe) {
 519                 /* validate the request for a new or update InformInfo */
 520                 if (validate_infr(sa, &inform_info_rec) != TRUE) {
 521                         cl_plock_release(sa->p_lock);
 522
 523                         OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4305: "
 524                                 "Failed to validate a new inform object\n");
 525
 526                         /* o13-13.1.1: we need to set the subscribe bit to 0 */
 527                         p_recvd_inform_info->subscribe = 0;
 528                         osm_sa_send_error(sa, p_madw,
 529                                           IB_SA_MAD_STATUS_REQ_INVALID);
 530                         goto Exit;
 531                 }
 532
 533                 /* ok - we can try and create a new entry */
 534                 if (p_infr == NULL) {
 535                         /* Create the instance of the osm_infr_t object */
 536                         p_infr = osm_infr_new(&inform_info_rec);
 537                         if (p_infr == NULL) {
 538                                 cl_plock_release(sa->p_lock);
 539
 540                                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4306: "
 541                                         "Failed to create a new inform object\n");
 542
 543                                 /* o13-13.1.1: we need to set the subscribe bit to 0 */
 544                                 p_recvd_inform_info->subscribe = 0;
 545                                 osm_sa_send_error(sa, p_madw,
 546                                                   IB_SA_MAD_STATUS_NO_RESOURCES);
 547                                 goto Exit;
 548                         }
 549
 550                         OSM_LOG(sa->p_log, OSM_LOG_VERBOSE,
 551                                 "Adding event subscription for port 0x%" PRIx64 "\n",
 552                                 cl_ntoh64(inform_info_rec.inform_record.subscriber_gid.unicast.interface_id));
 553
 554                         /* Add this new osm_infr_t object to subnet object */
 555                         osm_infr_insert_to_db(sa->p_subn, sa->p_log, p_infr);
 556                 } else
 557                         /* Update the old instance of the osm_infr_t object */
 558                         p_infr->inform_record = inform_info_rec.inform_record;
 559                 /* We got an UnSubscribe request */
 560         } else if (p_infr == NULL) {
 561                 cl_plock_release(sa->p_lock);
 562
 563                 /* No Such Item - So Error */
 564                 OSM_LOG(sa->p_log, OSM_LOG_ERROR, "ERR 4307: "
 565                         "Failed to UnSubscribe to non existing inform object\n");
 566
 567                 /* o13-13.1.1: we need to set the subscribe bit to 0 */
 568                 p_recvd_inform_info->subscribe = 0;
 569                 osm_sa_send_error(sa, p_madw, IB_SA_MAD_STATUS_REQ_INVALID);
 570                 goto Exit;
 571         } else {
 572                 /* Delete this object from the subnet list of informs */
 573                 OSM_LOG(sa->p_log, OSM_LOG_VERBOSE,
 574                         "Removing event subscription for port 0x%" PRIx64 "\n",
 575                         cl_ntoh64(inform_info_rec.inform_record.subscriber_gid.unicast.interface_id));
 576                 osm_infr_remove_from_db(sa->p_subn, sa->p_log, p_infr);
 577         }
 578
 579         cl_plock_release(sa->p_lock);
 580
 581         /* send the success response */
 582         infr_rcv_respond(sa, p_madw);
 583
 584 Exit:
 585         OSM_LOG_EXIT(sa->p_log);
 586 }
 587
 588 void osm_infr_rcv_process(IN void *context, IN void *data)
 589 {
 590         osm_sa_t *sa = context;
 591         osm_madw_t *p_madw = data;
 592         ib_sa_mad_t *p_sa_mad;
 593
 594         OSM_LOG_ENTER(sa->p_log);
 595
 596         CL_ASSERT(p_madw);
 597
 598         p_sa_mad = osm_madw_get_sa_mad_ptr(p_madw);
 599
 600         CL_ASSERT(p_sa_mad->attr_id == IB_MAD_ATTR_INFORM_INFO);
 601
 602         if (p_sa_mad->method != IB_MAD_METHOD_SET) {
 603                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 604                         "Unsupported Method (%s) for InformInfo\n",
 605                         ib_get_sa_method_str(p_sa_mad->method));
 606                 osm_sa_send_error(sa, p_madw, IB_MAD_STATUS_UNSUP_METHOD_ATTR);
 607                 goto Exit;
 608         }
 609
 610         infr_rcv_process_set_method(sa, p_madw);
 611
 612 Exit:
 613         OSM_LOG_EXIT(sa->p_log);
 614 }
 615
 616 void osm_infir_rcv_process(IN void *context, IN void *data)
 617 {
 618         osm_sa_t *sa = context;
 619         osm_madw_t *p_madw = data;
 620         ib_sa_mad_t *p_sa_mad;
 621
 622         OSM_LOG_ENTER(sa->p_log);
 623
 624         CL_ASSERT(p_madw);
 625
 626         p_sa_mad = osm_madw_get_sa_mad_ptr(p_madw);
 627
 628         CL_ASSERT(p_sa_mad->attr_id == IB_MAD_ATTR_INFORM_INFO_RECORD);
 629
 630         if (p_sa_mad->method != IB_MAD_METHOD_GET &&
 631             p_sa_mad->method != IB_MAD_METHOD_GETTABLE) {
 632                 OSM_LOG(sa->p_log, OSM_LOG_DEBUG,
 633                         "Unsupported Method (%s) for InformInfoRecord\n",
 634                         ib_get_sa_method_str(p_sa_mad->method));
 635                 osm_sa_send_error(sa, p_madw, IB_MAD_STATUS_UNSUP_METHOD_ATTR);
 636                 goto Exit;
 637         }
 638
 639         infr_rcv_process_get_method(sa, p_madw);
 640
 641 Exit:
 642         OSM_LOG_EXIT(sa->p_log);
 643 }