| /****************************************************************************** |
| * |
| * <:copyright-BRCM:2016:DUAL/GPL:standard |
| * |
| * Copyright (c) 2016 Broadcom |
| * All Rights Reserved |
| * |
| * Unless you and Broadcom execute a separate written software license |
| * agreement governing use of this software, this software is licensed |
| * to you under the terms of the GNU General Public License version 2 |
| * (the "GPL"), available at http://www.broadcom.com/licenses/GPLv2.php, |
| * with the following added to such license: |
| * |
| * As a special exception, the copyright holders of this software give |
| * you permission to link this software with independent modules, and |
| * to copy and distribute the resulting executable under terms of your |
| * choice, provided that you also meet, for each linked independent |
| * module, the terms and conditions of the license of that module. |
| * An independent module is a module which is not derived from this |
| * software. The special exception does not apply to any modifications |
| * of the software. |
| * |
| * Not withstanding the above, under no circumstances may you combine |
| * this software in any way with any other Broadcom software provided |
| * under a license other than the GPL, without Broadcom's express prior |
| * written consent. |
| * |
| * :> |
| * |
| *****************************************************************************/ |
| |
| #include <bcm_dev_log.h> |
| #include <bcmcli.h> |
| #include <bal_objs.h> |
| #include <bal_api.h> |
| #include <bcm_topo.h> |
| #include "rsc_mgr.h" |
| #include "rsc_mgr_common.h" |
| #include "rsc_mgr_cli.h" |
| |
| static bcmos_errno rsc_mgr_cli_cmd_init(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| return rsc_mgr_init(); |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_base_alloc_id_set(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmbal_aggregation_port_id min_data_agg_port_id = (bcmbal_aggregation_port_id)bcmcli_find_named_parm(session, "min_data_agg_port_id")->value.unumber; |
| |
| return rsc_mgr_access_int_base_alloc_id_set(access_int_id, min_data_agg_port_id); |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_base_gem_set(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmbal_service_port_id min_data_svc_port_id = (bcmbal_service_port_id)bcmcli_find_named_parm(session, "min_data_svc_port_id")->value.unumber; |
| |
| return rsc_mgr_access_int_base_gem_set(access_int_id, min_data_svc_port_id); |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_alloc_id_alloc(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmcli_cmd_parm *agg_port_id_parm = bcmcli_find_named_parm(session, "agg_port_id"); |
| bcmbal_aggregation_port_id agg_port_id = 0; |
| uint32_t range_size = (uint32_t)bcmcli_find_named_parm(session, "range_size")->value.unumber; |
| uint32_t ref_count; |
| bcmos_errno rc; |
| |
| if (agg_port_id_parm) |
| agg_port_id = (bcmbal_aggregation_port_id)agg_port_id_parm->value.unumber; |
| |
| rc = rsc_mgr_alloc_id_alloc(access_int_id, &agg_port_id, range_size, NULL); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| rc = rsc_mgr_alloc_id_get_ref_count(access_int_id, agg_port_id, &ref_count); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| bcmcli_session_print(session, "Allocated alloc ID=%u (ref_count=%u)\n", agg_port_id, ref_count); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_alloc_id_free(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmbal_aggregation_port_id agg_port_id = (bcmbal_aggregation_port_id)bcmcli_find_named_parm(session, "agg_port_id")->value.unumber; |
| uint32_t ref_count; |
| bcmos_errno rc; |
| |
| rc = rsc_mgr_alloc_id_get_ref_count(access_int_id, agg_port_id, &ref_count); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| rc = rsc_mgr_alloc_id_free(access_int_id, agg_port_id, NULL); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| bcmcli_session_print(session, "Freed alloc ID=%u (ref_count=%u)\n", agg_port_id, ref_count - 1); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_gem_alloc(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmcli_cmd_parm *svc_port_id_parm = bcmcli_find_named_parm(session, "svc_port_id"); |
| bcmbal_service_port_id svc_port_id = 0; |
| uint32_t range_size = (uint32_t)bcmcli_find_named_parm(session, "range_size")->value.unumber; |
| rsc_mgr_obj_type gem_type = (rsc_mgr_obj_type)bcmcli_find_named_parm(session, "gem_type")->value.enum_val; |
| uint32_t ref_count; |
| bcmos_errno rc; |
| |
| if (svc_port_id_parm) |
| svc_port_id = (bcmbal_service_port_id)svc_port_id_parm->value.unumber; |
| |
| if (RSC_MGR_OBJ_TYPE_GEM_PORT_MULTICAST == gem_type) |
| rc = rsc_mgr_gem_alloc_multicast(access_int_id, &svc_port_id, range_size, NULL); |
| else if (RSC_MGR_OBJ_TYPE_GEM_PORT_BROADCAST == gem_type) |
| rc = rsc_mgr_gem_alloc_broadcast(access_int_id, &svc_port_id, range_size, NULL); |
| else |
| rc = rsc_mgr_gem_alloc_unicast(access_int_id, &svc_port_id, range_size, NULL); |
| |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| rc = rsc_mgr_gem_get_ref_count(access_int_id, svc_port_id, &ref_count); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| bcmcli_session_print(session, "Allocated GEM port=%u (ref_count=%u)\n", svc_port_id, ref_count); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_gem_free(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| bcmbal_service_port_id svc_port_id = (bcmbal_service_port_id)bcmcli_find_named_parm(session, "svc_port_id")->value.unumber; |
| uint32_t ref_count; |
| bcmos_errno rc; |
| |
| rc = rsc_mgr_gem_get_ref_count(access_int_id, svc_port_id, &ref_count); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| rc = rsc_mgr_gem_free(access_int_id, svc_port_id, NULL); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| bcmcli_session_print(session, "Freed GEM port=%u (ref_count=%u)\n", svc_port_id, ref_count - 1); |
| |
| return BCM_ERR_OK; |
| } |
| /*allocates a new tm node auto id |
| no inputs parameters are used */ |
| static bcmos_errno rsc_mgr_cli_cmd_tm_sched_auto_alloc(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_tm_sched_id tm_sched_auto_id = 0; |
| bcmos_errno rc; |
| |
| rc = _rsc_mgr_tm_sched_auto_id_alloc(&tm_sched_auto_id); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| |
| bcmcli_session_print(session, "Allocated TM SCHED AUTO ID %u \n", tm_sched_auto_id); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_tm_sched_auto_free(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_tm_sched_id tm_sched_auto_id = (bcmbal_tm_sched_id)bcmcli_find_named_parm(session, "tm_sched_auto_id")->value.unumber; |
| uint32_t ref_count; |
| bcmos_errno rc; |
| |
| rc = _rsc_mgr_tm_sched_auto_id_get_ref_count(tm_sched_auto_id, &ref_count); |
| |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| rc = _rsc_mgr_tm_sched_auto_id_free(tm_sched_auto_id); |
| if (rc != BCM_ERR_OK) |
| return rc; |
| |
| bcmcli_session_print(session, "Freed TM NODE AUTO ID %u (ref_count=%u)\n", tm_sched_auto_id, ref_count - 1); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static void rsc_mgr_show_objs_list(bcmcli_session *session, bcmbal_intf_id access_int_id, rsc_mgr_obj_rsc *obj_rsc, |
| rsc_mgr_obj_list *obj_list) |
| { |
| rsc_mgr_obj *obj_iter; |
| |
| TAILQ_FOREACH(obj_iter, obj_list, list) |
| { |
| if (obj_iter->range_size == 1) |
| { |
| bcmcli_session_print(session, "\t%s=%u (obj_type=%s, ref_count=%u)\n", |
| obj_rsc->obj_name, obj_iter->id, RSC_MGR_OBJ_TYPE_STR(obj_iter->type), obj_iter->ref_count); |
| } |
| else |
| { |
| bcmcli_session_print(session, "\t%s=%u .. %u (obj_type=%s, ref_count=%u)\n", |
| obj_rsc->obj_name, obj_iter->id, obj_iter->id + obj_iter->range_size - 1, RSC_MGR_OBJ_TYPE_STR(obj_iter->type), obj_iter->ref_count); |
| } |
| } |
| } |
| |
| static void rsc_mgr_show_objs(bcmcli_session *session, bcmbal_intf_id access_int_id, rsc_mgr_obj_rsc *obj_rsc) |
| { |
| bcmcli_session_print(session, "Base data %s=%u\n", obj_rsc->obj_name, obj_rsc->min_data_obj_id); |
| bcmcli_session_print(session, "Allocated %ss:\n", obj_rsc->obj_name); |
| rsc_mgr_show_objs_list(session, access_int_id, obj_rsc, &obj_rsc->allocated_objs); |
| bcmcli_session_print(session, "Free %ss:\n", obj_rsc->obj_name); |
| rsc_mgr_show_objs_list(session, access_int_id, obj_rsc, &obj_rsc->free_objs); |
| } |
| |
| static bcmos_errno rsc_mgr_show(bcmcli_session *session, bcmbal_intf_id access_int_id) |
| { |
| bcmos_errno rc; |
| rsc_mgr_topo_pon_context *topo_context; |
| |
| rc = rsc_mgr_init_validate(); |
| if (rc != BCM_ERR_OK) |
| { |
| BCM_LOG(ERROR, rsc_mgr_log_id, "Resource manager is uninitialized\n"); |
| return rc; |
| } |
| |
| if (!bcm_topo_pon_is_valid(access_int_id)) |
| return BCM_ERR_PARM; |
| |
| topo_context = RSC_MGR_PON_TOPO_CONTEXT(access_int_id); |
| rsc_mgr_show_objs(session, access_int_id, &topo_context->alloc_ids); |
| rsc_mgr_show_objs(session, access_int_id, &topo_context->gems); |
| |
| return BCM_ERR_OK; |
| } |
| |
| static bcmos_errno rsc_mgr_cli_cmd_show(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms) |
| { |
| bcmbal_intf_id access_int_id = (bcmbal_intf_id)bcmcli_find_named_parm(session, "key.access_int_id")->value.unumber; |
| |
| return rsc_mgr_show(session, access_int_id); |
| } |
| |
| void rsc_mgr_cli_init(bcmcli_entry *cli_dir) |
| { |
| bcmcli_entry *dbg_dir; |
| |
| static bcmcli_enum_val rsc_mgr_cli_enum_gem_type_table[] = |
| { |
| { .name = "unicast", .val = RSC_MGR_OBJ_TYPE_GEM_PORT_UNICAST }, |
| { .name = "multicast", .val = RSC_MGR_OBJ_TYPE_GEM_PORT_MULTICAST }, |
| { .name = "broadcast", .val = RSC_MGR_OBJ_TYPE_GEM_PORT_BROADCAST }, |
| BCMCLI_ENUM_LAST |
| }; |
| |
| dbg_dir = bcmcli_dir_add(cli_dir, "rsc_mgr", "BAL resource manager API access", BCMCLI_ACCESS_ADMIN, NULL); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "init", "Initialize resource manager for a specific access terminal", rsc_mgr_cli_cmd_init, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "base_alloc_id_set", "Set the base alloc ID for an access interface", rsc_mgr_cli_cmd_base_alloc_id_set, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("min_data_agg_port_id", "minimal data aggregation port ID", BCMCLI_PARM_UNUMBER, 0)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "base_gem_set", "Set the base GEM port for an access interface", rsc_mgr_cli_cmd_base_gem_set, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("min_data_svc_port_id", "minimal data service port ID", BCMCLI_PARM_UNUMBER, 0)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "alloc_id_alloc", "Allocate an alloc ID range or reuse an existing alloc ID range", rsc_mgr_cli_cmd_alloc_id_alloc, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("agg_port_id", "aggregation port ID (if omitted a new alloc ID is allocated, otherwise we reuse an existing alloc ID)", |
| BCMCLI_PARM_UNUMBER, BCMCLI_PARM_FLAG_OPTIONAL), |
| BCMCLI_MAKE_PARM_RANGE("range_size", "range size", BCMCLI_PARM_UNUMBER, 0, RSC_MGR_MIN_RANGE_SIZE, RSC_MGR_MAX_RANGE_SIZE)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "alloc_id_free", "Free an alloc ID range", rsc_mgr_cli_cmd_alloc_id_free, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("agg_port_id", "base of alloc ID range", BCMCLI_PARM_UNUMBER, 0)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "gem_alloc", "Allocate a GEM port range or reuse an existing GEM port range", rsc_mgr_cli_cmd_gem_alloc, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("svc_port_id", "service port ID (if omitted a new GEM port is allocated, otherwise we reuse an existing GEM port)", |
| BCMCLI_PARM_UNUMBER, BCMCLI_PARM_FLAG_OPTIONAL), |
| BCMCLI_MAKE_PARM_RANGE("range_size", "range size", BCMCLI_PARM_UNUMBER, 0, RSC_MGR_MIN_RANGE_SIZE, RSC_MGR_MAX_RANGE_SIZE), |
| BCMCLI_MAKE_PARM_ENUM("gem_type", "GEM type", rsc_mgr_cli_enum_gem_type_table, 0)); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "gem_free", "Free a GEM port range", rsc_mgr_cli_cmd_gem_free, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0), |
| BCMCLI_MAKE_PARM("svc_port_id", "base of GEM port range", BCMCLI_PARM_UNUMBER, 0)); |
| |
| BCMCLI_MAKE_CMD_NOPARM(dbg_dir, "tm_sched_auto_id_alloc", "Allocate a tm node auto id or reuse an existing id", rsc_mgr_cli_cmd_tm_sched_auto_alloc); |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "tm_sched_auto_id_free", "Free a tm node auto id", rsc_mgr_cli_cmd_tm_sched_auto_free, |
| BCMCLI_MAKE_PARM("tm_sched_auto_id", "tm node auto id to be free", BCMCLI_PARM_UNUMBER, 0)); |
| |
| |
| BCMCLI_MAKE_CMD(dbg_dir, "show", "Show the database of the resource manager", rsc_mgr_cli_cmd_show, |
| BCMCLI_MAKE_PARM_RANGE("key.access_term_id", "access terminal identifier", BCMCLI_PARM_UNUMBER, 0, 0, MAX_SUPPORTED_OLTS), |
| BCMCLI_MAKE_PARM("key.access_int_id", "access interface identifier", BCMCLI_PARM_UNUMBER, 0)); |
| } |
| |