src/bal_group_hdlr.c

/*
** Copyright 2017-present Open Networking Foundation
**
** Licensed under the Apache License, Version 2.0 (the "License");
** you may not use this file except in compliance with the License.
** You may obtain a copy of the License at
**
** http://www.apache.org/licenses/LICENSE-2.0
**
** Unless required by applicable law or agreed to in writing, software
** distributed under the License is distributed on an "AS IS" BASIS,
** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
** See the License for the specific language governing permissions and
** limitations under the License.
*/

#include <stdio.h>
#include <bal_api.h>

#undef _SYS_QUEUE_H_

/* Includes related to proto buf */
#include "asfvolt16_driver.h"
#include "bal_group_hdlr.h"


/********************************************************************\
 * Function    : bal_group_cfg_req                                  *
 * Description : Configures the OLT device                          *
 ********************************************************************/

uint32_t bal_group_cfg_set(BalGroupCfg *tm_group_cfg)
{
    bcmos_errno err = BCM_ERR_OK;
    bcmbal_group_cfg grp_cfg_obj;   /**< declare main API struct */
    bcmbal_group_key key = { };      /**< declare key */
    int grp_mem_idx;

    if(tm_group_cfg->key->has_group_id)
    {
       key.group_id = tm_group_cfg->key->group_id;
    }
    else
    {
       ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to configure the group cfg(OLT): Group Id was not present");
       return BAL_ERRNO__BAL_ERR_NOENT;
    }

    ASFVOLT_LOG(ASFVOLT_DEBUG, "Configuration of OLT(group cfg) starts");

    /* init the API struct */
    BCMBAL_CFG_INIT(&grp_cfg_obj, group, key);

    /* decode API parameters from GRPC */
    if(tm_group_cfg->data->has_members_cmd)
    {
        ASFVOLT_CFG_PROP_SET(grp_cfg_obj, group, members_cmd,
                             tm_group_cfg->data->has_members_cmd,
                             tm_group_cfg->data->members_cmd);
    }

    if(tm_group_cfg->data->has_cookie)
    {
        ASFVOLT_CFG_PROP_SET(grp_cfg_obj, group, cookie,
                             tm_group_cfg->data->has_cookie,
                             tm_group_cfg->data->cookie);
    }

    BalIdList *balFlows = (BalIdList *)tm_group_cfg->data->flows;
    bcmbal_flow_id_list_u32 valFlows = {};

    valFlows.len = balFlows->n_val;
    valFlows.val = (bcmbal_flow_id *)malloc((valFlows.len)*sizeof(bcmbal_flow_id));
    if(!valFlows.val)
    {
       ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to configure the group cfg(OLT): Memory Exhausted");
       return BAL_ERRNO__BAL_ERR_NOMEM;
    }
    memcpy((void *)valFlows.val, (const void *)balFlows->val,
           (balFlows->n_val)*sizeof(bcmbal_flow_id));
    ASFVOLT_CFG_PROP_SET(grp_cfg_obj, group, flows, BCMOS_TRUE, valFlows);

    if(tm_group_cfg->data->has_type)
    {
        ASFVOLT_CFG_PROP_SET(grp_cfg_obj, group, type,
                             tm_group_cfg->data->has_type,
                             tm_group_cfg->data->type);
    }

    BalGroupMemberInfoList *balMembers =
              (BalGroupMemberInfoList *)tm_group_cfg->data->members;
    bcmbal_group_member_info_list_u16 valMembers = {};
    /*if(balMembers->has_len)*/
    {
       valMembers.len = balMembers->n_val;
       valMembers.val =
        (bcmbal_group_member_info *)malloc((valMembers.len)*sizeof(bcmbal_group_member_info));
       if(!valMembers.val)
       {
          ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to configure the group cfg(OLT): Memory Exhausted");
          return BAL_ERRNO__BAL_ERR_NOMEM;
       }
       //check
       //valMembers.val = &balMembers->val;
       for(grp_mem_idx = 0; grp_mem_idx < valMembers.len; grp_mem_idx++)
       {
          if(balMembers->val[grp_mem_idx]->has_intf_id)
          {
             valMembers.val[grp_mem_idx].intf_id
                                  = balMembers->val[grp_mem_idx]->intf_id;
          }
          if(balMembers->val[grp_mem_idx]->has_svc_port_id)
          {
             valMembers.val[grp_mem_idx].svc_port_id
                               = balMembers->val[grp_mem_idx]->svc_port_id;
          }
          if(balMembers->val[grp_mem_idx]->has_intf_type)
          {
             valMembers.val[grp_mem_idx].intf_type
                     = balMembers->val[grp_mem_idx]->intf_type;
          }
          if(balMembers->val[grp_mem_idx]->queue->has_sched_id)
          {
             valMembers.val[grp_mem_idx].queue.sched_id
                     = balMembers->val[grp_mem_idx]->queue->sched_id;
          }
          if(balMembers->val[grp_mem_idx]->queue->has_queue_id)
          {
             valMembers.val[grp_mem_idx].queue.queue_id
                     = balMembers->val[grp_mem_idx]->queue->queue_id;
          }
       }
       ASFVOLT_CFG_PROP_SET(grp_cfg_obj, group, members, BCMOS_TRUE, valMembers);
    }

    err = bcmbal_cfg_set(DEFAULT_ATERM_ID, &(grp_cfg_obj.hdr));

    if(BCM_ERR_OK != err)
    {
        ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to configure the group cfg(OLT)");
        return err;
    }

    ASFVOLT_LOG(ASFVOLT_INFO, "Set Group configuration sent to OLT for Group Id(%d)",
                               key.group_id);
    return err;
}


