@@ -472,22 +472,21 @@ int osm_sa_db_file_load(struct osm_opensm *p_osm);
* SYNOPSIS
*/
-ib_api_status_t
-osm_mcmr_rcv_find_or_create_new_mgrp(IN osm_sa_t * sa, IN ib_net64_t comp_mask,
- IN ib_member_rec_t * p_recvd_mcmember_rec,
- OUT osm_mgrp_t ** pp_mgrp);
+osm_mgrp_t *osm_mcmr_rcv_find_or_create_new_mgrp(IN osm_sa_t * sa,
+ IN ib_net64_t comp_mask,
+ IN ib_member_rec_t *
+ p_recvd_mcmember_rec);
/*
* PARAMETERS
* p_sa
* [in] Pointer to an osm_sa_t object.
+* comp_mask
+* [in] SA query component mask
* p_recvd_mcmember_rec
* [in] Received Multicast member record
*
-* pp_mgrp
-* [out] pointer the osm_mgrp_t object
-*
* RETURN VALUES
-* IB_SUCCESS, IB_ERROR
+* The pointer to MC group object found or created, NULL in case of errors
*
*********/
@@ -174,9 +174,8 @@ ib_api_status_t osm_prtn_add_mcgroup(osm_log_t * p_log, osm_subn_t * p_subn,
ib_member_rec_t mc_rec;
ib_net64_t comp_mask;
ib_net16_t pkey;
- osm_mgrp_t *p_mgrp = NULL;
+ osm_mgrp_t *mgrp;
osm_sa_t *p_sa = &p_subn->p_osm->sa;
- ib_api_status_t status = IB_SUCCESS;
uint8_t hop_limit;
pkey = p->pkey | cl_hton16(0x8000);
@@ -197,24 +196,25 @@ ib_api_status_t osm_prtn_add_mcgroup(osm_log_t * p_log, osm_subn_t * p_subn,
mc_rec.pkt_life = p_subn->opt.subnet_timeout;
mc_rec.sl_flow_hop = ib_member_set_sl_flow_hop(p->sl, 0, hop_limit);
/* Scope in MCMemberRecord (if present) needs to be consistent with MGID */
- mc_rec.scope_state = ib_member_set_scope_state(scope, IB_MC_REC_STATE_FULL_MEMBER);
+ mc_rec.scope_state =
+ ib_member_set_scope_state(scope, IB_MC_REC_STATE_FULL_MEMBER);
ib_mgid_set_scope(&mc_rec.mgid, scope);
/* don't update rate, mtu */
comp_mask = IB_MCR_COMPMASK_MTU | IB_MCR_COMPMASK_MTU_SEL |
IB_MCR_COMPMASK_RATE | IB_MCR_COMPMASK_RATE_SEL;
- status = osm_mcmr_rcv_find_or_create_new_mgrp(p_sa, comp_mask, &mc_rec,
- &p_mgrp);
- if (!p_mgrp || status != IB_SUCCESS)
+ mgrp = osm_mcmr_rcv_find_or_create_new_mgrp(p_sa, comp_mask, &mc_rec);
+ if (!mgrp) {
OSM_LOG(p_log, OSM_LOG_ERROR,
"Failed to create MC group with pkey 0x%04x\n",
cl_ntoh16(pkey));
- if (p_mgrp) {
- p_mgrp->well_known = TRUE;
- p->mgrp = p_mgrp;
+ return IB_ERROR;
}
- return status;
+ mgrp->well_known = TRUE;
+ p->mgrp = mgrp;
+
+ return IB_SUCCESS;
}
static uint16_t generate_pkey(osm_subn_t * p_subn)
@@ -741,10 +741,10 @@ static osm_mgrp_t *load_mcgroup(osm_opensm_t * p_osm, ib_net16_t mlid,
comp_mask = IB_MCR_COMPMASK_MTU | IB_MCR_COMPMASK_MTU_SEL
| IB_MCR_COMPMASK_RATE | IB_MCR_COMPMASK_RATE_SEL;
- if (osm_mcmr_rcv_find_or_create_new_mgrp(&p_osm->sa,
- comp_mask, p_mcm_rec,
- &p_mgrp) != IB_SUCCESS ||
- !p_mgrp || p_mgrp->mlid != mlid) {
+ if (!(p_mgrp = osm_mcmr_rcv_find_or_create_new_mgrp(&p_osm->sa,
+ comp_mask,
+ p_mcm_rec)) ||
+ p_mgrp->mlid != mlid) {
OSM_LOG(&p_osm->log, OSM_LOG_ERROR,
"cannot create MC group with mlid 0x%04x and mgid "
"0x%016" PRIx64 ":0x%016" PRIx64 "\n", cl_ntoh16(mlid),
@@ -868,21 +868,20 @@ Exit:
/**********************************************************************
Call this function to find or create a new mgrp.
**********************************************************************/
-ib_api_status_t osm_mcmr_rcv_find_or_create_new_mgrp(IN osm_sa_t * sa,
- IN ib_net64_t comp_mask,
- IN ib_member_rec_t *
- p_recvd_mcmember_rec,
- OUT osm_mgrp_t ** pp_mgrp)
+osm_mgrp_t *osm_mcmr_rcv_find_or_create_new_mgrp(IN osm_sa_t * sa,
+ IN ib_net64_t comp_mask,
+ IN ib_member_rec_t *
+ p_recvd_mcmember_rec)
{
osm_mgrp_t *mgrp;
if ((mgrp = osm_get_mgrp_by_mgid(sa->p_subn,
- &p_recvd_mcmember_rec->mgid))) {
- *pp_mgrp = mgrp;
- return IB_SUCCESS;
- }
- return mcmr_rcv_create_new_mgrp(sa, comp_mask, p_recvd_mcmember_rec,
- NULL, pp_mgrp);
+ &p_recvd_mcmember_rec->mgid)))
+ return mgrp;
+ if (mcmr_rcv_create_new_mgrp(sa, comp_mask, p_recvd_mcmember_rec, NULL,
+ &mgrp) == IB_SUCCESS)
+ return mgrp;
+ return NULL;
}
/*********************************************************************