Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1 | /* |
| 2 | ** Copyright 2017-present Open Networking Foundation |
| 3 | ** |
| 4 | ** Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | ** you may not use this file except in compliance with the License. |
| 6 | ** You may obtain a copy of the License at |
| 7 | ** |
| 8 | ** http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | ** |
| 10 | ** Unless required by applicable law or agreed to in writing, software |
| 11 | ** distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | ** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | ** See the License for the specific language governing permissions and |
| 14 | ** limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | #include "bal_indications_hdlr.h" |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 18 | #include "bal_indications_queue.h" |
| 19 | |
| 20 | /*global variables*/ |
| 21 | |
| 22 | /*extern variables*/ |
| 23 | |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 24 | |
| 25 | /*static bcmos_mutex bal_ind_lock; - Need to define bcm independent mutex*/ |
| 26 | /********************************************************************\ |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 27 | * Function : bal_acc_term_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 28 | * Description : This function will handle the indications for * |
| 29 | * Access Terminal Indication * |
| 30 | * * |
| 31 | ********************************************************************/ |
| 32 | bcmos_errno bal_acc_term_indication_cb(bcmbal_obj *obj) |
| 33 | { |
| 34 | bcmos_errno result = BCM_ERR_OK; |
| 35 | |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 36 | if(BCMBAL_OBJ_ID_ACCESS_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 37 | bcmbal_access_terminal_auto_id_ind != obj->subgroup) |
| 38 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 39 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 40 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 41 | result = BCM_ERR_INTERNAL; |
| 42 | } |
| 43 | else |
| 44 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 45 | ASFVOLT_LOG(ASFVOLT_DEBUG, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 46 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 47 | BalIndications *balIndCfg; |
| 48 | balIndCfg = malloc(sizeof(BalIndications)); |
| 49 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 50 | bal_indications__init(balIndCfg); |
| 51 | balIndCfg->u_case = BAL_INDICATIONS__U_ACCESS_TERM_IND; |
| 52 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 53 | balIndCfg->objtype = obj->obj_type; |
| 54 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 55 | balIndCfg->sub_group = obj->subgroup; |
| 56 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 57 | |
| 58 | bcmbal_access_terminal_ind *acc_term_ind = (bcmbal_access_terminal_ind *)obj; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 59 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 60 | balIndCfg->access_term_ind = malloc(sizeof(BalAccessTerminalInd)); |
| 61 | memset(balIndCfg->access_term_ind, 0, sizeof(BalAccessTerminalInd)); |
| 62 | bal_access_terminal_ind__init(balIndCfg->access_term_ind); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 63 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 64 | BalObj *hdr; |
| 65 | hdr = malloc(sizeof(BalObj)); |
| 66 | memset(hdr, 0, sizeof(BalObj)); |
| 67 | bal_obj__init(hdr); |
| 68 | balIndCfg->access_term_ind->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 69 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 70 | BalAccessTerminalKey *accessTermkey; |
| 71 | accessTermkey = malloc(sizeof(BalAccessTerminalKey)); |
| 72 | memset(accessTermkey, 0, sizeof(BalAccessTerminalKey)); |
| 73 | bal_access_terminal_key__init(accessTermkey); |
| 74 | balIndCfg->access_term_ind->key = accessTermkey; |
| 75 | balIndCfg->access_term_ind->key->has_access_term_id = BAL_GRPC_PRES; |
| 76 | balIndCfg->access_term_ind->key->access_term_id = acc_term_ind->key.access_term_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 77 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 78 | BalAccessTerminalIndData *accessTermIndData; |
| 79 | accessTermIndData = malloc(sizeof(BalAccessTerminalIndData)); |
| 80 | memset(accessTermIndData, 0, sizeof(BalAccessTerminalIndData)); |
| 81 | bal_access_terminal_ind_data__init(accessTermIndData); |
| 82 | balIndCfg->access_term_ind->data = accessTermIndData; |
| 83 | balIndCfg->access_term_ind->data->has_admin_state = BAL_GRPC_PRES; |
| 84 | balIndCfg->access_term_ind->data->admin_state = acc_term_ind->data.admin_state; |
| 85 | balIndCfg->access_term_ind->data->has_oper_status = BAL_GRPC_PRES; |
| 86 | balIndCfg->access_term_ind->data->oper_status = acc_term_ind->data.oper_status; |
| 87 | balIndCfg->access_term_ind->data->has_iwf_mode = BAL_GRPC_PRES; |
| 88 | balIndCfg->access_term_ind->data->iwf_mode = acc_term_ind->data.iwf_mode; |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 89 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 90 | BalTopology *balTop; |
| 91 | balTop = malloc(sizeof(BalTopology)); |
| 92 | memset(balTop, 0, sizeof(BalTopology)); |
| 93 | bal_topology__init(balTop); |
| 94 | balIndCfg->access_term_ind->data->topology = balTop; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 95 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 96 | balIndCfg->access_term_ind->data->topology->has_num_of_nni_ports = BAL_GRPC_PRES; |
| 97 | balIndCfg->access_term_ind->data->topology->num_of_nni_ports = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 98 | acc_term_ind->data.topology.num_of_nni_ports; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 99 | balIndCfg->access_term_ind->data->topology->has_num_of_pon_ports = BAL_GRPC_PRES; |
| 100 | balIndCfg->access_term_ind->data->topology->num_of_pon_ports = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 101 | acc_term_ind->data.topology.num_of_pon_ports; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 102 | balIndCfg->access_term_ind->data->topology->has_num_of_mac_devs = BAL_GRPC_PRES; |
| 103 | balIndCfg->access_term_ind->data->topology->num_of_mac_devs = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 104 | acc_term_ind->data.topology.num_of_mac_devs; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 105 | balIndCfg->access_term_ind->data->topology->has_num_of_pons_per_mac_dev = BAL_GRPC_PRES; |
| 106 | balIndCfg->access_term_ind->data->topology->num_of_pons_per_mac_dev = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 107 | acc_term_ind->data.topology.num_of_pons_per_mac_dev; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 108 | balIndCfg->access_term_ind->data->topology->has_pon_family = BAL_GRPC_PRES; |
| 109 | balIndCfg->access_term_ind->data->topology->pon_family = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 110 | acc_term_ind->data.topology.pon_family; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 111 | balIndCfg->access_term_ind->data->topology->has_pon_sub_family = BAL_GRPC_PRES; |
| 112 | balIndCfg->access_term_ind->data->topology->pon_sub_family = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 113 | acc_term_ind->data.topology.pon_sub_family; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 114 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 115 | BalSwVersion *balsv; |
| 116 | balsv = malloc(sizeof(BalSwVersion)); |
| 117 | memset(balsv, 0, sizeof(BalSwVersion)); |
| 118 | bal_sw_version__init(balsv); |
| 119 | balIndCfg->access_term_ind->data->sw_version = balsv; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 120 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 121 | balIndCfg->access_term_ind->data->sw_version->has_version_type = BAL_GRPC_PRES; |
| 122 | balIndCfg->access_term_ind->data->sw_version->version_type = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 123 | acc_term_ind->data.sw_version.version_type; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 124 | balIndCfg->access_term_ind->data->sw_version->has_major_rev = BAL_GRPC_PRES; |
| 125 | balIndCfg->access_term_ind->data->sw_version->major_rev = |
Rajeswara Rao | a3efbca | 2017-09-08 18:01:16 +0530 | [diff] [blame] | 126 | acc_term_ind->data.sw_version.major_rev; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 127 | balIndCfg->access_term_ind->data->sw_version->has_minor_rev = BAL_GRPC_PRES; |
| 128 | balIndCfg->access_term_ind->data->sw_version->minor_rev = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 129 | acc_term_ind->data.sw_version.minor_rev; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 130 | balIndCfg->access_term_ind->data->sw_version->has_patch_rev = BAL_GRPC_PRES; |
| 131 | balIndCfg->access_term_ind->data->sw_version->patch_rev = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 132 | acc_term_ind->data.sw_version.patch_rev; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 133 | balIndCfg->access_term_ind->data->sw_version->has_om_version = BAL_GRPC_PRES; |
| 134 | balIndCfg->access_term_ind->data->sw_version->om_version = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 135 | acc_term_ind->data.sw_version.om_version; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 136 | balIndCfg->access_term_ind->data->sw_version->has_dev_point = BAL_GRPC_PRES; |
| 137 | balIndCfg->access_term_ind->data->sw_version->dev_point = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 138 | acc_term_ind->data.sw_version.dev_point; |
| 139 | |
| 140 | bal_register_indication_cbs(); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 141 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 142 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 143 | bal_indication_node->bal_indication = balIndCfg; |
root | 2ca2cc0 | 2017-11-03 19:51:57 +0530 | [diff] [blame] | 144 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 145 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 146 | add_bal_indication_node(bal_indication_node); |
| 147 | pthread_mutex_unlock(&bal_ind_queue_lock); |
| 148 | |
Rajeswara Rao | 9f1cea1 | 2017-10-10 18:25:29 +0530 | [diff] [blame] | 149 | is_reboot = BAL_REBOOT_STATUS__BAL_OLT_UP_AFTER_ACTIVATION; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 150 | } |
| 151 | |
| 152 | return result; |
| 153 | } |
| 154 | |
| 155 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 156 | * Function : bal_acc_term_osc_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 157 | * Description : This function will handle the indications for * |
| 158 | * Access Terminal Operational State Change * |
| 159 | * * |
| 160 | ********************************************************************/ |
| 161 | bcmos_errno bal_acc_term_osc_indication_cb(bcmbal_obj *obj) |
| 162 | { |
| 163 | bcmos_errno result = BCM_ERR_OK; |
| 164 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 165 | if(BCMBAL_OBJ_ID_ACCESS_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 166 | bcmbal_access_terminal_auto_id_oper_status_change != obj->subgroup) |
| 167 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 168 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 169 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 170 | result = BCM_ERR_INTERNAL; |
| 171 | } |
| 172 | else |
| 173 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 174 | BalIndications *balIndCfg; |
| 175 | balIndCfg = malloc(sizeof(BalIndications)); |
| 176 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 177 | bal_indications__init(balIndCfg); |
| 178 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 179 | balIndCfg->objtype = obj->obj_type; |
| 180 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 181 | balIndCfg->sub_group = obj->subgroup; |
| 182 | balIndCfg->u_case = BAL_INDICATIONS__U_ACCESS_TERM_IND_OP_STATE; |
| 183 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 184 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 185 | bcmbal_access_terminal_oper_status_change *acc_term_osc = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 186 | (bcmbal_access_terminal_oper_status_change *)obj; |
| 187 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 188 | BalAccessTerminalOperStatusChange *acessTermOSC; |
| 189 | acessTermOSC = malloc(sizeof(BalAccessTerminalOperStatusChange)); |
| 190 | memset(acessTermOSC, 0, sizeof(BalAccessTerminalOperStatusChange)); |
| 191 | bal_access_terminal_oper_status_change__init(acessTermOSC); |
| 192 | balIndCfg->access_term_ind_op_state = acessTermOSC; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 193 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 194 | BalObj *hdr; |
| 195 | hdr = malloc(sizeof(BalObj)); |
| 196 | memset(hdr, 0, sizeof(BalObj)); |
| 197 | bal_obj__init(hdr); |
| 198 | balIndCfg->access_term_ind_op_state->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 199 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 200 | BalAccessTerminalKey *accessTermkey; |
| 201 | accessTermkey = malloc(sizeof(BalAccessTerminalKey)); |
| 202 | memset(accessTermkey, 0, sizeof(BalAccessTerminalKey)); |
| 203 | bal_access_terminal_key__init(accessTermkey); |
| 204 | balIndCfg->access_term_ind_op_state->key = accessTermkey; |
| 205 | balIndCfg->access_term_ind_op_state->key->has_access_term_id = BAL_GRPC_PRES; |
| 206 | balIndCfg->access_term_ind_op_state->key->access_term_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 207 | acc_term_osc->key.access_term_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 208 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 209 | BalAccessTerminalOperStatusChangeData *accessTermOscData; |
| 210 | accessTermOscData = malloc(sizeof(BalAccessTerminalOperStatusChangeData)); |
| 211 | memset(accessTermOscData, 0, sizeof(BalAccessTerminalOperStatusChangeData)); |
| 212 | bal_access_terminal_oper_status_change_data__init(accessTermOscData); |
| 213 | balIndCfg->access_term_ind_op_state->data = accessTermOscData; |
| 214 | balIndCfg->access_term_ind_op_state->data->has_new_oper_status = BAL_GRPC_PRES; |
| 215 | balIndCfg->access_term_ind_op_state->data->new_oper_status = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 216 | acc_term_osc->data.new_oper_status; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 217 | balIndCfg->access_term_ind_op_state->data->has_old_oper_status = BAL_GRPC_PRES; |
| 218 | balIndCfg->access_term_ind_op_state->data->old_oper_status = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 219 | acc_term_osc->data.old_oper_status; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 220 | balIndCfg->access_term_ind_op_state->data->has_admin_state = BAL_GRPC_PRES; |
| 221 | balIndCfg->access_term_ind_op_state->data->admin_state = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 222 | acc_term_osc->data.admin_state; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 223 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 224 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 225 | bal_indication_node->bal_indication = balIndCfg; |
| 226 | |
| 227 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 228 | add_bal_indication_node(bal_indication_node); |
| 229 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 230 | } |
| 231 | |
| 232 | return result; |
| 233 | } |
| 234 | |
| 235 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 236 | * Function : bal_flow_osc_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 237 | * Description : This function will handle the indications for * |
| 238 | * Flow Operational State Change * |
| 239 | * * |
| 240 | ********************************************************************/ |
| 241 | bcmos_errno bal_flow_osc_indication_cb(bcmbal_obj *obj) |
| 242 | { |
| 243 | bcmos_errno result = BCM_ERR_OK; |
| 244 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 245 | if(BCMBAL_OBJ_ID_FLOW != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 246 | bcmbal_flow_auto_id_oper_status_change != obj->subgroup) |
| 247 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 248 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 249 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 250 | result = BCM_ERR_INTERNAL; |
| 251 | } |
| 252 | else |
| 253 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 254 | BalIndications *balIndCfg; |
| 255 | balIndCfg = malloc(sizeof(BalIndications)); |
| 256 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 257 | bal_indications__init(balIndCfg); |
| 258 | balIndCfg->u_case = BAL_INDICATIONS__U_FLOW_OP_STATE; |
| 259 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 260 | balIndCfg->objtype = obj->obj_type; |
| 261 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 262 | balIndCfg->sub_group = obj->subgroup; |
| 263 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 264 | |
| 265 | bcmbal_flow_oper_status_change *flow_osc = (bcmbal_flow_oper_status_change *)obj; |
| 266 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 267 | BalFlowOperStatusChange *flowOscInd; |
| 268 | flowOscInd = malloc(sizeof(BalFlowOperStatusChange)); |
| 269 | memset(flowOscInd, 0, sizeof(BalFlowOperStatusChange)); |
| 270 | bal_flow_oper_status_change__init(flowOscInd); |
| 271 | balIndCfg->flow_op_state = flowOscInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 272 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 273 | BalObj *hdr; |
| 274 | hdr = malloc(sizeof(BalObj)); |
| 275 | memset(hdr, 0, sizeof(BalObj)); |
| 276 | bal_obj__init(hdr); |
| 277 | balIndCfg->flow_op_state->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 278 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 279 | BalFlowKey *flowkey; |
| 280 | flowkey = malloc(sizeof(BalFlowKey)); |
| 281 | memset(flowkey, 0, sizeof(BalFlowKey)); |
| 282 | bal_flow_key__init(flowkey); |
| 283 | balIndCfg->flow_op_state->key = flowkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 284 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 285 | balIndCfg->flow_op_state->key->has_flow_id = BAL_GRPC_PRES; |
| 286 | balIndCfg->flow_op_state->key->flow_id = flow_osc->key.flow_id; |
| 287 | balIndCfg->flow_op_state->key->has_flow_type = BAL_GRPC_PRES; |
| 288 | balIndCfg->flow_op_state->key->flow_type = flow_osc->key.flow_type; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 289 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 290 | BalFlowOperStatusChangeData *flowOscIndData; |
| 291 | flowOscIndData = malloc(sizeof(BalFlowOperStatusChangeData)); |
| 292 | memset(flowOscIndData, 0, sizeof(BalFlowOperStatusChangeData)); |
| 293 | bal_flow_oper_status_change_data__init(flowOscIndData); |
| 294 | balIndCfg->flow_op_state->data = flowOscIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 295 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 296 | balIndCfg->flow_op_state->data->has_new_oper_status = BAL_GRPC_PRES; |
| 297 | balIndCfg->flow_op_state->data->new_oper_status = flow_osc->data.new_oper_status; |
| 298 | balIndCfg->flow_op_state->data->has_old_oper_status = BAL_GRPC_PRES; |
| 299 | balIndCfg->flow_op_state->data->old_oper_status = flow_osc->data.old_oper_status; |
| 300 | balIndCfg->flow_op_state->data->has_admin_state = BAL_GRPC_PRES; |
| 301 | balIndCfg->flow_op_state->data->admin_state = flow_osc->data.admin_state; |
| 302 | balIndCfg->flow_op_state->data->has_svc_port_id = BAL_GRPC_PRES; |
| 303 | balIndCfg->flow_op_state->data->svc_port_id = flow_osc->data.svc_port_id; |
| 304 | balIndCfg->flow_op_state->data->has_dba_tm_sched_id = BAL_GRPC_PRES; |
| 305 | balIndCfg->flow_op_state->data->dba_tm_sched_id = flow_osc->data.dba_tm_sched_id; |
| 306 | balIndCfg->flow_op_state->data->has_cookie = BAL_GRPC_PRES; |
| 307 | balIndCfg->flow_op_state->data->cookie = flow_osc->data.cookie; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 308 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 309 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 310 | bal_indication_node->bal_indication = balIndCfg; |
| 311 | |
| 312 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 313 | add_bal_indication_node(bal_indication_node); |
| 314 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 315 | } |
| 316 | |
| 317 | return result; |
| 318 | } |
| 319 | |
| 320 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 321 | * Function : bal_flow_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 322 | * Description : This function will handle the indications for * |
| 323 | * Flow Indication * |
| 324 | * * |
| 325 | ********************************************************************/ |
| 326 | bcmos_errno bal_flow_indication_cb(bcmbal_obj *obj) |
| 327 | { |
| 328 | bcmos_errno result = BCM_ERR_OK; |
| 329 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 330 | if(BCMBAL_OBJ_ID_FLOW != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 331 | bcmbal_flow_auto_id_ind != obj->subgroup) |
| 332 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 333 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 334 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 335 | result = BCM_ERR_INTERNAL; |
| 336 | } |
| 337 | else |
| 338 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 339 | BalIndications *balIndCfg; |
| 340 | balIndCfg = malloc(sizeof(BalIndications)); |
| 341 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 342 | bal_indications__init(balIndCfg); |
| 343 | balIndCfg->u_case = BAL_INDICATIONS__U_FLOW_IND; |
| 344 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 345 | balIndCfg->objtype = obj->obj_type; |
| 346 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 347 | balIndCfg->sub_group = obj->subgroup; |
| 348 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 349 | |
| 350 | bcmbal_flow_ind *flow_ind = (bcmbal_flow_ind *)obj; |
| 351 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 352 | BalFlowInd *flowInd; |
| 353 | flowInd = malloc(sizeof(BalFlowInd)); |
| 354 | memset(flowInd, 0, sizeof(BalFlowInd)); |
| 355 | bal_flow_ind__init(flowInd); |
| 356 | balIndCfg->flow_ind = flowInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 357 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 358 | BalObj *hdr; |
| 359 | hdr = malloc(sizeof(BalObj)); |
| 360 | memset(hdr, 0, sizeof(BalObj)); |
| 361 | bal_obj__init(hdr); |
| 362 | balIndCfg->flow_ind->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 363 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 364 | BalFlowKey *flowkey; |
| 365 | flowkey = malloc(sizeof(BalFlowKey)); |
| 366 | memset(flowkey, 0, sizeof(BalFlowKey)); |
| 367 | bal_flow_key__init(flowkey); |
| 368 | balIndCfg->flow_ind->key = flowkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 369 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 370 | balIndCfg->flow_ind->key->has_flow_id = BAL_GRPC_PRES; |
| 371 | balIndCfg->flow_ind->key->flow_id = flow_ind->key.flow_id; |
| 372 | balIndCfg->flow_ind->key->has_flow_type = BAL_GRPC_PRES; |
| 373 | balIndCfg->flow_ind->key->flow_type = flow_ind->key.flow_type; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 374 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 375 | BalFlowIndData *flowIndData; |
| 376 | flowIndData = malloc(sizeof(BalFlowIndData)); |
| 377 | memset(flowIndData, 0, sizeof(BalFlowIndData)); |
| 378 | bal_flow_ind_data__init(flowIndData); |
| 379 | balIndCfg->flow_ind->data = flowIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 380 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 381 | balIndCfg->flow_ind->data->has_admin_state = BAL_GRPC_PRES; |
| 382 | balIndCfg->flow_ind->data->admin_state = flow_ind->data.admin_state; |
| 383 | balIndCfg->flow_ind->data->has_oper_status= BAL_GRPC_PRES; |
| 384 | balIndCfg->flow_ind->data->oper_status= flow_ind->data.oper_status; |
| 385 | balIndCfg->flow_ind->data->has_access_int_id = BAL_GRPC_PRES; |
| 386 | balIndCfg->flow_ind->data->access_int_id = flow_ind->data.access_int_id; |
| 387 | balIndCfg->flow_ind->data->has_network_int_id = BAL_GRPC_PRES; |
| 388 | balIndCfg->flow_ind->data->network_int_id = flow_ind->data.network_int_id; |
| 389 | balIndCfg->flow_ind->data->has_sub_term_id = BAL_GRPC_PRES; |
| 390 | balIndCfg->flow_ind->data->sub_term_id = flow_ind->data.sub_term_id; |
| 391 | balIndCfg->flow_ind->data->has_sub_term_uni_idx = BAL_GRPC_PRES; |
| 392 | balIndCfg->flow_ind->data->sub_term_uni_idx = flow_ind->data.sub_term_uni_idx; |
| 393 | balIndCfg->flow_ind->data->has_svc_port_id = BAL_GRPC_PRES; |
| 394 | balIndCfg->flow_ind->data->svc_port_id = flow_ind->data.svc_port_id; |
| 395 | balIndCfg->flow_ind->data->has_resolve_mac = BAL_GRPC_PRES; |
| 396 | balIndCfg->flow_ind->data->resolve_mac = flow_ind->data.resolve_mac; |
| 397 | balIndCfg->flow_ind->data->has_cookie = BAL_GRPC_PRES; |
| 398 | balIndCfg->flow_ind->data->cookie = flow_ind->data.cookie; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 399 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 400 | BalClassifier *balClassifier; |
| 401 | balClassifier = malloc(sizeof(BalClassifier)); |
| 402 | memset(balClassifier, 0, sizeof(BalClassifier)); |
| 403 | bal_classifier__init(balClassifier); |
| 404 | balIndCfg->flow_ind->data->classifier = balClassifier; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 405 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 406 | balIndCfg->flow_ind->data->classifier->has_presence_mask = BAL_GRPC_PRES; |
| 407 | balIndCfg->flow_ind->data->classifier->presence_mask = flow_ind->data.classifier.presence_mask; |
| 408 | balIndCfg->flow_ind->data->classifier->has_o_tpid = BAL_GRPC_PRES; |
| 409 | balIndCfg->flow_ind->data->classifier->o_tpid = flow_ind->data.classifier.o_tpid; |
| 410 | balIndCfg->flow_ind->data->classifier->has_o_vid = BAL_GRPC_PRES; |
| 411 | balIndCfg->flow_ind->data->classifier->o_vid = flow_ind->data.classifier.o_vid; |
| 412 | balIndCfg->flow_ind->data->classifier->has_i_tpid = BAL_GRPC_PRES; |
| 413 | balIndCfg->flow_ind->data->classifier->i_tpid = flow_ind->data.classifier.i_tpid; |
| 414 | balIndCfg->flow_ind->data->classifier->has_i_vid = BAL_GRPC_PRES; |
| 415 | balIndCfg->flow_ind->data->classifier->i_vid = flow_ind->data.classifier.i_vid; |
| 416 | balIndCfg->flow_ind->data->classifier->has_o_pbits = BAL_GRPC_PRES; |
| 417 | balIndCfg->flow_ind->data->classifier->o_pbits = flow_ind->data.classifier.o_pbits; |
| 418 | balIndCfg->flow_ind->data->classifier->has_i_pbits = BAL_GRPC_PRES; |
| 419 | balIndCfg->flow_ind->data->classifier->i_pbits = flow_ind->data.classifier.i_pbits; |
| 420 | balIndCfg->flow_ind->data->classifier->has_ether_type = BAL_GRPC_PRES; |
| 421 | balIndCfg->flow_ind->data->classifier->ether_type = flow_ind->data.classifier.ether_type; |
| 422 | balIndCfg->flow_ind->data->classifier->has_dst_mac = BAL_GRPC_PRES; |
| 423 | balIndCfg->flow_ind->data->classifier->dst_mac.len = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 424 | (BCMOS_ETH_ALEN)*sizeof(flow_ind->data.classifier.dst_mac.u8); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 425 | balIndCfg->flow_ind->data->classifier->dst_mac.data = |
| 426 | (uint8_t *)malloc((balIndCfg->flow_ind->data->classifier->dst_mac.len)*sizeof(uint8_t)); |
| 427 | memcpy(balIndCfg->flow_ind->data->classifier->dst_mac.data, |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 428 | flow_ind->data.classifier.dst_mac.u8, |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 429 | balIndCfg->flow_ind->data->classifier->dst_mac.len); |
| 430 | balIndCfg->flow_ind->data->classifier->has_src_mac = BAL_GRPC_PRES; |
| 431 | balIndCfg->flow_ind->data->classifier->src_mac.len = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 432 | (BCMOS_ETH_ALEN)*sizeof(flow_ind->data.classifier.src_mac.u8); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 433 | balIndCfg->flow_ind->data->classifier->src_mac.data = |
| 434 | (uint8_t *)malloc((balIndCfg->flow_ind->data->classifier->src_mac.len)*sizeof(uint8_t)); |
| 435 | memcpy(balIndCfg->flow_ind->data->classifier->src_mac.data, |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 436 | flow_ind->data.classifier.src_mac.u8, |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 437 | balIndCfg->flow_ind->data->classifier->src_mac.len); |
| 438 | balIndCfg->flow_ind->data->classifier->has_ip_proto = BAL_GRPC_PRES; |
| 439 | balIndCfg->flow_ind->data->classifier->ip_proto = flow_ind->data.classifier.ip_proto; |
| 440 | balIndCfg->flow_ind->data->classifier->has_dst_ip = BAL_GRPC_PRES; |
| 441 | balIndCfg->flow_ind->data->classifier->dst_ip = flow_ind->data.classifier.dst_ip.u32; |
| 442 | balIndCfg->flow_ind->data->classifier->has_src_ip = BAL_GRPC_PRES; |
| 443 | balIndCfg->flow_ind->data->classifier->src_ip = flow_ind->data.classifier.src_ip.u32; |
| 444 | balIndCfg->flow_ind->data->classifier->has_src_port = BAL_GRPC_PRES; |
| 445 | balIndCfg->flow_ind->data->classifier->src_port = flow_ind->data.classifier.src_port; |
| 446 | balIndCfg->flow_ind->data->classifier->has_dst_port = BAL_GRPC_PRES; |
| 447 | balIndCfg->flow_ind->data->classifier->dst_port = flow_ind->data.classifier.dst_port; |
| 448 | balIndCfg->flow_ind->data->classifier->has_pkt_tag_type = BAL_GRPC_PRES; |
| 449 | balIndCfg->flow_ind->data->classifier->pkt_tag_type = flow_ind->data.classifier.pkt_tag_type; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 450 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 451 | BalAction *balAction; |
| 452 | balAction = malloc(sizeof(BalAction)); |
| 453 | memset(balAction, 0, sizeof(BalAction)); |
| 454 | bal_action__init(balAction); |
| 455 | balIndCfg->flow_ind->data->action = balAction; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 456 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 457 | balIndCfg->flow_ind->data->action->has_presence_mask = BAL_GRPC_PRES; |
| 458 | balIndCfg->flow_ind->data->action->presence_mask = flow_ind->data.action.presence_mask; |
| 459 | balIndCfg->flow_ind->data->action->has_cmds_bitmask = BAL_GRPC_PRES; |
| 460 | balIndCfg->flow_ind->data->action->cmds_bitmask = flow_ind->data.action.cmds_bitmask; |
| 461 | balIndCfg->flow_ind->data->action->has_o_vid = BAL_GRPC_PRES; |
| 462 | balIndCfg->flow_ind->data->action->o_vid = flow_ind->data.action.o_vid; |
| 463 | balIndCfg->flow_ind->data->action->has_o_pbits = BAL_GRPC_PRES; |
| 464 | balIndCfg->flow_ind->data->action->o_pbits = flow_ind->data.action.o_pbits; |
| 465 | balIndCfg->flow_ind->data->action->has_o_tpid = BAL_GRPC_PRES; |
| 466 | balIndCfg->flow_ind->data->action->o_tpid = flow_ind->data.action.o_tpid; |
| 467 | balIndCfg->flow_ind->data->action->has_i_vid = BAL_GRPC_PRES; |
| 468 | balIndCfg->flow_ind->data->action->i_vid = flow_ind->data.action.i_vid; |
| 469 | balIndCfg->flow_ind->data->action->has_i_pbits = BAL_GRPC_PRES; |
| 470 | balIndCfg->flow_ind->data->action->i_pbits = flow_ind->data.action.i_pbits; |
| 471 | balIndCfg->flow_ind->data->action->has_i_tpid = BAL_GRPC_PRES; |
| 472 | balIndCfg->flow_ind->data->action->i_tpid = flow_ind->data.action.i_tpid; |
| 473 | |
| 474 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 475 | bal_indication_node->bal_indication = balIndCfg; |
| 476 | |
| 477 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 478 | add_bal_indication_node(bal_indication_node); |
| 479 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 480 | } |
| 481 | |
| 482 | return result; |
| 483 | } |
| 484 | |
| 485 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 486 | * Function : bal_group_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 487 | * Description : This function will handle the indications for * |
| 488 | * Group Indication * |
| 489 | * * |
| 490 | ********************************************************************/ |
| 491 | bcmos_errno bal_group_indication_cb(bcmbal_obj *obj) |
| 492 | { |
| 493 | bcmos_errno result = BCM_ERR_OK; |
root | 2ca2cc0 | 2017-11-03 19:51:57 +0530 | [diff] [blame] | 494 | unsigned int i = 0; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 495 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 496 | if(BCMBAL_OBJ_ID_GROUP != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 497 | bcmbal_group_auto_id_ind != obj->subgroup) |
| 498 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 499 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 500 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 501 | result = BCM_ERR_INTERNAL; |
| 502 | } |
| 503 | else |
| 504 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 505 | BalIndications *balIndCfg; |
| 506 | balIndCfg = malloc(sizeof(BalIndications)); |
| 507 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 508 | bal_indications__init(balIndCfg); |
| 509 | balIndCfg->u_case = BAL_INDICATIONS__U_GROUP_IND; |
| 510 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 511 | balIndCfg->objtype = obj->obj_type; |
| 512 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 513 | balIndCfg->sub_group = obj->subgroup; |
| 514 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 515 | |
| 516 | bcmbal_group_ind *group_ind = (bcmbal_group_ind *)obj; |
| 517 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 518 | BalGroupInd *groupInd; |
| 519 | groupInd = malloc(sizeof(BalGroupInd)); |
| 520 | memset(groupInd, 0, sizeof(BalGroupInd)); |
| 521 | bal_group_ind__init(groupInd); |
| 522 | balIndCfg->group_ind = groupInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 523 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 524 | BalObj *hdr; |
| 525 | hdr = malloc(sizeof(BalObj)); |
| 526 | memset(hdr, 0, sizeof(BalObj)); |
| 527 | bal_obj__init(hdr); |
| 528 | balIndCfg->group_ind->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 529 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 530 | BalGroupKey *groupkey; |
| 531 | groupkey = malloc(sizeof(BalGroupKey)); |
| 532 | memset(groupkey, 0, sizeof(BalGroupKey)); |
| 533 | bal_group_key__init(groupkey); |
| 534 | balIndCfg->group_ind->key = groupkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 535 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 536 | balIndCfg->group_ind->key->has_group_id = BAL_GRPC_PRES; |
| 537 | balIndCfg->group_ind->key->group_id = group_ind->key.group_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 538 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 539 | BalGroupIndData *groupIndData; |
| 540 | groupIndData = malloc(sizeof(BalGroupIndData)); |
| 541 | memset(groupIndData, 0, sizeof(BalGroupIndData)); |
| 542 | bal_group_ind_data__init(groupIndData); |
| 543 | balIndCfg->group_ind->data = groupIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 544 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 545 | balIndCfg->group_ind->data->has_members_cmd = BAL_GRPC_PRES; |
| 546 | balIndCfg->group_ind->data->members_cmd = group_ind->data.members_cmd; |
| 547 | balIndCfg->group_ind->data->has_cookie = BAL_GRPC_PRES; |
| 548 | balIndCfg->group_ind->data->cookie = group_ind->data.cookie; |
| 549 | balIndCfg->group_ind->data->has_owner = BAL_GRPC_PRES; |
| 550 | balIndCfg->group_ind->data->owner = group_ind->data.owner; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 551 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 552 | BalGroupMemberInfoList *balMembers; |
| 553 | balMembers = malloc(sizeof(BalGroupMemberInfoList)); |
| 554 | memset(balMembers, 0, sizeof(BalGroupMemberInfoList)); |
| 555 | bal_group_member_info_list__init(balMembers); |
| 556 | balIndCfg->group_ind->data->members = balMembers; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 557 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 558 | balIndCfg->group_ind->data->members->n_val = group_ind->data.members.len; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 559 | |
| 560 | BalGroupMemberInfo *balMemberInfo; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 561 | BalAction *balAction; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 562 | BalTmQueueRef *balQueue; |
root | 2ca2cc0 | 2017-11-03 19:51:57 +0530 | [diff] [blame] | 563 | for (i = 0; i < balIndCfg->group_ind->data->members->n_val; i++) |
| 564 | { |
| 565 | balMemberInfo = malloc(sizeof(BalGroupMemberInfo)); |
| 566 | memset(balMemberInfo, 0, sizeof(BalGroupMemberInfo)); |
| 567 | bal_group_member_info__init(balMemberInfo); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 568 | |
root | 2ca2cc0 | 2017-11-03 19:51:57 +0530 | [diff] [blame] | 569 | balMemberInfo->has_intf_id = BAL_GRPC_PRES; |
| 570 | balMemberInfo->intf_id = group_ind->data.members.val->intf_id; |
| 571 | balMemberInfo->has_svc_port_id = BAL_GRPC_PRES; |
| 572 | balMemberInfo->svc_port_id = group_ind->data.members.val->svc_port_id; |
| 573 | |
| 574 | balAction = malloc(sizeof(BalAction)); |
| 575 | memset(balAction, 0, sizeof(BalAction)); |
| 576 | bal_action__init(balAction); |
| 577 | balMemberInfo->action = balAction; |
| 578 | |
| 579 | balMemberInfo->action->has_presence_mask = BAL_GRPC_PRES; |
| 580 | balMemberInfo->action->presence_mask = group_ind->data.members.val->action.presence_mask; |
| 581 | balMemberInfo->action->has_cmds_bitmask = BAL_GRPC_PRES; |
| 582 | balMemberInfo->action->cmds_bitmask = group_ind->data.members.val->action.cmds_bitmask; |
| 583 | balMemberInfo->action->has_o_vid = BAL_GRPC_PRES; |
| 584 | balMemberInfo->action->o_vid = group_ind->data.members.val->action.o_vid; |
| 585 | balMemberInfo->action->has_o_pbits = BAL_GRPC_PRES; |
| 586 | balMemberInfo->action->o_pbits = group_ind->data.members.val->action.o_pbits; |
| 587 | balMemberInfo->action->has_o_tpid = BAL_GRPC_PRES; |
| 588 | balMemberInfo->action->o_tpid = group_ind->data.members.val->action.o_tpid; |
| 589 | balMemberInfo->action->has_i_vid = BAL_GRPC_PRES; |
| 590 | balMemberInfo->action->i_vid = group_ind->data.members.val->action.i_vid; |
| 591 | balMemberInfo->action->has_i_pbits = BAL_GRPC_PRES; |
| 592 | balMemberInfo->action->i_pbits = group_ind->data.members.val->action.i_pbits; |
| 593 | balMemberInfo->action->has_i_tpid = BAL_GRPC_PRES; |
| 594 | balMemberInfo->action->i_tpid = group_ind->data.members.val->action.i_tpid; |
| 595 | |
| 596 | balQueue = malloc(sizeof(BalTmQueueRef)); |
| 597 | memset(balQueue, 0, sizeof(BalTmQueueRef)); |
| 598 | bal_tm_queue_ref__init(balQueue); |
| 599 | balMemberInfo->queue = balQueue; |
| 600 | |
| 601 | balMemberInfo->queue->has_sched_id = BAL_GRPC_PRES; |
| 602 | balMemberInfo->queue->sched_id = group_ind->data.members.val->queue.sched_id; |
| 603 | balMemberInfo->queue->has_queue_id = BAL_GRPC_PRES; |
| 604 | balMemberInfo->queue->queue_id = group_ind->data.members.val->queue.queue_id; |
| 605 | |
| 606 | balIndCfg->group_ind->data->members->val[i] = balMemberInfo; |
| 607 | } |
| 608 | |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 609 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 610 | BalIdList *balFlows; |
| 611 | balFlows = malloc(sizeof(BalIdList)); |
| 612 | memset(balFlows, 0, sizeof(BalIdList)); |
| 613 | bal_id_list__init(balFlows); |
| 614 | balIndCfg->group_ind->data->flows = balFlows; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 615 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 616 | balIndCfg->group_ind->data->flows->n_val = group_ind->data.flows.len; |
| 617 | balIndCfg->group_ind->data->flows->val = |
| 618 | (uint32_t *)malloc((balIndCfg->group_ind->data->flows->n_val)*sizeof(uint32_t)); |
| 619 | memcpy(balIndCfg->group_ind->data->flows->val, group_ind->data.flows.val, |
| 620 | balIndCfg->group_ind->data->flows->n_val); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 621 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 622 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 623 | bal_indication_node->bal_indication = balIndCfg; |
| 624 | |
| 625 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 626 | add_bal_indication_node(bal_indication_node); |
| 627 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 628 | } |
| 629 | |
| 630 | return result; |
| 631 | } |
| 632 | |
| 633 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 634 | * Function : bal_interface_osc_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 635 | * Description : This function will handle the indications for * |
| 636 | * Interface Operational State Change * |
| 637 | * * |
| 638 | ********************************************************************/ |
| 639 | bcmos_errno bal_interface_osc_indication_cb(bcmbal_obj *obj) |
| 640 | { |
| 641 | bcmos_errno result = BCM_ERR_OK; |
| 642 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 643 | if(BCMBAL_OBJ_ID_INTERFACE != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 644 | bcmbal_interface_auto_id_oper_status_change != obj->subgroup) |
| 645 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 646 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 647 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 648 | result = BCM_ERR_INTERNAL; |
| 649 | } |
| 650 | else |
| 651 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 652 | BalIndications *balIndCfg; |
| 653 | balIndCfg = malloc(sizeof(BalIndications)); |
| 654 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 655 | bal_indications__init(balIndCfg); |
| 656 | balIndCfg->u_case = BAL_INDICATIONS__U_INTERFACE_OP_STATE; |
| 657 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 658 | balIndCfg->objtype = obj->obj_type; |
| 659 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 660 | balIndCfg->sub_group = obj->subgroup; |
| 661 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 662 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 663 | bcmbal_interface_oper_status_change *int_osc_ind = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 664 | (bcmbal_interface_oper_status_change *)obj; |
| 665 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 666 | BalInterfaceOperStatusChange *ifOsc; |
| 667 | ifOsc = malloc(sizeof(BalInterfaceOperStatusChange)); |
| 668 | memset(ifOsc, 0, sizeof(BalInterfaceOperStatusChange)); |
| 669 | bal_interface_oper_status_change__init(ifOsc); |
| 670 | balIndCfg->interface_op_state = ifOsc; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 671 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 672 | BalObj *hdr; |
| 673 | hdr = malloc(sizeof(BalObj)); |
| 674 | memset(hdr, 0, sizeof(BalObj)); |
| 675 | bal_obj__init(hdr); |
| 676 | balIndCfg->interface_op_state->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 677 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 678 | BalInterfaceKey *ifkey; |
| 679 | ifkey = malloc(sizeof(BalInterfaceKey)); |
| 680 | memset(ifkey, 0, sizeof(BalInterfaceKey)); |
| 681 | bal_interface_key__init(ifkey); |
| 682 | balIndCfg->interface_op_state->key = ifkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 683 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 684 | balIndCfg->interface_op_state->key->has_intf_id = BAL_GRPC_PRES; |
| 685 | balIndCfg->interface_op_state->key->intf_id = int_osc_ind->key.intf_id; |
| 686 | balIndCfg->interface_op_state->key->has_intf_type = BAL_GRPC_PRES; |
| 687 | balIndCfg->interface_op_state->key->intf_type = int_osc_ind->key.intf_type; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 688 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 689 | BalInterfaceOperStatusChangeData *ifOscIndData; |
| 690 | ifOscIndData = malloc(sizeof(BalInterfaceOperStatusChangeData)); |
| 691 | memset(ifOscIndData, 0, sizeof(BalInterfaceOperStatusChangeData)); |
| 692 | bal_interface_oper_status_change_data__init(ifOscIndData); |
| 693 | balIndCfg->interface_op_state->data = ifOscIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 694 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 695 | balIndCfg->interface_op_state->data->has_new_oper_status = BAL_GRPC_PRES; |
| 696 | balIndCfg->interface_op_state->data->new_oper_status = int_osc_ind->data.new_oper_status; |
| 697 | balIndCfg->interface_op_state->data->has_old_oper_status = BAL_GRPC_PRES; |
| 698 | balIndCfg->interface_op_state->data->old_oper_status = int_osc_ind->data.old_oper_status; |
| 699 | balIndCfg->interface_op_state->data->has_admin_state = BAL_GRPC_PRES; |
| 700 | balIndCfg->interface_op_state->data->admin_state = int_osc_ind->data.admin_state; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 701 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 702 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 703 | bal_indication_node->bal_indication = balIndCfg; |
| 704 | |
| 705 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 706 | add_bal_indication_node(bal_indication_node); |
| 707 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 708 | } |
| 709 | |
| 710 | return result; |
| 711 | } |
| 712 | |
| 713 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 714 | * Function : bal_interface_los_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 715 | * Description : This function will handle the indications for * |
| 716 | * Interface los Indication * |
| 717 | * * |
| 718 | ********************************************************************/ |
| 719 | bcmos_errno bal_interface_los_indication_cb(bcmbal_obj *obj) |
| 720 | { |
| 721 | bcmos_errno result = BCM_ERR_OK; |
| 722 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 723 | if(BCMBAL_OBJ_ID_INTERFACE != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 724 | bcmbal_interface_auto_id_los != obj->subgroup) |
| 725 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 726 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 727 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 728 | result = BCM_ERR_INTERNAL; |
| 729 | } |
| 730 | else |
| 731 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 732 | BalIndications *balIndCfg; |
| 733 | balIndCfg = malloc(sizeof(BalIndications)); |
| 734 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 735 | bal_indications__init(balIndCfg); |
| 736 | balIndCfg->u_case = BAL_INDICATIONS__U_INTERFACE_LOS; |
| 737 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 738 | balIndCfg->objtype = obj->obj_type; |
| 739 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 740 | balIndCfg->sub_group = obj->subgroup; |
| 741 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 742 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 743 | bcmbal_interface_los *int_los_ind = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 744 | (bcmbal_interface_los *)obj; |
| 745 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 746 | BalInterfaceLos *ifLos; |
| 747 | ifLos = malloc(sizeof(BalInterfaceLos)); |
| 748 | memset(ifLos, 0, sizeof(BalInterfaceLos)); |
| 749 | bal_interface_los__init(ifLos); |
| 750 | balIndCfg->interface_los = ifLos; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 751 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 752 | BalObj *hdr; |
| 753 | hdr = malloc(sizeof(BalObj)); |
| 754 | memset(hdr, 0, sizeof(BalObj)); |
| 755 | bal_obj__init(hdr); |
| 756 | balIndCfg->interface_los->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 757 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 758 | BalInterfaceKey *ifkey; |
| 759 | ifkey = malloc(sizeof(BalInterfaceKey)); |
| 760 | memset(ifkey, 0, sizeof(BalInterfaceKey)); |
| 761 | bal_interface_key__init(ifkey); |
| 762 | balIndCfg->interface_los->key = ifkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 763 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 764 | balIndCfg->interface_los->key->has_intf_id = BAL_GRPC_PRES; |
| 765 | balIndCfg->interface_los->key->intf_id = int_los_ind->key.intf_id; |
| 766 | balIndCfg->interface_los->key->has_intf_type = BAL_GRPC_PRES; |
| 767 | balIndCfg->interface_los->key->intf_type = int_los_ind->key.intf_type; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 768 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 769 | BalInterfaceLosData *ifLosIndData; |
| 770 | ifLosIndData = malloc(sizeof(BalInterfaceLosData)); |
| 771 | memset(ifLosIndData, 0, sizeof(BalInterfaceLosData)); |
| 772 | bal_interface_los_data__init(ifLosIndData); |
| 773 | balIndCfg->interface_los->data = ifLosIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 774 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 775 | balIndCfg->interface_los->data->has_status = BAL_GRPC_PRES; |
| 776 | balIndCfg->interface_los->data->status = int_los_ind->data.status; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 777 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 778 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 779 | bal_indication_node->bal_indication = balIndCfg; |
| 780 | |
| 781 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 782 | add_bal_indication_node(bal_indication_node); |
| 783 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 784 | } |
| 785 | |
| 786 | return result; |
| 787 | } |
| 788 | |
| 789 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 790 | * Function : bal_interface_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 791 | * Description : This function will handle the indications for * |
| 792 | * Interface Indication * |
| 793 | * * |
| 794 | ********************************************************************/ |
| 795 | bcmos_errno bal_interface_indication_cb(bcmbal_obj *obj) |
| 796 | { |
| 797 | bcmos_errno result = BCM_ERR_OK; |
| 798 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 799 | if(BCMBAL_OBJ_ID_INTERFACE != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 800 | bcmbal_interface_auto_id_ind != obj->subgroup) |
| 801 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 802 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 803 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 804 | result = BCM_ERR_INTERNAL; |
| 805 | } |
| 806 | else |
| 807 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 808 | BalIndications *balIndCfg; |
| 809 | balIndCfg = malloc(sizeof(BalIndications)); |
| 810 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 811 | bal_indications__init(balIndCfg); |
| 812 | balIndCfg->u_case = BAL_INDICATIONS__U_INTERFACE_IND; |
| 813 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 814 | balIndCfg->objtype = obj->obj_type; |
| 815 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 816 | balIndCfg->sub_group = obj->subgroup; |
| 817 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 818 | |
| 819 | bcmbal_interface_ind *interface_ind = (bcmbal_interface_ind *)obj; |
| 820 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 821 | BalInterfaceInd *ifInd; |
| 822 | ifInd = malloc(sizeof(BalInterfaceInd)); |
| 823 | memset(ifInd, 0, sizeof(BalInterfaceInd)); |
| 824 | bal_interface_ind__init(ifInd); |
| 825 | balIndCfg->interface_ind = ifInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 826 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 827 | BalObj *hdr; |
| 828 | hdr = malloc(sizeof(BalObj)); |
| 829 | memset(hdr, 0, sizeof(BalObj)); |
| 830 | bal_obj__init(hdr); |
| 831 | balIndCfg->interface_ind->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 832 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 833 | BalInterfaceKey *ifkey; |
| 834 | ifkey = malloc(sizeof(BalInterfaceKey)); |
| 835 | memset(ifkey, 0, sizeof(BalInterfaceKey)); |
| 836 | bal_interface_key__init(ifkey); |
| 837 | balIndCfg->interface_ind->key = ifkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 838 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 839 | balIndCfg->interface_ind->key->has_intf_id = BAL_GRPC_PRES; |
| 840 | balIndCfg->interface_ind->key->intf_id = interface_ind->key.intf_id; |
| 841 | balIndCfg->interface_ind->key->has_intf_type = BAL_GRPC_PRES; |
| 842 | balIndCfg->interface_ind->key->intf_type = interface_ind->key.intf_type; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 843 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 844 | BalInterfaceIndData *ifIndData; |
| 845 | ifIndData = malloc(sizeof(BalInterfaceIndData)); |
| 846 | memset(ifIndData, 0, sizeof(BalInterfaceIndData)); |
| 847 | bal_interface_ind_data__init(ifIndData); |
| 848 | balIndCfg->interface_ind->data = ifIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 849 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 850 | balIndCfg->interface_ind->data->has_admin_state = BAL_GRPC_PRES; |
| 851 | balIndCfg->interface_ind->data->admin_state = interface_ind->data.admin_state; |
| 852 | balIndCfg->interface_ind->data->has_oper_status = BAL_GRPC_PRES; |
| 853 | balIndCfg->interface_ind->data->oper_status = interface_ind->data.oper_status; |
| 854 | balIndCfg->interface_ind->data->has_min_data_agg_port_id = BAL_GRPC_PRES; |
| 855 | balIndCfg->interface_ind->data->min_data_agg_port_id = interface_ind->data.min_data_agg_port_id; |
| 856 | balIndCfg->interface_ind->data->has_min_data_svc_port_id = BAL_GRPC_PRES; |
| 857 | balIndCfg->interface_ind->data->min_data_svc_port_id = interface_ind->data.min_data_svc_port_id; |
| 858 | balIndCfg->interface_ind->data->has_transceiver_type = BAL_GRPC_PRES; |
| 859 | balIndCfg->interface_ind->data->transceiver_type = interface_ind->data.transceiver_type; |
| 860 | balIndCfg->interface_ind->data->has_ds_miss_mode = BAL_GRPC_PRES; |
| 861 | balIndCfg->interface_ind->data->ds_miss_mode = interface_ind->data.ds_miss_mode; |
| 862 | balIndCfg->interface_ind->data->has_mtu = BAL_GRPC_PRES; |
| 863 | balIndCfg->interface_ind->data->mtu = interface_ind->data.mtu; |
| 864 | balIndCfg->interface_ind->data->has_flow_control = BAL_GRPC_PRES; |
| 865 | balIndCfg->interface_ind->data->flow_control = interface_ind->data.flow_control; |
| 866 | balIndCfg->interface_ind->data->has_ds_tm = BAL_GRPC_PRES; |
| 867 | balIndCfg->interface_ind->data->ds_tm = interface_ind->data.ds_tm; |
| 868 | balIndCfg->interface_ind->data->has_us_tm = BAL_GRPC_PRES; |
| 869 | balIndCfg->interface_ind->data->us_tm = interface_ind->data.us_tm; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 870 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 871 | BalIdList *balFlows; |
| 872 | balFlows = malloc(sizeof(BalIdList)); |
| 873 | memset(balFlows, 0, sizeof(BalIdList)); |
| 874 | bal_id_list__init(balFlows); |
| 875 | balIndCfg->interface_ind->data->sub_term_id_list = balFlows; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 876 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 877 | balIndCfg->interface_ind->data->sub_term_id_list->n_val = interface_ind->data.sub_term_id_list.len; |
| 878 | balIndCfg->interface_ind->data->sub_term_id_list->val = |
| 879 | (uint32_t *)malloc((balIndCfg->interface_ind->data->sub_term_id_list->n_val)*sizeof(uint32_t)); |
| 880 | memcpy(balIndCfg->interface_ind->data->sub_term_id_list->val, interface_ind->data.sub_term_id_list.val, |
| 881 | balIndCfg->interface_ind->data->sub_term_id_list->n_val); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 882 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 883 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 884 | bal_indication_node->bal_indication = balIndCfg; |
| 885 | |
| 886 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 887 | add_bal_indication_node(bal_indication_node); |
| 888 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 889 | } |
| 890 | |
| 891 | return result; |
| 892 | } |
| 893 | |
| 894 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 895 | * Function : bal_sub_term_osc_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 896 | * Description : This function will handle the indications for * |
| 897 | * Subscriber term Operational State Change * |
| 898 | * * |
| 899 | ********************************************************************/ |
| 900 | bcmos_errno bal_sub_term_osc_indication_cb(bcmbal_obj *obj) |
| 901 | { |
| 902 | bcmos_errno result = BCM_ERR_OK; |
| 903 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 904 | if(BCMBAL_OBJ_ID_SUBSCRIBER_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 905 | bcmbal_subscriber_terminal_auto_id_oper_status_change != obj->subgroup) |
| 906 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 907 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 908 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 909 | result = BCM_ERR_INTERNAL; |
| 910 | } |
| 911 | else |
| 912 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 913 | BalIndications *balIndCfg; |
| 914 | balIndCfg = malloc(sizeof(BalIndications)); |
| 915 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 916 | bal_indications__init(balIndCfg); |
| 917 | balIndCfg->u_case = BAL_INDICATIONS__U_TERMINAL_OP_STATE; |
| 918 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 919 | balIndCfg->objtype = obj->obj_type; |
| 920 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 921 | balIndCfg->sub_group = obj->subgroup; |
| 922 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 923 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 924 | bcmbal_subscriber_terminal_oper_status_change *sub_osc_ind = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 925 | (bcmbal_subscriber_terminal_oper_status_change *)obj; |
| 926 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 927 | BalSubscriberTerminalOperStatusChange *subOscInd; |
| 928 | subOscInd = malloc(sizeof(BalSubscriberTerminalOperStatusChange)); |
| 929 | memset(subOscInd, 0, sizeof(BalSubscriberTerminalOperStatusChange)); |
| 930 | bal_subscriber_terminal_oper_status_change__init(subOscInd); |
| 931 | balIndCfg->terminal_op_state = subOscInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 932 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 933 | BalObj *hdr; |
| 934 | hdr = malloc(sizeof(BalObj)); |
| 935 | memset(hdr, 0, sizeof(BalObj)); |
| 936 | bal_obj__init(hdr); |
| 937 | balIndCfg->terminal_op_state->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 938 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 939 | BalSubscriberTerminalKey *subkey; |
| 940 | subkey = malloc(sizeof(BalSubscriberTerminalKey)); |
| 941 | memset(subkey, 0, sizeof(BalSubscriberTerminalKey)); |
| 942 | bal_subscriber_terminal_key__init(subkey); |
| 943 | balIndCfg->terminal_op_state->key = subkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 944 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 945 | balIndCfg->terminal_op_state->key->has_intf_id = BAL_GRPC_PRES; |
| 946 | balIndCfg->terminal_op_state->key->intf_id = sub_osc_ind->key.intf_id; |
| 947 | balIndCfg->terminal_op_state->key->has_sub_term_id = BAL_GRPC_PRES; |
| 948 | balIndCfg->terminal_op_state->key->sub_term_id = sub_osc_ind->key.sub_term_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 949 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 950 | BalSubscriberTerminalOperStatusChangeData *subOscIndData; |
| 951 | subOscIndData = malloc(sizeof(BalSubscriberTerminalOperStatusChangeData)); |
| 952 | memset(subOscIndData, 0, sizeof(BalSubscriberTerminalOperStatusChangeData)); |
| 953 | bal_subscriber_terminal_oper_status_change_data__init(subOscIndData); |
| 954 | balIndCfg->terminal_op_state->data = subOscIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 955 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 956 | balIndCfg->terminal_op_state->data->has_new_oper_status = BAL_GRPC_PRES; |
| 957 | balIndCfg->terminal_op_state->data->new_oper_status = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 958 | sub_osc_ind->data.new_oper_status; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 959 | balIndCfg->terminal_op_state->data->has_old_oper_status = BAL_GRPC_PRES; |
| 960 | balIndCfg->terminal_op_state->data->old_oper_status = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 961 | sub_osc_ind->data.old_oper_status; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 962 | balIndCfg->terminal_op_state->data->has_admin_state = BAL_GRPC_PRES; |
| 963 | balIndCfg->terminal_op_state->data->admin_state = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 964 | sub_osc_ind->data.admin_state; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 965 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 966 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 967 | bal_indication_node->bal_indication = balIndCfg; |
| 968 | |
| 969 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 970 | add_bal_indication_node(bal_indication_node); |
| 971 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 972 | } |
| 973 | |
| 974 | return result; |
| 975 | } |
| 976 | |
| 977 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 978 | * Function : bal_sub_term_disc_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 979 | * Description : This function will handle the indications for * |
| 980 | * Subscriber term disc indication * |
| 981 | * * |
| 982 | ********************************************************************/ |
| 983 | bcmos_errno bal_sub_term_disc_indication_cb(bcmbal_obj *obj) |
| 984 | { |
| 985 | bcmos_errno result = BCM_ERR_OK; |
| 986 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 987 | if(BCMBAL_OBJ_ID_SUBSCRIBER_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 988 | bcmbal_subscriber_terminal_auto_id_sub_term_disc != obj->subgroup) |
| 989 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 990 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 991 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 992 | result = BCM_ERR_INTERNAL; |
| 993 | } |
| 994 | else |
| 995 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 996 | ASFVOLT_LOG(ASFVOLT_DEBUG, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 997 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 998 | BalIndications *balIndCfg; |
| 999 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1000 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1001 | bal_indications__init(balIndCfg); |
| 1002 | balIndCfg->u_case = BAL_INDICATIONS__U_TERMINAL_DISC; |
| 1003 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1004 | balIndCfg->objtype = obj->obj_type; |
| 1005 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1006 | balIndCfg->sub_group = obj->subgroup; |
| 1007 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1008 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1009 | bcmbal_subscriber_terminal_sub_term_disc *sub_disc_ind = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1010 | (bcmbal_subscriber_terminal_sub_term_disc *)obj; |
| 1011 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1012 | BalSubscriberTerminalSubTermDisc *subDiscInd; |
| 1013 | subDiscInd = malloc(sizeof(BalSubscriberTerminalSubTermDisc)); |
| 1014 | memset(subDiscInd, 0, sizeof(BalSubscriberTerminalSubTermDisc)); |
| 1015 | bal_subscriber_terminal_sub_term_disc__init(subDiscInd); |
| 1016 | balIndCfg->terminal_disc = subDiscInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1017 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1018 | BalObj *hdr; |
| 1019 | hdr = malloc(sizeof(BalObj)); |
| 1020 | memset(hdr, 0, sizeof(BalObj)); |
| 1021 | bal_obj__init(hdr); |
| 1022 | balIndCfg->terminal_disc->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1023 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1024 | BalSubscriberTerminalKey *subkey; |
| 1025 | subkey = malloc(sizeof(BalSubscriberTerminalKey)); |
| 1026 | memset(subkey, 0, sizeof(BalSubscriberTerminalKey)); |
| 1027 | bal_subscriber_terminal_key__init(subkey); |
| 1028 | balIndCfg->terminal_disc->key = subkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1029 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1030 | balIndCfg->terminal_disc->key->has_intf_id = BAL_GRPC_PRES; |
| 1031 | balIndCfg->terminal_disc->key->intf_id = sub_disc_ind->key.intf_id; |
| 1032 | balIndCfg->terminal_disc->key->has_sub_term_id = BAL_GRPC_PRES; |
| 1033 | balIndCfg->terminal_disc->key->sub_term_id = sub_disc_ind->key.sub_term_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1034 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1035 | BalSubscriberTerminalSubTermDiscData *subDiscIndData; |
| 1036 | subDiscIndData = malloc(sizeof(BalSubscriberTerminalSubTermDiscData)); |
| 1037 | memset(subDiscIndData, 0, sizeof(BalSubscriberTerminalSubTermDiscData)); |
| 1038 | bal_subscriber_terminal_sub_term_disc_data__init(subDiscIndData); |
| 1039 | balIndCfg->terminal_disc->data = subDiscIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1040 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1041 | BalSerialNumber *serial_number; |
| 1042 | serial_number = malloc(sizeof(BalSerialNumber)); |
| 1043 | memset(serial_number, 0, sizeof(BalSerialNumber)); |
| 1044 | bal_serial_number__init(serial_number); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1045 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1046 | balIndCfg->terminal_disc->data->serial_number = serial_number; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1047 | |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1048 | ASFVOLT_LOG(ASFVOLT_INFO, "Discovered ONU serial number " |
| 1049 | "%c%c%c%c%02X%02X%02X%02X", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1050 | sub_disc_ind->data.serial_number.vendor_id[0], |
| 1051 | sub_disc_ind->data.serial_number.vendor_id[1], |
| 1052 | sub_disc_ind->data.serial_number.vendor_id[2], |
| 1053 | sub_disc_ind->data.serial_number.vendor_id[3], |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1054 | sub_disc_ind->data.serial_number.vendor_specific[0], |
| 1055 | sub_disc_ind->data.serial_number.vendor_specific[1], |
| 1056 | sub_disc_ind->data.serial_number.vendor_specific[2], |
| 1057 | sub_disc_ind->data.serial_number.vendor_specific[3]); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1058 | |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1059 | //ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Discovery:Before decoding:Vendor id is %s", sub_disc_ind->data.serial_number.vendor_id); |
| 1060 | //ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Discovery:Before decoding:Vendor specific is %s", sub_disc_ind->data.serial_number.vendor_specific); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1061 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1062 | char *vendor_id = malloc(sizeof(char)*MAX_CHAR_LENGTH); |
| 1063 | memset(vendor_id, 0, MAX_CHAR_LENGTH); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1064 | sprintf(vendor_id,"%c%c%c%c", |
| 1065 | sub_disc_ind->data.serial_number.vendor_id[0], |
| 1066 | sub_disc_ind->data.serial_number.vendor_id[1], |
| 1067 | sub_disc_ind->data.serial_number.vendor_id[2], |
| 1068 | sub_disc_ind->data.serial_number.vendor_id[3]); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1069 | balIndCfg->terminal_disc->data->serial_number->vendor_id = vendor_id; |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1070 | ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Discovery:After decoding:Vendor id is %s", balIndCfg->terminal_disc->data->serial_number->vendor_id); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1071 | char *vendor_specific = malloc(sizeof(char)*MAX_CHAR_LENGTH); |
| 1072 | memset(vendor_specific, 0, MAX_CHAR_LENGTH); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1073 | sprintf(vendor_specific,"%1X%1X%1X%1X%1X%1X%1X%1X", |
| 1074 | sub_disc_ind->data.serial_number.vendor_specific[0]>>4 & 0x0f, |
| 1075 | sub_disc_ind->data.serial_number.vendor_specific[0] & 0x0f, |
| 1076 | sub_disc_ind->data.serial_number.vendor_specific[1]>>4 & 0x0f, |
| 1077 | sub_disc_ind->data.serial_number.vendor_specific[1] & 0x0f, |
| 1078 | sub_disc_ind->data.serial_number.vendor_specific[2]>>4 & 0x0f, |
| 1079 | sub_disc_ind->data.serial_number.vendor_specific[2] & 0x0f, |
| 1080 | sub_disc_ind->data.serial_number.vendor_specific[3]>>4 & 0x0f, |
| 1081 | sub_disc_ind->data.serial_number.vendor_specific[3] & 0x0f); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1082 | balIndCfg->terminal_disc->data->serial_number->vendor_specific = vendor_specific; |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1083 | ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Discovery:After decoding:Vendor specific is %s", balIndCfg->terminal_disc->data->serial_number->vendor_specific); |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1084 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1085 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1086 | bal_indication_node->bal_indication = balIndCfg; |
| 1087 | |
| 1088 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1089 | add_bal_indication_node(bal_indication_node); |
| 1090 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1091 | } |
| 1092 | |
| 1093 | return result; |
| 1094 | } |
| 1095 | |
| 1096 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1097 | * Function : bal_sub_term_alarm_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1098 | * Description : This function will handle the indications for * |
| 1099 | * Subscriber term alarm indication * |
| 1100 | * * |
| 1101 | ********************************************************************/ |
| 1102 | bcmos_errno bal_sub_term_alarm_indication_cb(bcmbal_obj *obj) |
| 1103 | { |
| 1104 | bcmos_errno result = BCM_ERR_OK; |
| 1105 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1106 | if(BCMBAL_OBJ_ID_SUBSCRIBER_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1107 | bcmbal_subscriber_terminal_auto_id_sub_term_alarm != obj->subgroup) |
| 1108 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1109 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API \'%s\' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1110 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1111 | result = BCM_ERR_INTERNAL; |
| 1112 | } |
| 1113 | else |
| 1114 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1115 | BalIndications *balIndCfg; |
| 1116 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1117 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1118 | bal_indications__init(balIndCfg); |
| 1119 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1120 | balIndCfg->objtype = BAL_OBJ_ID__BAL_OBJ_ID_SUBSCRIBER_TERMINAL; |
| 1121 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1122 | balIndCfg->sub_group = obj->subgroup; |
| 1123 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1124 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1125 | balIndCfg->u_case = BAL_INDICATIONS__U_TERMINAL_ALARM; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1126 | bcmbal_subscriber_terminal_sub_term_alarm *sub_term_alarm = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1127 | (bcmbal_subscriber_terminal_sub_term_alarm *)obj; |
| 1128 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1129 | BalSubscriberTerminalSubTermAlarm *subTermAlarm; |
| 1130 | subTermAlarm = malloc(sizeof(BalSubscriberTerminalSubTermAlarm)); |
| 1131 | memset(subTermAlarm, 0, sizeof(BalSubscriberTerminalSubTermAlarm)); |
| 1132 | bal_subscriber_terminal_sub_term_alarm__init(subTermAlarm); |
| 1133 | balIndCfg->terminal_alarm = subTermAlarm; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1134 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1135 | BalObj *hdr; |
| 1136 | hdr = malloc(sizeof(BalObj)); |
| 1137 | memset(hdr, 0, sizeof(BalObj)); |
| 1138 | bal_obj__init(hdr); |
| 1139 | balIndCfg->terminal_alarm->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1140 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1141 | BalSubscriberTerminalKey *subkey; |
| 1142 | subkey = malloc(sizeof(BalSubscriberTerminalKey)); |
| 1143 | memset(subkey, 0, sizeof(BalSubscriberTerminalKey)); |
| 1144 | bal_subscriber_terminal_key__init(subkey); |
| 1145 | balIndCfg->terminal_alarm->key = subkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1146 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1147 | balIndCfg->terminal_alarm->key->has_sub_term_id = BAL_GRPC_PRES; |
| 1148 | balIndCfg->terminal_alarm->key->sub_term_id = sub_term_alarm->key.sub_term_id; |
| 1149 | balIndCfg->terminal_alarm->key->has_intf_id = BAL_GRPC_PRES; |
| 1150 | balIndCfg->terminal_alarm->key->intf_id = sub_term_alarm->key.intf_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1151 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1152 | BalsubscriberTerminalSubTermAlarmData *subTermAlarmData; |
| 1153 | subTermAlarmData = malloc(sizeof(BalsubscriberTerminalSubTermAlarmData)); |
| 1154 | memset(subTermAlarmData, 0, sizeof(BalsubscriberTerminalSubTermAlarmData)); |
| 1155 | balsubscriber_terminal_sub_term_alarm_data__init(subTermAlarmData); |
| 1156 | balIndCfg->terminal_alarm->data = subTermAlarmData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1157 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1158 | BalSubscriberTerminalAlarms *balSubAlarms; |
| 1159 | balSubAlarms = malloc(sizeof(BalSubscriberTerminalAlarms)); |
| 1160 | memset(balSubAlarms, 0, sizeof(BalSubscriberTerminalAlarms)); |
| 1161 | bal_subscriber_terminal_alarms__init(balSubAlarms); |
| 1162 | balIndCfg->terminal_alarm->data->alarm = balSubAlarms; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1163 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1164 | balIndCfg->terminal_alarm->data->alarm->has_los = BAL_GRPC_PRES; |
| 1165 | balIndCfg->terminal_alarm->data->alarm->los = sub_term_alarm->data.alarm.los; |
| 1166 | balIndCfg->terminal_alarm->data->alarm->has_lob = BAL_GRPC_PRES; |
| 1167 | balIndCfg->terminal_alarm->data->alarm->lob = sub_term_alarm->data.alarm.lob; |
| 1168 | balIndCfg->terminal_alarm->data->alarm->has_lopc_miss = BAL_GRPC_PRES; |
| 1169 | balIndCfg->terminal_alarm->data->alarm->lopc_miss = sub_term_alarm->data.alarm.lopc_miss; |
| 1170 | balIndCfg->terminal_alarm->data->alarm->has_lopc_mic_error = BAL_GRPC_PRES; |
| 1171 | balIndCfg->terminal_alarm->data->alarm->lopc_mic_error = sub_term_alarm->data.alarm.lopc_mic_error; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1172 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1173 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1174 | bal_indication_node->bal_indication = balIndCfg; |
| 1175 | |
| 1176 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1177 | add_bal_indication_node(bal_indication_node); |
| 1178 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1179 | } |
| 1180 | |
| 1181 | return result; |
| 1182 | } |
| 1183 | |
| 1184 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1185 | * Function : bal_sub_term_dgi_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1186 | * Description : This function will handle the indications for * |
| 1187 | * Subscriber term dgi indication * |
| 1188 | * * |
| 1189 | ********************************************************************/ |
| 1190 | bcmos_errno bal_sub_term_dgi_indication_cb(bcmbal_obj *obj) |
| 1191 | { |
| 1192 | bcmos_errno result = BCM_ERR_OK; |
| 1193 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1194 | if(BCMBAL_OBJ_ID_SUBSCRIBER_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1195 | bcmbal_subscriber_terminal_auto_id_dgi != obj->subgroup) |
| 1196 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1197 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1198 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1199 | result = BCM_ERR_INTERNAL; |
| 1200 | } |
| 1201 | else |
| 1202 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1203 | BalIndications *balIndCfg; |
| 1204 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1205 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1206 | bal_indications__init(balIndCfg); |
| 1207 | balIndCfg->u_case = BAL_INDICATIONS__U_TERMINAL_DGI; |
| 1208 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1209 | balIndCfg->objtype = obj->obj_type; |
| 1210 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1211 | balIndCfg->sub_group = obj->subgroup; |
| 1212 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1213 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1214 | bcmbal_subscriber_terminal_dgi *sub_dgi_ind = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1215 | (bcmbal_subscriber_terminal_dgi *)obj; |
| 1216 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1217 | BalSubscriberTerminalDgi *subDgiInd; |
| 1218 | subDgiInd = malloc(sizeof(BalSubscriberTerminalDgi)); |
| 1219 | memset(subDgiInd, 0, sizeof(BalSubscriberTerminalDgi)); |
| 1220 | bal_subscriber_terminal_dgi__init(subDgiInd); |
| 1221 | balIndCfg->terminal_dgi= subDgiInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1222 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1223 | BalObj *hdr; |
| 1224 | hdr = malloc(sizeof(BalObj)); |
| 1225 | memset(hdr, 0, sizeof(BalObj)); |
| 1226 | bal_obj__init(hdr); |
| 1227 | balIndCfg->terminal_dgi->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1228 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1229 | BalSubscriberTerminalKey *subkey; |
| 1230 | subkey = malloc(sizeof(BalSubscriberTerminalKey)); |
| 1231 | memset(subkey, 0, sizeof(BalSubscriberTerminalKey)); |
| 1232 | bal_subscriber_terminal_key__init(subkey); |
| 1233 | balIndCfg->terminal_dgi->key = subkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1234 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1235 | balIndCfg->terminal_dgi->key->has_intf_id = BAL_GRPC_PRES; |
| 1236 | balIndCfg->terminal_dgi->key->intf_id = sub_dgi_ind->key.intf_id; |
| 1237 | balIndCfg->terminal_dgi->key->has_sub_term_id = BAL_GRPC_PRES; |
| 1238 | balIndCfg->terminal_dgi->key->sub_term_id = sub_dgi_ind->key.sub_term_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1239 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1240 | BalSubscriberTerminalDgiData *subDgiIndData; |
| 1241 | subDgiIndData = malloc(sizeof(BalSubscriberTerminalDgiData)); |
| 1242 | memset(subDgiIndData, 0, sizeof(BalSubscriberTerminalDgiData)); |
| 1243 | bal_subscriber_terminal_dgi_data__init(subDgiIndData); |
| 1244 | balIndCfg->terminal_dgi->data = subDgiIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1245 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1246 | balIndCfg->terminal_dgi->data->has_dgi_status = BAL_GRPC_PRES; |
| 1247 | balIndCfg->terminal_dgi->data->dgi_status = sub_dgi_ind->data.dgi_status; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1248 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1249 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1250 | bal_indication_node->bal_indication = balIndCfg; |
| 1251 | |
| 1252 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1253 | add_bal_indication_node(bal_indication_node); |
| 1254 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1255 | } |
| 1256 | |
| 1257 | return result; |
| 1258 | } |
| 1259 | |
| 1260 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1261 | * Function : bal_sub_term_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1262 | * Description : This function will handle the indications for * |
| 1263 | * Subscriber term indication * |
| 1264 | * * |
| 1265 | ********************************************************************/ |
| 1266 | bcmos_errno bal_sub_term_indication_cb(bcmbal_obj *obj) |
| 1267 | { |
| 1268 | bcmos_errno result = BCM_ERR_OK; |
| 1269 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1270 | if(BCMBAL_OBJ_ID_SUBSCRIBER_TERMINAL != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1271 | bcmbal_subscriber_terminal_auto_id_ind != obj->subgroup) |
| 1272 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1273 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1274 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1275 | result = BCM_ERR_INTERNAL; |
| 1276 | } |
| 1277 | else |
| 1278 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1279 | BalIndications *balIndCfg; |
| 1280 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1281 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1282 | bal_indications__init(balIndCfg); |
| 1283 | balIndCfg->u_case = BAL_INDICATIONS__U_TERMINAL_IND; |
| 1284 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1285 | balIndCfg->objtype = obj->obj_type; |
| 1286 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1287 | balIndCfg->sub_group = obj->subgroup; |
| 1288 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1289 | |
| 1290 | bcmbal_subscriber_terminal_ind *sub_ind = (bcmbal_subscriber_terminal_ind *)obj; |
| 1291 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1292 | BalSubscriberTerminalInd *subInd; |
| 1293 | subInd = malloc(sizeof(BalSubscriberTerminalInd)); |
| 1294 | memset(subInd, 0, sizeof(BalSubscriberTerminalInd)); |
| 1295 | bal_subscriber_terminal_ind__init(subInd); |
| 1296 | balIndCfg->terminal_ind = subInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1297 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1298 | BalObj *hdr; |
| 1299 | hdr = malloc(sizeof(BalObj)); |
| 1300 | memset(hdr, 0, sizeof(BalObj)); |
| 1301 | bal_obj__init(hdr); |
| 1302 | balIndCfg->terminal_ind->hdr = hdr; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1303 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1304 | BalSubscriberTerminalKey *subkey; |
| 1305 | subkey = malloc(sizeof(BalSubscriberTerminalKey)); |
| 1306 | memset(subkey, 0, sizeof(BalSubscriberTerminalKey)); |
| 1307 | bal_subscriber_terminal_key__init(subkey); |
| 1308 | balIndCfg->terminal_ind->key = subkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1309 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1310 | balIndCfg->terminal_ind->key->has_intf_id = BAL_GRPC_PRES; |
| 1311 | balIndCfg->terminal_ind->key->intf_id = sub_ind->key.intf_id; |
| 1312 | balIndCfg->terminal_ind->key->has_sub_term_id = BAL_GRPC_PRES; |
| 1313 | balIndCfg->terminal_ind->key->sub_term_id = sub_ind->key.sub_term_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1314 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1315 | BalSubscriberTerminalIndData *subIndData; |
| 1316 | subIndData = malloc(sizeof(BalSubscriberTerminalIndData)); |
| 1317 | memset(subIndData, 0, sizeof(BalSubscriberTerminalIndData)); |
| 1318 | bal_subscriber_terminal_ind_data__init(subIndData); |
| 1319 | balIndCfg->terminal_ind->data = subIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1320 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1321 | balIndCfg->terminal_ind->data->has_admin_state = BAL_GRPC_PRES; |
| 1322 | balIndCfg->terminal_ind->data->admin_state = sub_ind->data.admin_state; |
| 1323 | balIndCfg->terminal_ind->data->has_oper_status = BAL_GRPC_PRES; |
| 1324 | balIndCfg->terminal_ind->data->oper_status = sub_ind->data.oper_status; |
| 1325 | balIndCfg->terminal_ind->data->has_svc_port_id = BAL_GRPC_PRES; |
| 1326 | balIndCfg->terminal_ind->data->svc_port_id = sub_ind->data.svc_port_id; |
| 1327 | balIndCfg->terminal_ind->data->has_ds_tm = BAL_GRPC_PRES; |
| 1328 | balIndCfg->terminal_ind->data->ds_tm = sub_ind->data.ds_tm; |
| 1329 | balIndCfg->terminal_ind->data->has_us_tm = BAL_GRPC_PRES; |
| 1330 | balIndCfg->terminal_ind->data->us_tm = sub_ind->data.us_tm; |
| 1331 | balIndCfg->terminal_ind->data->has_sub_term_rate = BAL_GRPC_PRES; |
| 1332 | balIndCfg->terminal_ind->data->sub_term_rate = sub_ind->data.sub_term_rate; |
| 1333 | char *password = malloc(sizeof(char)*MAX_CHAR_LENGTH*2); |
| 1334 | memset(password, 0, MAX_CHAR_LENGTH*2); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1335 | strcpy(password,(const char *)sub_ind->data.password.arr); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1336 | balIndCfg->terminal_ind->data->password = password; |
| 1337 | char *registration_id = malloc(sizeof(char)*MAX_CHAR_LENGTH*8); |
| 1338 | memset(registration_id, 0, MAX_CHAR_LENGTH*8); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1339 | strcpy(registration_id,(const char *)sub_ind->data.registration_id.arr); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1340 | balIndCfg->terminal_ind->data->registration_id = registration_id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1341 | |
| 1342 | #if 0 |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1343 | balIndCfg->terminal_ind->data->has_mac_address = BAL_GRPC_PRES; |
| 1344 | balIndCfg->terminal_ind->data->mac_address.len = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1345 | (BCMOS_ETH_ALEN)*sizeof(sub_ind->data.mac_address.u8); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1346 | uint8_t mac_address[balIndCfg->terminal_ind->data->mac_address.len]; |
| 1347 | memset(&mac_address, 0 ,balIndCfg->terminal_ind->data->mac_address.len); |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1348 | strcpy((char *)mac_address,(const char *)sub_ind->data.mac_address.u8); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1349 | balIndCfg->terminal_ind->data->mac_address.data = mac_address; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1350 | #endif |
| 1351 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1352 | BalSerialNumber *serialNum; |
| 1353 | serialNum = malloc(sizeof(BalSerialNumber)); |
| 1354 | memset(serialNum, 0, sizeof(BalSerialNumber)); |
| 1355 | bal_serial_number__init(serialNum); |
| 1356 | balIndCfg->terminal_ind->data->serial_number = serialNum; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1357 | |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1358 | //ASFVOLT_LOG(ASFVOLT_ERROR, "ONU Activation:Before decoding:Vendor id is %s", sub_ind->data.serial_number.vendor_id); |
| 1359 | //ASFVOLT_LOG(ASFVOLT_ERROR, "ONU Activation:Before decoding:Vendor specific is %s", sub_ind->data.serial_number.vendor_specific); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1360 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1361 | char *vendor_id = malloc(sizeof(char)*MAX_CHAR_LENGTH); |
| 1362 | memset(vendor_id, 0, MAX_CHAR_LENGTH); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1363 | sprintf(vendor_id,"%c%c%c%c", |
| 1364 | sub_ind->data.serial_number.vendor_id[0], |
| 1365 | sub_ind->data.serial_number.vendor_id[1], |
| 1366 | sub_ind->data.serial_number.vendor_id[2], |
| 1367 | sub_ind->data.serial_number.vendor_id[3]); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1368 | balIndCfg->terminal_ind->data->serial_number->vendor_id = vendor_id; |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1369 | ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Activation:After decoding:Vendor id is %s", balIndCfg->terminal_ind->data->serial_number->vendor_id); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1370 | char *vendor_specific = malloc(sizeof(char)*MAX_CHAR_LENGTH); |
| 1371 | memset(vendor_specific, 0, MAX_CHAR_LENGTH); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1372 | sprintf(vendor_specific,"%1X%1X%1X%1X%1X%1X%1X%1X", |
| 1373 | sub_ind->data.serial_number.vendor_specific[0]>>4 & 0x0f, |
| 1374 | sub_ind->data.serial_number.vendor_specific[0] & 0x0f, |
| 1375 | sub_ind->data.serial_number.vendor_specific[1]>>4 & 0x0f, |
| 1376 | sub_ind->data.serial_number.vendor_specific[1] & 0x0f, |
| 1377 | sub_ind->data.serial_number.vendor_specific[2]>>4 & 0x0f, |
| 1378 | sub_ind->data.serial_number.vendor_specific[2] & 0x0f, |
| 1379 | sub_ind->data.serial_number.vendor_specific[3]>>4 & 0x0f, |
| 1380 | sub_ind->data.serial_number.vendor_specific[3] & 0x0f); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1381 | balIndCfg->terminal_ind->data->serial_number->vendor_specific = vendor_specific; |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1382 | ASFVOLT_LOG(ASFVOLT_DEBUG, "ONU Activation:After decoding:Vendor specific is %s", balIndCfg->terminal_ind->data->serial_number->vendor_specific); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1383 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1384 | BalIdList *balAggportList; |
| 1385 | balAggportList = malloc(sizeof(BalIdList)); |
| 1386 | memset(balAggportList, 0, sizeof(BalIdList)); |
| 1387 | bal_id_list__init(balAggportList); |
| 1388 | balIndCfg->terminal_ind->data->agg_port_id_list = balAggportList; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1389 | |
| 1390 | #if 0 |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1391 | balIndCfg->terminal_ind->data->agg_port_id_list->n_val = sub_ind->data.agg_port_id_list.len; |
| 1392 | uint32_t agg_port_id_list[balIndCfg->terminal_ind->data->agg_port_id_list->n_val]; |
| 1393 | memset(&agg_port_id_list, 0, balIndCfg->terminal_ind->data->agg_port_id_list->n_val); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1394 | strcpy((char *)agg_port_id_list,(const char *)sub_ind->data.agg_port_id_list.val); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1395 | balIndCfg->terminal_ind->data->agg_port_id_list->val = agg_port_id_list; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1396 | #endif |
| 1397 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1398 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1399 | bal_indication_node->bal_indication = balIndCfg; |
| 1400 | |
| 1401 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1402 | add_bal_indication_node(bal_indication_node); |
| 1403 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1404 | } |
| 1405 | |
| 1406 | return result; |
| 1407 | } |
| 1408 | |
| 1409 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1410 | * Function : fill_bal_tm_red * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1411 | * Description : This function will fill grpc-BalTmred struture * |
| 1412 | * from bal-bcmbal_tm_red structure * |
| 1413 | * * |
| 1414 | ********************************************************************/ |
| 1415 | void fill_bal_tm_red(BalTmred *grpc_red, bcmbal_tm_red *bal_red) |
| 1416 | { |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1417 | grpc_red->has_min_threshold = BAL_GRPC_PRES; |
| 1418 | grpc_red->min_threshold = bal_red->min_threshold; |
| 1419 | grpc_red->has_max_threshold = BAL_GRPC_PRES; |
| 1420 | grpc_red->max_threshold = bal_red->max_threshold; |
| 1421 | grpc_red->has_max_probability = BAL_GRPC_PRES; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1422 | grpc_red->max_probability = bal_red->max_probability; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1423 | return; |
| 1424 | } |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1425 | |
| 1426 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1427 | * Function : bal_tm_queue_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1428 | * Description : This function will handle the indications for * |
| 1429 | * TM Queue indication * |
| 1430 | * * |
| 1431 | ********************************************************************/ |
| 1432 | bcmos_errno bal_tm_queue_indication_cb(bcmbal_obj *obj) |
| 1433 | { |
| 1434 | bcmos_errno result = BCM_ERR_OK; |
| 1435 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1436 | if(BCMBAL_OBJ_ID_TM_QUEUE != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1437 | bcmbal_tm_queue_auto_id_ind != obj->subgroup) |
| 1438 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1439 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1440 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1441 | result = BCM_ERR_INTERNAL; |
| 1442 | } |
| 1443 | else |
| 1444 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1445 | BalIndications *balIndCfg; |
| 1446 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1447 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1448 | bal_indications__init(balIndCfg); |
| 1449 | balIndCfg->u_case = BAL_INDICATIONS__U_TM_QUEUE__IND; |
| 1450 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1451 | balIndCfg->objtype = obj->obj_type; |
| 1452 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1453 | balIndCfg->sub_group = obj->subgroup; |
| 1454 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1455 | |
| 1456 | bcmbal_tm_queue_ind *tm_que_ind = (bcmbal_tm_queue_ind *)obj; |
| 1457 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1458 | BalTmQueueInd *tmQueInd; |
| 1459 | tmQueInd = malloc(sizeof(BalTmQueueInd)); |
| 1460 | memset(tmQueInd, 0, sizeof(BalTmQueueInd)); |
| 1461 | bal_tm_queue_ind__init(tmQueInd); |
| 1462 | balIndCfg->tm_queue_ind = tmQueInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1463 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1464 | BalTmQueueKey *tmQkey; |
| 1465 | tmQkey = malloc(sizeof(BalTmQueueKey)); |
| 1466 | memset(tmQkey, 0, sizeof(BalTmQueueKey)); |
| 1467 | bal_tm_queue_key__init(tmQkey); |
| 1468 | balIndCfg->tm_queue_ind->key = tmQkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1469 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1470 | balIndCfg->tm_queue_ind->key->has_sched_id = BAL_GRPC_PRES; |
| 1471 | balIndCfg->tm_queue_ind->key->sched_id = tm_que_ind->key.sched_id; |
| 1472 | balIndCfg->tm_queue_ind->key->has_sched_dir = BAL_GRPC_PRES; |
| 1473 | balIndCfg->tm_queue_ind->key->sched_dir = tm_que_ind->key.sched_dir; |
| 1474 | balIndCfg->tm_queue_ind->key->has_id = BAL_GRPC_PRES; |
| 1475 | balIndCfg->tm_queue_ind->key->id = tm_que_ind->key.id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1476 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1477 | BalTmQueueIndData *tmQIndData; |
| 1478 | tmQIndData = malloc(sizeof(BalTmQueueIndData)); |
| 1479 | memset(tmQIndData, 0, sizeof(BalTmQueueIndData)); |
| 1480 | bal_tm_queue_ind_data__init(tmQIndData); |
| 1481 | balIndCfg->tm_queue_ind->data = tmQIndData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1482 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1483 | balIndCfg->tm_queue_ind->data->has_priority = BAL_GRPC_PRES; |
| 1484 | balIndCfg->tm_queue_ind->data->priority = tm_que_ind->data.priority; |
| 1485 | balIndCfg->tm_queue_ind->data->has_weight = BAL_GRPC_PRES; |
| 1486 | balIndCfg->tm_queue_ind->data->weight = tm_que_ind->data.weight; |
| 1487 | balIndCfg->tm_queue_ind->data->has_create_mode = BAL_GRPC_PRES; |
| 1488 | balIndCfg->tm_queue_ind->data->create_mode = tm_que_ind->data.create_mode; |
| 1489 | balIndCfg->tm_queue_ind->data->has_ref_count = BAL_GRPC_PRES; |
| 1490 | balIndCfg->tm_queue_ind->data->ref_count = tm_que_ind->data.ref_count; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1491 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1492 | BalTmShaping *balShape; |
| 1493 | balShape = malloc(sizeof(BalTmShaping)); |
| 1494 | memset(balShape, 0, sizeof(BalTmShaping)); |
| 1495 | bal_tm_shaping__init(balShape); |
| 1496 | balIndCfg->tm_queue_ind->data->rate = balShape; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1497 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1498 | balIndCfg->tm_queue_ind->data->rate->has_presence_mask = BAL_GRPC_PRES; |
| 1499 | balIndCfg->tm_queue_ind->data->rate->presence_mask = tm_que_ind->data.rate.presence_mask; |
| 1500 | balIndCfg->tm_queue_ind->data->rate->has_cir = BAL_GRPC_PRES; |
| 1501 | balIndCfg->tm_queue_ind->data->rate->cir = tm_que_ind->data.rate.cir; |
| 1502 | balIndCfg->tm_queue_ind->data->rate->has_pir = BAL_GRPC_PRES; |
| 1503 | balIndCfg->tm_queue_ind->data->rate->pir = tm_que_ind->data.rate.pir; |
| 1504 | balIndCfg->tm_queue_ind->data->rate->has_burst = BAL_GRPC_PRES; |
| 1505 | balIndCfg->tm_queue_ind->data->rate->burst = tm_que_ind->data.rate.burst; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1506 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1507 | BalTmBac *balBac; |
| 1508 | balBac = malloc(sizeof(BalTmBac)); |
| 1509 | memset(balBac, 0, sizeof(BalTmBac)); |
| 1510 | bal_tm_bac__init(balBac); |
| 1511 | balIndCfg->tm_queue_ind->data->bac = balBac; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1512 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1513 | balIndCfg->tm_queue_ind->data->bac->has_type = BAL_GRPC_PRES; |
| 1514 | balIndCfg->tm_queue_ind->data->bac->type = tm_que_ind->data.bac.type; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1515 | switch(tm_que_ind->data.bac.type) |
| 1516 | { |
| 1517 | case BCMBAL_TM_BAC_TYPE_TAILDROP: |
| 1518 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1519 | balIndCfg->tm_queue_ind->data->bac->u_case = BAL_TM_BAC__U_TAILDROP; |
| 1520 | BalTMBacTaildrop *balTaildrop; |
| 1521 | balTaildrop = malloc(sizeof(BalTMBacTaildrop)); |
| 1522 | memset(balTaildrop, 0, sizeof(BalTMBacTaildrop)); |
| 1523 | bal_tmbac_taildrop__init(balTaildrop); |
| 1524 | balIndCfg->tm_queue_ind->data->bac->taildrop = balTaildrop; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1525 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1526 | balIndCfg->tm_queue_ind->data->bac->taildrop->has_max_size = BAL_GRPC_PRES; |
| 1527 | balIndCfg->tm_queue_ind->data->bac->taildrop->max_size = |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1528 | tm_que_ind->data.bac.u.taildrop.max_size; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1529 | } |
| 1530 | break; |
| 1531 | case BCMBAL_TM_BAC_TYPE_WTAILDROP: |
| 1532 | { |
| 1533 | /* No bal/grpc structure was defined */ |
| 1534 | } |
| 1535 | break; |
| 1536 | case BCMBAL_TM_BAC_TYPE_RED: |
| 1537 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1538 | balIndCfg->tm_queue_ind->data->bac->u_case = BAL_TM_BAC__U_RED; |
| 1539 | BalTMBacRed *balBacRed; |
| 1540 | balBacRed = malloc(sizeof(BalTMBacRed)); |
| 1541 | memset(balBacRed, 0, sizeof(BalTMBacRed)); |
| 1542 | bal_tmbac_red__init(balBacRed); |
| 1543 | balIndCfg->tm_queue_ind->data->bac->red = balBacRed; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1544 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1545 | BalTmred *balRed; |
| 1546 | balRed = malloc(sizeof(BalTmred)); |
| 1547 | memset(balRed, 0, sizeof(BalTmred)); |
| 1548 | bal_tmred__init(balRed); |
| 1549 | balIndCfg->tm_queue_ind->data->bac->red->red = balRed; |
| 1550 | fill_bal_tm_red(balIndCfg->tm_queue_ind->data->bac->red->red, &tm_que_ind->data.bac.u.red.red); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1551 | } |
| 1552 | break; |
| 1553 | case BCMBAL_TM_BAC_TYPE_WRED: |
| 1554 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1555 | balIndCfg->tm_queue_ind->data->bac->u_case = BAL_TM_BAC__U_WRED; |
| 1556 | BalTMBacWred *balBacWred; |
| 1557 | balBacWred = malloc(sizeof(BalTMBacWred)); |
| 1558 | memset(balBacWred, 0, sizeof(BalTMBacWred)); |
| 1559 | bal_tmbac_wred__init(balBacWred); |
| 1560 | balIndCfg->tm_queue_ind->data->bac->wred = balBacWred; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1561 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1562 | BalTmred *balGreen; |
| 1563 | balGreen = malloc(sizeof(BalTmred)); |
| 1564 | memset(balGreen, 0, sizeof(BalTmred)); |
| 1565 | bal_tmred__init(balGreen); |
| 1566 | balIndCfg->tm_queue_ind->data->bac->wred->green = balGreen; |
| 1567 | fill_bal_tm_red(balIndCfg->tm_queue_ind->data->bac->wred->green, &tm_que_ind->data.bac.u.wred.green); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1568 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1569 | BalTmred *balYellow; |
| 1570 | balYellow = malloc(sizeof(BalTmred)); |
| 1571 | memset(balYellow, 0, sizeof(BalTmred)); |
| 1572 | bal_tmred__init(balYellow); |
| 1573 | balIndCfg->tm_queue_ind->data->bac->wred->yellow = balYellow; |
| 1574 | fill_bal_tm_red(balIndCfg->tm_queue_ind->data->bac->wred->yellow, &tm_que_ind->data.bac.u.wred.yellow); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1575 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1576 | BalTmred *balRed; |
| 1577 | balRed = malloc(sizeof(BalTmred)); |
| 1578 | memset(balRed, 0, sizeof(BalTmred)); |
| 1579 | bal_tmred__init(balRed); |
| 1580 | balIndCfg->tm_queue_ind->data->bac->wred->red = balRed; |
| 1581 | fill_bal_tm_red(balIndCfg->tm_queue_ind->data->bac->wred->red, &tm_que_ind->data.bac.u.wred.red); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1582 | } |
| 1583 | break; |
| 1584 | default: |
| 1585 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1586 | balIndCfg->tm_queue_ind->data->bac->u_case = BAL_TM_BAC__U__NOT_SET; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1587 | } |
| 1588 | break; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1589 | |
| 1590 | } |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1591 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1592 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1593 | bal_indication_node->bal_indication = balIndCfg; |
| 1594 | |
| 1595 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1596 | add_bal_indication_node(bal_indication_node); |
| 1597 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1598 | } |
| 1599 | |
| 1600 | return result; |
| 1601 | } |
| 1602 | |
| 1603 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1604 | * Function : bal_tm_sched_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1605 | * Description : This function will handle the indications for * |
| 1606 | * TM Sched indication * |
| 1607 | * * |
| 1608 | ********************************************************************/ |
| 1609 | bcmos_errno bal_tm_sched_indication_cb(bcmbal_obj *obj) |
| 1610 | { |
| 1611 | bcmos_errno result = BCM_ERR_OK; |
| 1612 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1613 | if(BCMBAL_OBJ_ID_TM_SCHED != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1614 | bcmbal_tm_sched_auto_id_ind != obj->subgroup) |
| 1615 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1616 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1617 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1618 | result = BCM_ERR_INTERNAL; |
| 1619 | } |
| 1620 | else |
| 1621 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1622 | BalIndications *balIndCfg; |
| 1623 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1624 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1625 | bal_indications__init(balIndCfg); |
| 1626 | balIndCfg->u_case = BAL_INDICATIONS__U_TM_SCHED__IND; |
| 1627 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1628 | balIndCfg->objtype = obj->obj_type; |
| 1629 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1630 | balIndCfg->sub_group = obj->subgroup; |
| 1631 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1632 | |
| 1633 | bcmbal_tm_sched_ind *tm_sched_ind = (bcmbal_tm_sched_ind *)obj; |
| 1634 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1635 | BalTmSchedInd *tmSchedInd; |
| 1636 | tmSchedInd = malloc(sizeof(BalTmSchedInd)); |
| 1637 | memset(tmSchedInd, 0, sizeof(BalTmSchedInd)); |
| 1638 | bal_tm_sched_ind__init(tmSchedInd); |
| 1639 | balIndCfg->tm_sched_ind = tmSchedInd; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1640 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1641 | BalTmSchedKey *tmSchedkey; |
| 1642 | tmSchedkey = malloc(sizeof(BalTmSchedKey)); |
| 1643 | memset(tmSchedkey, 0, sizeof(BalTmSchedKey)); |
| 1644 | bal_tm_sched_key__init(tmSchedkey); |
| 1645 | balIndCfg->tm_sched_ind->key = tmSchedkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1646 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1647 | balIndCfg->tm_sched_ind->key->has_dir = BAL_GRPC_PRES; |
| 1648 | balIndCfg->tm_sched_ind->key->dir = tm_sched_ind->key.dir; |
| 1649 | balIndCfg->tm_sched_ind->key->has_id = BAL_GRPC_PRES; |
| 1650 | balIndCfg->tm_sched_ind->key->id = tm_sched_ind->key.id; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1651 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1652 | BalTmSchedIndData *tmSIndData; |
| 1653 | tmSIndData = malloc(sizeof(BalTmSchedIndData)); |
| 1654 | memset(tmSIndData, 0, sizeof(BalTmSchedIndData)); |
| 1655 | bal_tm_sched_ind_data__init(tmSIndData); |
| 1656 | balIndCfg->tm_sched_ind->data = tmSIndData; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1657 | /* TODO: data should be populate */ |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1658 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1659 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1660 | bal_indication_node->bal_indication = balIndCfg; |
| 1661 | |
| 1662 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1663 | add_bal_indication_node(bal_indication_node); |
| 1664 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1665 | } |
| 1666 | |
| 1667 | return result; |
| 1668 | } |
| 1669 | |
| 1670 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1671 | * Function : bal_packet_data_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1672 | * Description : This function will handle the indications for * |
| 1673 | * Packet Data indication * |
| 1674 | * * |
| 1675 | ********************************************************************/ |
| 1676 | bcmos_errno bal_packet_data_indication_cb(bcmbal_obj *obj) |
| 1677 | { |
| 1678 | bcmos_errno result = BCM_ERR_OK; |
| 1679 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1680 | if(BCMBAL_OBJ_ID_PACKET != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1681 | bcmbal_packet_auto_id_bearer_channel_rx != obj->subgroup) |
| 1682 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1683 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1684 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1685 | result = BCM_ERR_INTERNAL; |
| 1686 | } |
| 1687 | else |
| 1688 | { |
| 1689 | /*bcmos_mutex_lock(&bal_ind_lock);-- Need to define bcm independent mutex*/ |
| 1690 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1691 | BalIndications *balIndCfg; |
| 1692 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1693 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1694 | bal_indications__init(balIndCfg); |
| 1695 | balIndCfg->u_case = BAL_INDICATIONS__U_PKT_DATA; |
| 1696 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1697 | balIndCfg->objtype = obj->obj_type; |
| 1698 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1699 | balIndCfg->sub_group = obj->subgroup; |
| 1700 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1701 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1702 | BalPacketBearerChannelRx *rxChannel; |
| 1703 | rxChannel = malloc(sizeof(BalPacketBearerChannelRx)); |
| 1704 | memset(rxChannel, 0, sizeof(BalPacketBearerChannelRx)); |
| 1705 | bal_packet_bearer_channel_rx__init(rxChannel); |
| 1706 | balIndCfg->pktdata = rxChannel; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1707 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1708 | BalObj *hdr; |
| 1709 | hdr = malloc(sizeof(BalObj)); |
| 1710 | memset(hdr, 0, sizeof(BalObj)); |
| 1711 | bal_obj__init(hdr); |
| 1712 | balIndCfg->pktdata->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1713 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1714 | BalPacketKey *packetkey; |
| 1715 | packetkey = malloc(sizeof(BalPacketKey)); |
| 1716 | memset(packetkey, 0, sizeof(BalPacketKey)); |
| 1717 | bal_packet_key__init(packetkey); |
| 1718 | balIndCfg->pktdata->key = packetkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1719 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1720 | bcmbal_packet_bearer_channel_rx *rx_channel = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1721 | (bcmbal_packet_bearer_channel_rx *)obj; |
| 1722 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1723 | balIndCfg->pktdata->key->has_reserved = BAL_GRPC_PRES; |
| 1724 | balIndCfg->pktdata->key->reserved = rx_channel->key.reserved; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1725 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1726 | BalDest *PktSndDest; |
| 1727 | PktSndDest = malloc(sizeof(BalDest)); |
| 1728 | memset(PktSndDest, 0, sizeof(BalDest)); |
| 1729 | bal_dest__init(PktSndDest); |
| 1730 | balIndCfg->pktdata->key->packet_send_dest = PktSndDest; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1731 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1732 | balIndCfg->pktdata->key->packet_send_dest->has_type = BAL_GRPC_PRES; |
| 1733 | balIndCfg->pktdata->key->packet_send_dest->type = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1734 | rx_channel->key.packet_send_dest.type; |
| 1735 | switch( rx_channel->key.packet_send_dest.type) |
| 1736 | { |
| 1737 | case BCMBAL_DEST_TYPE_NNI: |
| 1738 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1739 | balIndCfg->pktdata->key->packet_send_dest->u_case = BAL_DEST__U_NNI; |
| 1740 | BalDestNni *balNni; |
| 1741 | balNni = malloc(sizeof(BalDestNni)); |
| 1742 | memset(balNni, 0, sizeof(BalDestNni)); |
| 1743 | bal_dest_nni__init(balNni); |
| 1744 | balIndCfg->pktdata->key->packet_send_dest->nni = balNni; |
| 1745 | balIndCfg->pktdata->key->packet_send_dest->nni->has_intf_id = BAL_GRPC_PRES; |
| 1746 | balIndCfg->pktdata->key->packet_send_dest->nni->intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1747 | rx_channel->key.packet_send_dest.u.nni.intf_id; |
| 1748 | } |
| 1749 | break; |
| 1750 | case BCMBAL_DEST_TYPE_SUB_TERM: |
| 1751 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1752 | balIndCfg->pktdata->key->packet_send_dest->u_case = BAL_DEST__U_SUB_TERM; |
| 1753 | BalDestSubTerm *balSubTerm; |
| 1754 | balSubTerm = malloc(sizeof(BalDestSubTerm)); |
| 1755 | memset(balSubTerm, 0, sizeof(BalDestSubTerm)); |
| 1756 | bal_dest_sub_term__init(balSubTerm); |
| 1757 | balIndCfg->pktdata->key->packet_send_dest->sub_term = balSubTerm; |
| 1758 | balIndCfg->pktdata->key->packet_send_dest->sub_term->has_sub_term_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1759 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1760 | balIndCfg->pktdata->key->packet_send_dest->sub_term->sub_term_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1761 | rx_channel->key.packet_send_dest.u.sub_term.sub_term_id; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1762 | balIndCfg->pktdata->key->packet_send_dest->sub_term->has_sub_term_uni = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1763 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1764 | balIndCfg->pktdata->key->packet_send_dest->sub_term->sub_term_uni = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1765 | rx_channel->key.packet_send_dest.u.sub_term.sub_term_uni; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1766 | balIndCfg->pktdata->key->packet_send_dest->sub_term->has_intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1767 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1768 | balIndCfg->pktdata->key->packet_send_dest->sub_term->intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1769 | rx_channel->key.packet_send_dest.u.sub_term.intf_id; |
| 1770 | } |
| 1771 | break; |
| 1772 | case BCMBAL_DEST_TYPE_SVC_PORT: |
| 1773 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1774 | balIndCfg->pktdata->key->packet_send_dest->u_case = BAL_DEST__U_SVC_PORT; |
| 1775 | BalDestSvcPort *balSvcPort; |
| 1776 | balSvcPort = malloc(sizeof(BalDestSvcPort)); |
| 1777 | memset(balSvcPort, 0, sizeof(BalDestSvcPort)); |
| 1778 | bal_dest_svc_port__init(balSvcPort); |
| 1779 | balIndCfg->pktdata->key->packet_send_dest->svc_port = balSvcPort; |
| 1780 | balIndCfg->pktdata->key->packet_send_dest->svc_port->has_svc_port_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1781 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1782 | balIndCfg->pktdata->key->packet_send_dest->svc_port->svc_port_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1783 | rx_channel->key.packet_send_dest.u.svc_port.svc_port_id; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1784 | balIndCfg->pktdata->key->packet_send_dest->svc_port->has_intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1785 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1786 | balIndCfg->pktdata->key->packet_send_dest->svc_port->has_intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1787 | rx_channel->key.packet_send_dest.u.svc_port.intf_id; |
| 1788 | } |
| 1789 | break; |
| 1790 | default: |
| 1791 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1792 | balIndCfg->pktdata->key->packet_send_dest->u_case = BAL_DEST__U__NOT_SET; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1793 | } |
| 1794 | break; |
| 1795 | } |
| 1796 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1797 | BalPacketBearerChannelRxData *pkdData; |
| 1798 | pkdData = malloc(sizeof(BalPacketBearerChannelRxData)); |
| 1799 | memset(pkdData, 0, sizeof(BalPacketBearerChannelRxData)); |
| 1800 | bal_packet_bearer_channel_rx_data__init(pkdData); |
| 1801 | balIndCfg->pktdata->data = pkdData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1802 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1803 | balIndCfg->pktdata->data->has_flow_id = BAL_GRPC_PRES; |
| 1804 | balIndCfg->pktdata->data->flow_id = rx_channel->data.flow_id; |
| 1805 | balIndCfg->pktdata->data->has_flow_type = BAL_GRPC_PRES; |
| 1806 | balIndCfg->pktdata->data->flow_type = rx_channel->data.flow_type; |
| 1807 | balIndCfg->pktdata->data->has_intf_id = BAL_GRPC_PRES; |
| 1808 | balIndCfg->pktdata->data->intf_id = rx_channel->data.intf_id; |
| 1809 | balIndCfg->pktdata->data->has_intf_type = BAL_GRPC_PRES; |
| 1810 | balIndCfg->pktdata->data->intf_type = rx_channel->data.intf_type; |
| 1811 | balIndCfg->pktdata->data->has_svc_port = BAL_GRPC_PRES; |
| 1812 | balIndCfg->pktdata->data->svc_port = rx_channel->data.svc_port; |
| 1813 | balIndCfg->pktdata->data->has_flow_cookie = BAL_GRPC_PRES; |
| 1814 | balIndCfg->pktdata->data->flow_cookie = rx_channel->data.flow_cookie; |
| 1815 | balIndCfg->pktdata->data->has_pkt = BAL_GRPC_PRES; |
| 1816 | balIndCfg->pktdata->data->pkt.len = rx_channel->data.pkt.len; |
| 1817 | balIndCfg->pktdata->data->pkt.data = (uint8_t *)malloc((balIndCfg->pktdata->data->pkt.len)*sizeof(uint8_t)); |
| 1818 | memcpy(balIndCfg->pktdata->data->pkt.data, rx_channel->data.pkt.val, balIndCfg->pktdata->data->pkt.len); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1819 | |
| 1820 | /*bcmos_mutex_unlock(&bal_ind_lock);-- Need to define bcm independent mutex*/ |
| 1821 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1822 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1823 | bal_indication_node->bal_indication = balIndCfg; |
| 1824 | |
| 1825 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1826 | add_bal_indication_node(bal_indication_node); |
| 1827 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1828 | } |
| 1829 | |
| 1830 | return result; |
| 1831 | } |
| 1832 | |
| 1833 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1834 | * Function : bal_omci_data_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1835 | * Description : This function will handle the indications for * |
| 1836 | * OMCI Data Response * |
| 1837 | * * |
| 1838 | ********************************************************************/ |
| 1839 | bcmos_errno bal_omci_data_indication_cb(bcmbal_obj *obj) |
| 1840 | { |
| 1841 | bcmos_errno result = BCM_ERR_OK; |
| 1842 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1843 | if(BCMBAL_OBJ_ID_PACKET != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1844 | bcmbal_packet_auto_id_itu_omci_channel_rx != obj->subgroup) |
| 1845 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1846 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1847 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1848 | result = BCM_ERR_INTERNAL; |
| 1849 | } |
| 1850 | else |
| 1851 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1852 | ASFVOLT_LOG(ASFVOLT_DEBUG, "Received OMCI response via BAL APIs"); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1853 | BalIndications *balIndCfg; |
| 1854 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1855 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1856 | bal_indications__init(balIndCfg); |
| 1857 | balIndCfg->u_case = BAL_INDICATIONS__U_BAL_OMCI_RESP; |
| 1858 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1859 | balIndCfg->objtype = obj->obj_type; |
| 1860 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1861 | balIndCfg->sub_group = obj->subgroup; |
| 1862 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1863 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1864 | BalPacketItuOmciChannelRx *omciChannel; |
| 1865 | omciChannel = malloc(sizeof(BalPacketItuOmciChannelRx)); |
| 1866 | memset(omciChannel, 0, sizeof(BalPacketItuOmciChannelRx)); |
| 1867 | bal_packet_itu_omci_channel_rx__init(omciChannel); |
| 1868 | balIndCfg->balomciresp = omciChannel; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1869 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1870 | BalObj *hdr; |
| 1871 | hdr = malloc(sizeof(BalObj)); |
| 1872 | memset(hdr, 0, sizeof(BalObj)); |
| 1873 | bal_obj__init(hdr); |
| 1874 | balIndCfg->balomciresp->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1875 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1876 | BalPacketKey *packetkey; |
| 1877 | packetkey = malloc(sizeof(BalPacketKey)); |
| 1878 | memset(packetkey, 0, sizeof(BalPacketKey)); |
| 1879 | bal_packet_key__init(packetkey); |
| 1880 | balIndCfg->balomciresp->key = packetkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1881 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1882 | BalPacketItuOmciChannelRxData *omciData; |
| 1883 | omciData = malloc(sizeof(BalPacketItuOmciChannelRxData)); |
| 1884 | memset(omciData, 0, sizeof(BalPacketItuOmciChannelRxData)); |
| 1885 | bal_packet_itu_omci_channel_rx_data__init(omciData); |
| 1886 | balIndCfg->balomciresp->data = omciData; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1887 | |
| 1888 | bcmbal_packet_itu_omci_channel_rx *omci_channel = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1889 | (bcmbal_packet_itu_omci_channel_rx *)obj; |
| 1890 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1891 | balIndCfg->balomciresp->data->has_pkt = BAL_GRPC_PRES; |
| 1892 | balIndCfg->balomciresp->data->pkt.len = omci_channel->data.pkt.len; |
| 1893 | balIndCfg->balomciresp->data->pkt.data = (uint8_t *)malloc((omci_channel->data.pkt.len)*sizeof(uint8_t)); |
| 1894 | memcpy(balIndCfg->balomciresp->data->pkt.data, omci_channel->data.pkt.val, |
| 1895 | balIndCfg->balomciresp->data->pkt.len); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1896 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1897 | balIndCfg->balomciresp->key->has_reserved = BAL_GRPC_PRES; |
| 1898 | balIndCfg->balomciresp->key->reserved = omci_channel->key.reserved; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1899 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1900 | BalDest *PktSndDest; |
| 1901 | PktSndDest = malloc(sizeof(BalDest)); |
| 1902 | memset(PktSndDest, 0, sizeof(BalDest)); |
| 1903 | bal_dest__init(PktSndDest); |
| 1904 | balIndCfg->balomciresp->key->packet_send_dest = PktSndDest; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1905 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1906 | balIndCfg->balomciresp->key->packet_send_dest->has_type = BAL_GRPC_PRES; |
| 1907 | balIndCfg->balomciresp->key->packet_send_dest->type = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1908 | omci_channel->key.packet_send_dest.type; |
| 1909 | switch( omci_channel->key.packet_send_dest.type) |
| 1910 | { |
| 1911 | case BCMBAL_DEST_TYPE_ITU_OMCI_CHANNEL: |
| 1912 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1913 | balIndCfg->balomciresp->key->packet_send_dest->u_case = BAL_DEST__U_ITU_OMCI_CHANNEL; |
| 1914 | BalItuOmciChannel *balOmci; |
| 1915 | balOmci = malloc(sizeof(BalItuOmciChannel)); |
| 1916 | memset(balOmci, 0, sizeof(BalItuOmciChannel)); |
| 1917 | bal_itu_omci_channel__init(balOmci); |
| 1918 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel = balOmci; |
| 1919 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->has_sub_term_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1920 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1921 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->sub_term_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1922 | omci_channel->key.packet_send_dest.u.itu_omci_channel.sub_term_id; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1923 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->has_intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1924 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1925 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1926 | omci_channel->key.packet_send_dest.u.itu_omci_channel.intf_id; |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1927 | ASFVOLT_LOG(ASFVOLT_DEBUG, "OMCI Response for ONU id %d", |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1928 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->sub_term_id); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1929 | } |
| 1930 | break; |
| 1931 | default: |
| 1932 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1933 | balIndCfg->balomciresp->key->packet_send_dest->u_case = BAL_DEST__U__NOT_SET; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1934 | } |
| 1935 | break; |
| 1936 | } |
| 1937 | |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1938 | ASFVOLT_HEX2LOG(ASFVOLT_DEBUG, "OMCI Response with %zd bytes is ", |
| 1939 | balIndCfg->balomciresp->data->pkt.data, balIndCfg->balomciresp->data->pkt.len); |
| 1940 | |
| 1941 | ASFVOLT_LOG(ASFVOLT_DEBUG, "OMCI Response for ONU id %d", |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1942 | balIndCfg->balomciresp->key->packet_send_dest->itu_omci_channel->sub_term_id); |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1943 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1944 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 1945 | bal_indication_node->bal_indication = balIndCfg; |
| 1946 | |
| 1947 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 1948 | add_bal_indication_node(bal_indication_node); |
| 1949 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1950 | } |
| 1951 | |
| 1952 | return result; |
| 1953 | } |
| 1954 | |
| 1955 | /********************************************************************\ |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1956 | * Function : bal_oam_data_indication_cb * |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1957 | * Description : This function will handle the indications for * |
| 1958 | * OAM Data Response * |
| 1959 | * * |
| 1960 | ********************************************************************/ |
| 1961 | bcmos_errno bal_oam_data_indication_cb(bcmbal_obj *obj) |
| 1962 | { |
| 1963 | bcmos_errno result = BCM_ERR_OK; |
| 1964 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1965 | if(BCMBAL_OBJ_ID_PACKET != obj->obj_type || |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1966 | bcmbal_packet_auto_id_ieee_oam_channel_rx != obj->subgroup) |
| 1967 | { |
Kim Kempf | afa1ab4 | 2017-11-13 09:31:47 -0800 | [diff] [blame] | 1968 | ASFVOLT_LOG(ASFVOLT_ERROR, "Processing BAL API '%s' IND callback (status is %s)", |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1969 | bcmbal_objtype_str(obj->obj_type), bcmos_strerror(obj->status)); |
| 1970 | result = BCM_ERR_INTERNAL; |
| 1971 | } |
| 1972 | else |
| 1973 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1974 | BalIndications *balIndCfg; |
| 1975 | balIndCfg = malloc(sizeof(BalIndications)); |
| 1976 | memset(balIndCfg, 0, sizeof(BalIndications)); |
| 1977 | bal_indications__init(balIndCfg); |
| 1978 | balIndCfg->u_case = BAL_INDICATIONS__U_BAL_OAM_RESP; |
| 1979 | balIndCfg->has_objtype = BAL_GRPC_PRES; |
| 1980 | balIndCfg->objtype = obj->obj_type; |
| 1981 | balIndCfg->has_sub_group = BAL_GRPC_PRES; |
| 1982 | balIndCfg->sub_group = obj->subgroup; |
| 1983 | balIndCfg->device_id = voltha_device_id; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1984 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1985 | BalPacketIeeeOamChannelRx *oamChannel; |
| 1986 | oamChannel = malloc(sizeof(BalPacketIeeeOamChannelRx)); |
| 1987 | memset(oamChannel, 0, sizeof(BalPacketIeeeOamChannelRx)); |
| 1988 | bal_packet_ieee_oam_channel_rx__init(oamChannel); |
| 1989 | balIndCfg->baloamresp = oamChannel; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 1990 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1991 | BalObj *hdr; |
| 1992 | hdr = malloc(sizeof(BalObj)); |
| 1993 | memset(hdr, 0, sizeof(BalObj)); |
| 1994 | bal_obj__init(hdr); |
| 1995 | balIndCfg->baloamresp->hdr = hdr; |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 1996 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 1997 | BalPacketKey *packetkey; |
| 1998 | packetkey = malloc(sizeof(BalPacketKey)); |
| 1999 | memset(packetkey, 0, sizeof(BalPacketKey)); |
| 2000 | bal_packet_key__init(packetkey); |
| 2001 | balIndCfg->baloamresp->key = packetkey; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2002 | |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 2003 | bcmbal_packet_ieee_oam_channel_rx *oam_channel = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2004 | (bcmbal_packet_ieee_oam_channel_rx *)obj; |
| 2005 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2006 | balIndCfg->baloamresp->key->has_reserved = BAL_GRPC_PRES; |
| 2007 | balIndCfg->baloamresp->key->reserved = oam_channel->key.reserved; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2008 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2009 | BalDest *PktSndDest; |
| 2010 | PktSndDest = malloc(sizeof(BalDest)); |
| 2011 | memset(PktSndDest, 0, sizeof(BalDest)); |
| 2012 | bal_dest__init(PktSndDest); |
| 2013 | balIndCfg->baloamresp->key->packet_send_dest = PktSndDest; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2014 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2015 | balIndCfg->baloamresp->key->packet_send_dest->has_type = BAL_GRPC_PRES; |
| 2016 | balIndCfg->baloamresp->key->packet_send_dest->type = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2017 | oam_channel->key.packet_send_dest.type; |
| 2018 | switch( oam_channel->key.packet_send_dest.type) |
| 2019 | { |
| 2020 | case BCMBAL_DEST_TYPE_IEEE_OAM_CHANNEL: |
| 2021 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2022 | balIndCfg->baloamresp->key->packet_send_dest->u_case = BAL_DEST__U_IEEE_OAM_CHANNEL; |
| 2023 | BalIeeeOamChannel *balOam; |
| 2024 | balOam = malloc(sizeof(BalIeeeOamChannel)); |
| 2025 | memset(balOam, 0, sizeof(BalIeeeOamChannel)); |
| 2026 | bal_ieee_oam_channel__init(balOam); |
| 2027 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel = balOam; |
| 2028 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->has_intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2029 | BAL_GRPC_PRES; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2030 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->intf_id = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2031 | oam_channel->key.packet_send_dest.u.ieee_oam_channel.intf_id; |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2032 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->has_mac_address = BAL_GRPC_PRES; |
| 2033 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->mac_address.len = |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2034 | (BCMOS_ETH_ALEN)*sizeof(oam_channel->key.packet_send_dest.u.ieee_oam_channel.mac_address.u8); |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2035 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->mac_address.data = |
| 2036 | (uint8_t *)malloc((balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->mac_address.len)*sizeof(uint8_t)); |
| 2037 | memcpy(balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->mac_address.data, |
Rajeswara Rao | b2e441c | 2017-09-20 16:40:21 +0530 | [diff] [blame] | 2038 | oam_channel->key.packet_send_dest.u.ieee_oam_channel.mac_address.u8, |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2039 | balIndCfg->baloamresp->key->packet_send_dest->ieee_oam_channel->mac_address.len); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2040 | |
| 2041 | } |
| 2042 | break; |
| 2043 | default: |
| 2044 | { |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2045 | balIndCfg->baloamresp->key->packet_send_dest->u_case = BAL_DEST__U__NOT_SET; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2046 | } |
| 2047 | break; |
| 2048 | } |
| 2049 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2050 | BalPacketIeeeOamChannelRxData *oamData; |
| 2051 | oamData = malloc(sizeof(BalPacketIeeeOamChannelRxData)); |
| 2052 | memset(oamData, 0, sizeof(BalPacketIeeeOamChannelRxData)); |
| 2053 | bal_packet_ieee_oam_channel_rx_data__init(oamData); |
| 2054 | balIndCfg->baloamresp->data = oamData; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2055 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2056 | balIndCfg->baloamresp->data->pkt.len = oam_channel->data.pkt.len; |
| 2057 | balIndCfg->baloamresp->data->pkt.data = (uint8_t *)malloc((balIndCfg->baloamresp->data->pkt.len)*sizeof(uint8_t)); |
| 2058 | memcpy(balIndCfg->baloamresp->data->pkt.data, oam_channel->data.pkt.val, |
| 2059 | balIndCfg->baloamresp->data->pkt.len); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2060 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2061 | list_node *bal_indication_node = malloc(sizeof(list_node)); |
| 2062 | bal_indication_node->bal_indication = balIndCfg; |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2063 | |
VoLTHA | 753536e | 2017-11-02 20:15:09 +0530 | [diff] [blame] | 2064 | pthread_mutex_lock(&bal_ind_queue_lock); |
| 2065 | add_bal_indication_node(bal_indication_node); |
| 2066 | pthread_mutex_unlock(&bal_ind_queue_lock); |
Rajeswara Rao | f6b4e6c | 2017-08-31 17:26:27 +0530 | [diff] [blame] | 2067 | } |
| 2068 | |
| 2069 | return result; |
| 2070 | } |