/********************************************************************\
 * Function    : bal_group_cfg_get                                  *
 * Description : get the OLT device group cfg                       *
 ********************************************************************/

uint32_t bal_group_cfg_get(BalGroupCfg *group_cfg)
{
    bcmos_errno err = BCM_ERR_OK;
    bcmbal_group_cfg grp_cfg_obj;   /**< declare main API struct */
    bcmbal_group_key key = { };      /**< declare key */

    if(group_cfg->key->has_group_id)
    {
       key.group_id = group_cfg->key->group_id;
    }
    else
    {
       ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to get the group cfg(OLT): Group Id was not present");
       return BAL_ERRNO__BAL_ERR_NOENT;
    }

    ASFVOLT_LOG(ASFVOLT_DEBUG, "Get group cfg(for OLT) starts");

    /* init the API struct */
    BCMBAL_CFG_INIT(&grp_cfg_obj, group, key);

    /* request all properties, include everything */
    BCMBAL_CFG_PROP_GET(&grp_cfg_obj, group, all_properties);

    err = bcmbal_cfg_get(DEFAULT_ATERM_ID, &grp_cfg_obj.hdr);

    if(BCM_ERR_OK != err)
    {
        ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to get the group Cfg(OLT)");
        return err;
    }

    ASFVOLT_LOG(ASFVOLT_INFO, "Get Group cfg sent to OLT for Group Id(%d)",
                               key.group_id);
   
    memcpy(group_cfg->key, &key, sizeof(BalFlowKey));
    memcpy(group_cfg->data, &grp_cfg_obj, sizeof(BalFlowCfgData));

    return err;
}

/********************************************************************\
 * Function    : bal_group_clear_req                            *
 * Description : clears the OLT device group cfg                    *
 ********************************************************************/

uint32_t bal_group_cfg_clear(BalGroupKey *tm_group_cfg_key)
{
    bcmos_errno err = BCM_ERR_OK;
    bcmbal_group_cfg grp_cfg_obj;   /**< declare main API struct */
    bcmbal_group_key key = { };      /**< declare key */

    if(tm_group_cfg_key->has_group_id)
    {
       key.group_id = tm_group_cfg_key->group_id;
    }
    else
    {
       ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to clear the group cfg(OLT): Group Id was not present");
       return BAL_ERRNO__BAL_ERR_NOENT;
    }

    ASFVOLT_LOG(ASFVOLT_DEBUG, "Clearing of OLT(group cfg) starts");

    /* init the API struct */
    BCMBAL_CFG_INIT(&grp_cfg_obj, group, key);

    err = bcmbal_cfg_clear(DEFAULT_ATERM_ID, &grp_cfg_obj.hdr);

    if(BCM_ERR_OK != err)
    {
        ASFVOLT_LOG(ASFVOLT_ERROR, "Failed to clear the group Cfg(OLT)");
        return err;
    }

    ASFVOLT_LOG(ASFVOLT_INFO, "Clear Group cfg clear sent to OLT for Group Id(%d)",
                               key.group_id);
    return err;
}

/********************************************************************\
 * Function    : bal_group_cfg_indication_cb                        *
 * Description : Call back function registered with BAL to handle   *
 *               event related to access terminal                   *
 ********************************************************************/
bcmos_errno bal_group_cfg_indication_cb(bcmbal_obj *obj)
{
    bcmos_errno result = BCM_ERR_OK;
    ASFVOLT_LOG(ASFVOLT_INFO, "Processing API ('%s)' IND callback status is (%s)",
		    bcmbal_objtype_str(obj->obj_type),
		    bcmos_strerror(obj->status));

    return result;
}