blob: 936e14a1672721214b9d5f288075a9abb1e609a6 [file] [log] [blame]
Shad Ansari01b0e652018-04-05 21:02:53 +00001/*
Girish Gowdraa707e7c2019-11-07 11:36:13 +05302 * Copyright 2018-present Open Networking Foundation
Shad Ansari01b0e652018-04-05 21:02:53 +00003
Girish Gowdraa707e7c2019-11-07 11:36:13 +05304 * 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
Shad Ansari01b0e652018-04-05 21:02:53 +00007
Girish Gowdraa707e7c2019-11-07 11:36:13 +05308 * http://www.apache.org/licenses/LICENSE-2.0
Shad Ansari01b0e652018-04-05 21:02:53 +00009
Girish Gowdraa707e7c2019-11-07 11:36:13 +053010 * 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
Shad Ansari01b0e652018-04-05 21:02:53 +000017#include "indications.h"
Shad Ansarib7b0ced2018-05-11 21:53:32 +000018#include "core.h"
Shad Ansari01b0e652018-04-05 21:02:53 +000019#include "utils.h"
Nicolas Palpacuer0f19b1a2018-06-07 17:29:31 -040020#include "stats_collection.h"
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -040021#include "translation.h"
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -040022#include "state.h"
23
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -040024#include <string>
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -040025
Shad Ansari01b0e652018-04-05 21:02:53 +000026extern "C"
27{
28#include <bcmos_system.h>
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000029#include <bcmolt_api.h>
30#include <bcmolt_host_api.h>
31#include <bcmolt_api_model_api_structs.h>
Shad Ansari01b0e652018-04-05 21:02:53 +000032}
33
34using grpc::Status;
35
Shad Ansari627b5782018-08-13 22:49:32 +000036extern Queue<openolt::Indication> oltIndQ;
Girish Gowdra96461052019-11-22 20:13:59 +053037extern std::map<alloc_cfg_compltd_key, Queue<alloc_cfg_complete_result> *> alloc_cfg_compltd_map;
38extern bcmos_fastlock alloc_cfg_wait_lock;
Shad Ansari01b0e652018-04-05 21:02:53 +000039
Nicolas Palpacuer3cad49d2018-07-02 14:03:24 -040040
Shad Ansari01b0e652018-04-05 21:02:53 +000041bool subscribed = false;
Girish Gowdruc8ed2ef2019-02-13 08:18:44 -080042uint32_t nni_intf_id = 0;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000043#define current_device 0
Shad Ansari01b0e652018-04-05 21:02:53 +000044
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000045static void OmciIndication(bcmolt_devid olt, bcmolt_msg *msg);
Shad Ansari01b0e652018-04-05 21:02:53 +000046
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000047#define INTERFACE_STATE_IF_DOWN(state) \
48 ((state == BCMOLT_INTERFACE_STATE_INACTIVE || \
49 state == BCMOLT_INTERFACE_STATE_PROCESSING || \
50 state == BCMOLT_INTERFACE_STATE_ACTIVE_STANDBY) ? BCMOS_TRUE : BCMOS_FALSE)
51#define INTERFACE_STATE_IF_UP(state) \
52 ((state == BCMOLT_INTERFACE_STATE_ACTIVE_WORKING) ? BCMOS_TRUE : BCMOS_FALSE)
53#define ONU_STATE_IF_DOWN(state) \
54 ((state == BCMOLT_ONU_OPERATION_INACTIVE || \
55 state == BCMOLT_ONU_OPERATION_DISABLE || \
56 state == BCMOLT_ONU_OPERATION_ACTIVE_STANDBY) ? BCMOS_TRUE : BCMOS_FALSE)
57#define ONU_STATE_IF_UP(state) \
58 ((state == BCMOLT_ONU_OPERATION_ACTIVE) ? BCMOS_TRUE : BCMOS_FALSE)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +053059#define ONU_ACTIVATION_COMPLETED_SUCCESS(state) \
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000060 ((state == BCMOLT_RESULT_SUCCESS) ? BCMOS_TRUE : BCMOS_FALSE)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +053061#define ONU_ACTIVATION_COMPLETED_FAIL(state) \
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000062 ((state != BCMOLT_RESULT_SUCCESS) ? BCMOS_TRUE : BCMOS_FALSE)
63#define SET_OPER_STATE(indication,state) \
64 (INTERFACE_STATE_IF_UP(state)) ? indication->set_oper_state("up") : \
65 indication->set_oper_state("down")
66#define GET_FLOW_TYPE(type) \
67 (type == BCMOLT_FLOW_TYPE_UPSTREAM) ? "upstream" : \
68 (type == BCMOLT_FLOW_TYPE_DOWNSTREAM) ? "downstream" : \
69 (type == BCMOLT_FLOW_TYPE_MULTICAST) ? "multicast" : "unknown"
70
71std::string bcmolt_to_grpc_intf_type(bcmolt_interface_type intf_type)
Craig Lutgen88a22ad2018-10-04 12:30:46 -050072{
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000073 if (intf_type == BCMOLT_INTERFACE_TYPE_NNI) {
Craig Lutgen88a22ad2018-10-04 12:30:46 -050074 return "nni";
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000075 } else if (intf_type == BCMOLT_INTERFACE_TYPE_PON) {
Craig Lutgen88a22ad2018-10-04 12:30:46 -050076 return "pon";
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000077 } else if (intf_type == BCMOLT_INTERFACE_TYPE_HOST) {
78 return "host";
Craig Lutgen88a22ad2018-10-04 12:30:46 -050079 }
80 return "unknown";
81}
82
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +000083std::string bcmolt_to_grpc_flow_intf_type(bcmolt_flow_interface_type intf_type)
84{
85 if (intf_type == BCMOLT_FLOW_INTERFACE_TYPE_NNI) {
86 return "nni";
87 } else if (intf_type == BCMOLT_FLOW_INTERFACE_TYPE_PON) {
88 return "pon";
89 } else if (intf_type == BCMOLT_FLOW_INTERFACE_TYPE_HOST) {
90 return "host";
91 }
92 return "unknown";
93}
94
95/*std::string getOnuRegistrationId(uint32_t intf_id, uint32_t onu_id){
Girish Gowdru376b33c2019-05-06 21:46:31 -070096 bcmbal_subscriber_terminal_key key;
97 bcmbal_subscriber_terminal_cfg sub_term_obj = {};
98 uint8_t *list_mem;// to fetch config details for ONU
99 bcmos_errno err = BCM_ERR_OK;
100
101 key.sub_term_id =onu_id;
102 key.intf_id = intf_id;
103 BCM_LOG(INFO, openolt_log_id,"Processing subscriber terminal cfg get for: %d",key.intf_id);
104
105 BCMBAL_CFG_INIT(&sub_term_obj, subscriber_terminal, key);
106
107 BCMBAL_CFG_PROP_GET(&sub_term_obj, subscriber_terminal, all_properties);
108 char *reg_id = (char*)malloc(sizeof(char)*MAX_REGID_LENGTH);
109 memset(reg_id, '\0', MAX_REGID_LENGTH);
110
111 //set memory to use for variable-sized lists
112 list_mem = (uint8_t*)malloc(BAL_DYNAMIC_LIST_BUFFER_SIZE);
113
114 if (list_mem == NULL)
115 {
116 BCM_LOG(ERROR,openolt_log_id,"Memory allocation failed while handling subscriber terminal \
117 cfg get subscriber_terminal_id(%d), Interface ID(%d)",key.sub_term_id, key.intf_id);
118 return reg_id;
119 }
120
121 memset(list_mem, 0, BAL_DYNAMIC_LIST_BUFFER_SIZE);
122 BCMBAL_CFG_LIST_BUF_SET(&sub_term_obj, subscriber_terminal, list_mem, BAL_DYNAMIC_LIST_BUFFER_SIZE);
123
124 //call API
125 err = bcmbal_cfg_get(DEFAULT_ATERM_ID, &sub_term_obj.hdr);
126
127 if (err != BCM_ERR_OK)
128 {
129 BCM_LOG(ERROR,openolt_log_id, "Failed to get information from BAL subscriber_terminal_id(%d), Interface ID(%d)",
130 key.sub_term_id, key.intf_id);
131 free(list_mem);
132 return reg_id;
133 }
134
135 BCM_LOG(INFO,openolt_log_id, "Get Subscriber cfg sent to OLT for Subscriber Id(%d) on Interface(%d)",
136 key.sub_term_id, key.intf_id);
137
138 for (int i=0; i<MAX_REGID_LENGTH ; i++){
139 reg_id[i]=sub_term_obj.data.registration_id.arr[i];
140 }
141
142 free(list_mem);
143 return reg_id;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000144}*/
Girish Gowdru376b33c2019-05-06 21:46:31 -0700145
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000146static void OltOperIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000147 openolt::Indication ind;
148 openolt::OltIndication* olt_ind = new openolt::OltIndication;
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500149 std::string admin_state;
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500150
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000151 switch (msg->subgroup) {
152 case BCMOLT_DEVICE_AUTO_SUBGROUP_CONNECTION_COMPLETE:
153 admin_state = "up";
154 olt_ind->set_oper_state("up");
155 break;
156 case BCMOLT_DEVICE_AUTO_SUBGROUP_DISCONNECTION_COMPLETE:
157 admin_state = "down";
158 olt_ind->set_oper_state("down");
159 break;
160 case BCMOLT_DEVICE_AUTO_SUBGROUP_CONNECTION_FAILURE:
161 admin_state = "failure";
162 olt_ind->set_oper_state("failure");
163 break;
Shad Ansari01b0e652018-04-05 21:02:53 +0000164 }
165 ind.set_allocated_olt_ind(olt_ind);
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500166
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000167 if (msg->subgroup == BCMOLT_DEVICE_AUTO_SUBGROUP_CONNECTION_COMPLETE) {
168 /* register for omci indication */
169 {
170 bcmolt_rx_cfg rx_cfg = {};
171 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
172 rx_cfg.rx_cb = OmciIndication;
173 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_omci_packet;
174 rx_cfg.module = BCMOS_MODULE_ID_OMCI_TRANSPORT;
175 bcmolt_ind_subscribe(current_device, &rx_cfg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000176 }
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500177 state.activate();
178 }
179 else {
180 state.deactivate();
181 }
182
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000183 oltIndQ.push(ind);
184 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000185}
186
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000187static void LosIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000188 openolt::Indication ind;
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400189 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
190 openolt::LosIndication* los_ind = new openolt::LosIndication;
191
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000192 switch (msg->obj_type) {
193 case BCMOLT_OBJ_ID_PON_INTERFACE:
194 switch (msg->subgroup) {
195 case BCMOLT_PON_INTERFACE_AUTO_SUBGROUP_LOS:
196 {
197 bcmolt_pon_interface_los* bcm_los_ind = (bcmolt_pon_interface_los *) msg;
198 int intf_id = interface_key_to_port_no(bcm_los_ind->key.pon_ni,
199 BCMOLT_INTERFACE_TYPE_PON);
200 std::string status = alarm_status_to_string(bcm_los_ind->data.status);
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400201
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530202 OPENOLT_LOG(INFO, openolt_log_id, "LOS indication : intf_id: %d port: %d status %s\n",
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000203 bcm_los_ind->key.pon_ni, intf_id, status.c_str());
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400204
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000205 los_ind->set_intf_id(intf_id);
206 los_ind->set_status(status);
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400207
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000208 alarm_ind->set_allocated_los_ind(los_ind);
209 ind.set_allocated_alarm_ind(alarm_ind);
210 break;
211 }
212 }
213 }
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400214
215 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000216 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000217}
218
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000219static void IfIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700220 openolt::Indication ind;
221 openolt::IntfIndication* intf_ind = new openolt::IntfIndication;
222
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530223 switch (msg->obj_type) {
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000224 case BCMOLT_OBJ_ID_PON_INTERFACE:
225 switch (msg->subgroup) {
226 case BCMOLT_PON_INTERFACE_AUTO_SUBGROUP_STATE_CHANGE_COMPLETED:
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530227 {
228 bcmolt_pon_interface_key *key =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000229 &((bcmolt_pon_interface_state_change_completed*)msg)->key;
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530230 bcmolt_pon_interface_state_change_completed_data *data =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000231 &((bcmolt_pon_interface_state_change_completed*)msg)->data;
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700232
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000233 intf_ind->set_intf_id(key->pon_ni);
234 SET_OPER_STATE(intf_ind, data->new_state);
235 ind.set_allocated_intf_ind(intf_ind);
236 break;
237 }
238 }
239 break;
240 case BCMOLT_OBJ_ID_NNI_INTERFACE:
241 switch (msg->subgroup) {
242 case BCMOLT_NNI_INTERFACE_AUTO_SUBGROUP_STATE_CHANGE:
243 {
244 OPENOLT_LOG(INFO, openolt_log_id, "intf indication, intf_id: %d\n",
245 ((bcmolt_nni_interface_state_change *)msg)->key.id);
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530246 bcmolt_nni_interface_key *key =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000247 &((bcmolt_nni_interface_state_change *)msg)->key;
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530248 bcmolt_nni_interface_state_change_data *data =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000249 &((bcmolt_nni_interface_state_change *)msg)->data;
250
251 intf_ind->set_intf_id(key->id);
252 SET_OPER_STATE(intf_ind, data->new_state);
253 ind.set_allocated_intf_ind(intf_ind);
254 break;
255 }
256 }
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700257 }
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700258
259 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000260 bcmolt_msg_free(msg);
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700261}
262
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000263static void IfOperIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000264 openolt::Indication ind;
265 openolt::IntfOperIndication* intf_oper_ind = new openolt::IntfOperIndication;
Shad Ansari01b0e652018-04-05 21:02:53 +0000266
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000267 switch (msg->obj_type) {
268 case BCMOLT_OBJ_ID_PON_INTERFACE:
269 switch (msg->subgroup) {
270 case BCMOLT_PON_INTERFACE_AUTO_SUBGROUP_STATE_CHANGE_COMPLETED:
271 {
272 bcmolt_pon_interface_key *key = &((bcmolt_pon_interface_state_change_completed*)msg)->key;
273 bcmolt_pon_interface_state_change_completed_data *data = &((bcmolt_pon_interface_state_change_completed*)msg)->data;
274 intf_oper_ind->set_intf_id(key->pon_ni);
275 intf_oper_ind->set_type(bcmolt_to_grpc_intf_type(BCMOLT_INTERFACE_TYPE_PON));
276 SET_OPER_STATE(intf_oper_ind, data->new_state);
277 OPENOLT_LOG(INFO, openolt_log_id, "intf oper state indication, intf_type %s, intf_id %d, oper_state %s\n",
278 intf_oper_ind->type().c_str(), key->pon_ni, intf_oper_ind->oper_state().c_str());
279 ind.set_allocated_intf_oper_ind(intf_oper_ind);
280 break;
281 }
282 }
283 case BCMOLT_OBJ_ID_NNI_INTERFACE:
284 switch (msg->subgroup) {
285 case BCMOLT_NNI_INTERFACE_AUTO_SUBGROUP_STATE_CHANGE:
286 {
287 bcmolt_nni_interface_key *key = &((bcmolt_nni_interface_state_change *)msg)->key;
288 bcmolt_nni_interface_state_change_data *data = &((bcmolt_nni_interface_state_change *)msg)->data;
289 bcmolt_interface intf_id = key->id;
290 bcmolt_interface_type intf_type = BCMOLT_INTERFACE_TYPE_NNI;
291 intf_oper_ind->set_intf_id(key->id);
292 intf_oper_ind->set_type(bcmolt_to_grpc_intf_type(BCMOLT_INTERFACE_TYPE_NNI));
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530293 SET_OPER_STATE(intf_oper_ind, data->new_state);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000294 OPENOLT_LOG(INFO, openolt_log_id, "intf oper state indication, intf_type %s, intf_id %d, oper_state %s\n",
295 intf_oper_ind->type().c_str(), key->id, intf_oper_ind->oper_state().c_str());
296 ind.set_allocated_intf_oper_ind(intf_oper_ind);
297 break;
298 }
299 }
Shad Ansari01b0e652018-04-05 21:02:53 +0000300 }
301
Shad Ansari01b0e652018-04-05 21:02:53 +0000302 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000303 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000304}
305
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000306static void OnuAlarmIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000307 openolt::Indication ind;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400308 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
309 openolt::OnuAlarmIndication* onu_alarm_ind = new openolt::OnuAlarmIndication;
310
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000311 switch (msg->obj_type) {
312 case BCMOLT_OBJ_ID_ONU:
313 switch (msg->subgroup) {
314 case BCMOLT_ONU_AUTO_SUBGROUP_XGPON_ALARM:
315 {
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530316 bcmolt_xgpon_onu_alarms *onu_alarms =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000317 &((bcmolt_onu_xgpon_alarm_data *)msg)->xgpon_onu_alarm;
318 onu_alarm_ind->set_los_status(alarm_status_to_string(onu_alarms->losi));
319 onu_alarm_ind->set_lob_status(alarm_status_to_string(onu_alarms->lobi));
320 onu_alarm_ind->set_lopc_miss_status(alarm_status_to_string(
321 onu_alarms->lopci_miss));
322 onu_alarm_ind->set_lopc_mic_error_status(alarm_status_to_string(
323 onu_alarms->lopci_mic_error));
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400324
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000325 alarm_ind->set_allocated_onu_alarm_ind(onu_alarm_ind);
326 ind.set_allocated_alarm_ind(alarm_ind);
327 break;
328 }
329 case BCMOLT_ONU_AUTO_SUBGROUP_GPON_ALARM:
330 {
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530331 bcmolt_gpon_onu_alarms *onu_alarms =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000332 &((bcmolt_onu_gpon_alarm_data *)msg)->gpon_onu_alarm;
333 onu_alarm_ind->set_los_status(alarm_status_to_string(onu_alarms->losi));
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530334 /* TODO: need to set lofi and loami
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000335 onu_alarm_ind->set_lof_status(alarm_status_to_string(onu_alarms->lofi));
336 onu_alarm_ind->set_loami_status(alarm_status_to_string(
337 onu_alarms->loami));
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530338 */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000339 alarm_ind->set_allocated_onu_alarm_ind(onu_alarm_ind);
340 ind.set_allocated_alarm_ind(alarm_ind);
341 break;
342 }
343 }
344 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400345
346 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000347 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000348}
349
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000350static void OnuDyingGaspIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000351 openolt::Indication ind;
Nicolas Palpacuera32f4c32018-06-28 12:55:10 -0400352 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000353 openolt::DyingGaspIndication* dgi_ind = new openolt::DyingGaspIndication;
nickc063ffd2018-05-22 14:35:28 -0400354
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000355 switch (msg->obj_type) {
356 case BCMOLT_OBJ_ID_ONU:
357 switch (msg->subgroup) {
358 case BCMOLT_ONU_AUTO_SUBGROUP_DGI:
359 {
360 bcmolt_onu_dgi_data* dgi_data = (bcmolt_onu_dgi_data *)msg;
361 dgi_ind->set_status(alarm_status_to_string(dgi_data->alarm_status));
nickc063ffd2018-05-22 14:35:28 -0400362
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000363 alarm_ind->set_allocated_dying_gasp_ind(dgi_ind);
364 ind.set_allocated_alarm_ind(alarm_ind);
365 break;
366 }
367 }
368 }
nickc063ffd2018-05-22 14:35:28 -0400369
370 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000371 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000372}
373
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000374static void OnuDiscoveryIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000375 openolt::Indication ind;
376 openolt::OnuDiscIndication* onu_disc_ind = new openolt::OnuDiscIndication;
377 openolt::SerialNumber* serial_number = new openolt::SerialNumber;
378
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000379 switch (msg->obj_type) {
380 case BCMOLT_OBJ_ID_PON_INTERFACE:
381 switch (msg->subgroup) {
382 case BCMOLT_PON_INTERFACE_AUTO_SUBGROUP_ONU_DISCOVERED:
383 {
384 bcmolt_pon_interface_key *key =
385 &((bcmolt_pon_interface_onu_discovered *)msg)->key;
Shad Ansari01b0e652018-04-05 21:02:53 +0000386
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530387 bcmolt_pon_interface_onu_discovered_data *data =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000388 &((bcmolt_pon_interface_onu_discovered *)msg)->data;
Shad Ansari01b0e652018-04-05 21:02:53 +0000389
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000390 bcmolt_serial_number *in_serial_number = &(data->serial_number);
Shad Ansari01b0e652018-04-05 21:02:53 +0000391
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000392 OPENOLT_LOG(INFO, openolt_log_id, "onu discover indication, pon_ni %d, serial_number %s\n",
393 key->pon_ni, serial_number_to_str(in_serial_number).c_str());
Shad Ansari01b0e652018-04-05 21:02:53 +0000394
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000395 onu_disc_ind->set_intf_id(key->pon_ni);
396 serial_number->set_vendor_id(reinterpret_cast<const char *>(in_serial_number->vendor_id.arr), 4);
397 serial_number->set_vendor_specific(reinterpret_cast<const char *>(in_serial_number->vendor_specific.arr), 8);
398 onu_disc_ind->set_allocated_serial_number(serial_number);
399 ind.set_allocated_onu_disc_ind(onu_disc_ind);
400 break;
401 }
402 }
403 }
Shad Ansari01b0e652018-04-05 21:02:53 +0000404
405 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000406 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000407}
408
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000409static void OmciIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000410 openolt::Indication ind;
411 openolt::OmciIndication* omci_ind = new openolt::OmciIndication;
Shad Ansari01b0e652018-04-05 21:02:53 +0000412
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000413 switch (msg->obj_type) {
414 case BCMOLT_OBJ_ID_ONU:
415 switch (msg->subgroup) {
416 case BCMOLT_ONU_AUTO_SUBGROUP_OMCI_PACKET:
417 {
418 bcmolt_onu_key *key = &((bcmolt_onu_omci_packet*)msg)->key;
419 bcmolt_onu_omci_packet_data *data = &((bcmolt_onu_omci_packet*)msg)->data;
Shad Ansari01b0e652018-04-05 21:02:53 +0000420
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530421 OPENOLT_LOG(DEBUG, omci_log_id, "OMCI indication: pon_ni %d, onu_id %d\n",
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000422 key->pon_ni, key->onu_id);
Shad Ansari01b0e652018-04-05 21:02:53 +0000423
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000424 omci_ind->set_intf_id(key->pon_ni);
425 omci_ind->set_onu_id(key->onu_id);
426 omci_ind->set_pkt(data->buffer.arr, data->buffer.len);
427
428 ind.set_allocated_omci_ind(omci_ind);
429 break;
430 }
431 }
432 }
433
Shad Ansari01b0e652018-04-05 21:02:53 +0000434 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000435 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000436}
437
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000438static void PacketIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000439 openolt::Indication ind;
Shad Ansari5fe93682018-04-26 05:24:19 +0000440 openolt::PacketIndication* pkt_ind = new openolt::PacketIndication;
Shad Ansari5fe93682018-04-26 05:24:19 +0000441
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000442 switch (msg->obj_type) {
443 case BCMOLT_OBJ_ID_FLOW:
444 switch (msg->subgroup) {
445 case BCMOLT_FLOW_AUTO_SUBGROUP_RECEIVE_ETH_PACKET:
446 {
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530447 bcmolt_flow_receive_eth_packet *pkt =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000448 (bcmolt_flow_receive_eth_packet*)msg;
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530449 bcmolt_flow_receive_eth_packet_data *pkt_data =
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000450 &((bcmolt_flow_receive_eth_packet*)msg)->data;
Shad Ansari5fe93682018-04-26 05:24:19 +0000451
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000452 uint32_t port_no = GetPortNum_(pkt->key.flow_id);
453 pkt_ind->set_intf_type(bcmolt_to_grpc_flow_intf_type((bcmolt_flow_interface_type)get_flow_status(pkt->key.flow_id, pkt->key.flow_type, INGRESS_INTF_TYPE)));
454 pkt_ind->set_intf_id(get_flow_status(pkt->key.flow_id, pkt->key.flow_type, INGRESS_INTF_ID));
455 pkt_ind->set_gemport_id(get_flow_status(pkt->key.flow_id, pkt->key.flow_type, SVC_PORT_ID));
456 pkt_ind->set_flow_id(pkt->key.flow_id);
457 pkt_ind->set_pkt(pkt_data->buffer.arr, pkt_data->buffer.len);
458 pkt_ind->set_port_no(port_no);
459 pkt_ind->set_cookie(get_flow_status(pkt->key.flow_id, pkt->key.flow_type, COOKIE));
460 ind.set_allocated_pkt_ind(pkt_ind);
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500461
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000462 OPENOLT_LOG(INFO, openolt_log_id, "packet indication, ingress intf_type %s, ingress intf_id %d, egress intf_type %s, egress intf_id %lu, svc_port %d, flow_type %s, flow_id %d, port_no %d, cookie %"PRIu64"\n",
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530463 pkt_ind->intf_type().c_str(), pkt_ind->intf_id(),
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000464 bcmolt_to_grpc_flow_intf_type((bcmolt_flow_interface_type)get_flow_status(pkt->key.flow_id, pkt->key.flow_type, EGRESS_INTF_TYPE)).c_str(),
465 get_flow_status(pkt->key.flow_id, pkt->key.flow_type, EGRESS_INTF_ID),
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530466 pkt_ind->gemport_id(), GET_FLOW_TYPE(pkt->key.flow_type),
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000467 pkt_ind->flow_id(), port_no, pkt_ind->cookie());
468 }
469 }
470 }
Craig Lutgen88a22ad2018-10-04 12:30:46 -0500471
Shad Ansari5fe93682018-04-26 05:24:19 +0000472 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000473 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000474}
475
Girish Gowdra96461052019-11-22 20:13:59 +0530476static void ItuPonAllocConfigCompletedInd(bcmolt_devid olt, bcmolt_msg *msg) {
477
478 switch (msg->obj_type) {
479 case BCMOLT_OBJ_ID_ITUPON_ALLOC:
480 switch (msg->subgroup) {
481 case BCMOLT_ITUPON_ALLOC_AUTO_SUBGROUP_CONFIGURATION_COMPLETED:
482 {
483 bcmolt_itupon_alloc_configuration_completed *pkt =
484 (bcmolt_itupon_alloc_configuration_completed*)msg;
485 bcmolt_itupon_alloc_configuration_completed_data *pkt_data =
486 &((bcmolt_itupon_alloc_configuration_completed*)msg)->data;
487
488 alloc_cfg_compltd_key key((uint32_t)pkt->key.pon_ni, (uint32_t) pkt->key.alloc_id);
489 alloc_cfg_complete_result res;
490 res.pon_intf_id = pkt->key.pon_ni;
491 res.alloc_id = pkt->key.alloc_id;
492
493 pkt_data->status == BCMOLT_RESULT_SUCCESS ? res.status = ALLOC_CFG_STATUS_SUCCESS: res.status = ALLOC_CFG_STATUS_FAIL;
494 switch (pkt_data->new_state) {
495 case BCMOLT_ACTIVATION_STATE_NOT_CONFIGURED:
496 res.state = ALLOC_OBJECT_STATE_NOT_CONFIGURED;
497 break;
498 case BCMOLT_ACTIVATION_STATE_INACTIVE:
499 res.state = ALLOC_OBJECT_STATE_INACTIVE;
500 break;
501 case BCMOLT_ACTIVATION_STATE_PROCESSING:
502 res.state = ALLOC_OBJECT_STATE_PROCESSING;
503 break;
504 case BCMOLT_ACTIVATION_STATE_ACTIVE:
505 res.state = ALLOC_OBJECT_STATE_ACTIVE;
506 break;
507 default:
508 OPENOLT_LOG(ERROR, openolt_log_id, "invalid itu pon alloc activation new_state, pon_intf %u, alloc_id %u, new_state %d\n",
509 pkt->key.pon_ni, pkt->key.alloc_id, pkt_data->new_state);
510 res.state = ALLOC_OBJECT_STATE_NOT_CONFIGURED;
511 }
512 OPENOLT_LOG(INFO, openolt_log_id, "received itu pon alloc cfg complete ind, pon intf %u, alloc_id %u, status %u, new_state %u\n",
513 pkt->key.pon_ni, pkt->key.alloc_id, pkt_data->status, pkt_data->new_state);
514
515 bcmos_fastlock_lock(&alloc_cfg_wait_lock);
516 // Push the result from BAL to queue
517 std::map<alloc_cfg_compltd_key, Queue<alloc_cfg_complete_result> *>::iterator it = alloc_cfg_compltd_map.find(key);
518 if (it == alloc_cfg_compltd_map.end()) {
519 // could be case of spurious aysnc response, OR, the application timed-out waiting for response and cleared the key.
520 bcmolt_msg_free(msg);
521 OPENOLT_LOG(ERROR, openolt_log_id, "alloc config key not found for alloc_id = %u, pon_intf = %u\n", pkt->key.alloc_id, pkt->key.pon_ni);
522 bcmos_fastlock_unlock(&alloc_cfg_wait_lock, 0);
523 return;
524 }
525 if (it->second) {
526 // Push the result
527 it->second->push(res);
528 }
529 bcmos_fastlock_unlock(&alloc_cfg_wait_lock, 0);
530 }
531 }
532 }
533
534 bcmolt_msg_free(msg);
535}
536
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000537static void FlowOperIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000538 openolt::Indication ind;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000539 OPENOLT_LOG(DEBUG, openolt_log_id, "flow oper state indication\n");
540 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000541}
542
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000543static void FlowIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000544 openolt::Indication ind;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000545 OPENOLT_LOG(DEBUG, openolt_log_id, "flow indication\n");
546 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000547}
548
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000549static void TmQIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000550 openolt::Indication ind;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000551 OPENOLT_LOG(DEBUG, openolt_log_id, "traffic mgmt queue indication\n");
552 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000553}
554
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000555static void TmSchedIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000556 openolt::Indication ind;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000557 OPENOLT_LOG(DEBUG, openolt_log_id, "traffic mgmt sheduler indication\n");
558 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000559}
560
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000561static void McastGroupIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Shad Ansari01b0e652018-04-05 21:02:53 +0000562 openolt::Indication ind;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000563 OPENOLT_LOG(DEBUG, openolt_log_id, "mcast group indication\n");
564 bcmolt_msg_free(msg);
Shad Ansari01b0e652018-04-05 21:02:53 +0000565}
566
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000567static void OnuStartupFailureIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400568 openolt::Indication ind;
569 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
570 openolt::OnuStartupFailureIndication* sufi_ind = new openolt::OnuStartupFailureIndication;
571
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000572 switch (msg->obj_type) {
573 case BCMOLT_OBJ_ID_ONU:
574 switch (msg->subgroup) {
575 case BCMOLT_ONU_AUTO_SUBGROUP_SUFI:
576 {
577 bcmolt_onu_key *key = &((bcmolt_onu_sufi*)msg)->key;
578 bcmolt_onu_sufi_data *data = &((bcmolt_onu_sufi*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400579
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000580 OPENOLT_LOG(WARNING, openolt_log_id, "onu startup failure indication, intf_id %d, onu_id %d, alarm %d\n",
581 key->pon_ni, key->onu_id, data->alarm_status);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400582
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000583 sufi_ind->set_intf_id(key->pon_ni);
584 sufi_ind->set_onu_id(key->onu_id);
585 sufi_ind->set_status(alarm_status_to_string(data->alarm_status));
586 alarm_ind->set_allocated_onu_startup_fail_ind(sufi_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400587
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000588 ind.set_allocated_alarm_ind(alarm_ind);
589 }
590 }
591 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400592
593 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000594 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400595}
596
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000597static void OnuSignalDegradeIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400598 openolt::Indication ind;
599 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
600 openolt::OnuSignalDegradeIndication* sdi_ind = new openolt::OnuSignalDegradeIndication;
601
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000602 switch (msg->obj_type) {
603 case BCMOLT_OBJ_ID_ONU:
604 switch (msg->subgroup) {
605 case BCMOLT_ONU_AUTO_SUBGROUP_SDI:
606 {
607 bcmolt_onu_key *key = &((bcmolt_onu_sdi*)msg)->key;
608 bcmolt_onu_sdi_data *data = &((bcmolt_onu_sdi*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400609
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000610 OPENOLT_LOG(WARNING, openolt_log_id, "onu signal degrade indication, intf_id %d, onu_id %d, alarm %d, BER %d\n",
611 key->pon_ni, key->onu_id, data->alarm_status, data->ber);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400612
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000613 sdi_ind->set_intf_id(key->pon_ni);
614 sdi_ind->set_onu_id(key->onu_id);
615 sdi_ind->set_status(alarm_status_to_string(data->alarm_status));
616 sdi_ind->set_inverse_bit_error_rate(data->ber);
617 alarm_ind->set_allocated_onu_signal_degrade_ind(sdi_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400618
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000619 ind.set_allocated_alarm_ind(alarm_ind);
620 }
621 }
622 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400623
624 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000625 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400626}
627
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000628static void OnuDriftOfWindowIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400629 openolt::Indication ind;
630 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
631 openolt::OnuDriftOfWindowIndication* dowi_ind = new openolt::OnuDriftOfWindowIndication;
632
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000633 switch (msg->obj_type) {
634 case BCMOLT_OBJ_ID_ONU:
635 switch (msg->subgroup) {
636 case BCMOLT_ONU_AUTO_SUBGROUP_DOWI:
637 {
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530638 bcmolt_onu_key *key = &((bcmolt_onu_dowi*)msg)->key;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000639 bcmolt_onu_dowi_data *data = &((bcmolt_onu_dowi*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400640
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000641 OPENOLT_LOG(WARNING, openolt_log_id, "onu drift of window indication, intf_id %d, onu_id %d, alarm %d, drift %d, new_eqd %d\n",
642 key->pon_ni, key->onu_id, data->alarm_status, data->drift_value, data->new_eqd);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400643
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000644 dowi_ind->set_intf_id(key->pon_ni);
645 dowi_ind->set_onu_id(key->onu_id);
646 dowi_ind->set_status(alarm_status_to_string(data->alarm_status));
647 dowi_ind->set_drift(data->drift_value);
648 dowi_ind->set_new_eqd(data->new_eqd);
649 alarm_ind->set_allocated_onu_drift_of_window_ind(dowi_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400650
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000651 ind.set_allocated_alarm_ind(alarm_ind);
652 }
653 }
654 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400655
656 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000657 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400658}
659
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000660static void OnuLossOfOmciChannelIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400661 openolt::Indication ind;
662 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
663 openolt::OnuLossOfOmciChannelIndication* looci_ind = new openolt::OnuLossOfOmciChannelIndication;
664
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000665 switch (msg->obj_type) {
666 case BCMOLT_OBJ_ID_ONU:
667 switch (msg->subgroup) {
668 case BCMOLT_ONU_AUTO_SUBGROUP_LOOCI:
669 {
670 bcmolt_onu_key *key = &((bcmolt_onu_looci*)msg)->key;
671 bcmolt_onu_looci_data *data = &((bcmolt_onu_looci*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400672
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000673 OPENOLT_LOG(WARNING, openolt_log_id, "onu loss of OMCI channel indication, intf_id %d, onu_id %d, alarm %d\n",
674 key->pon_ni, key->onu_id, data->alarm_status);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400675
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000676 looci_ind->set_intf_id(key->pon_ni);
677 looci_ind->set_onu_id(key->onu_id);
678 looci_ind->set_status(alarm_status_to_string(data->alarm_status));
679 alarm_ind->set_allocated_onu_loss_omci_ind(looci_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400680
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000681 ind.set_allocated_alarm_ind(alarm_ind);
682 }
683 }
684 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400685
686 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000687 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400688}
689
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000690static void OnuSignalsFailureIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400691 openolt::Indication ind;
692 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
693 openolt::OnuSignalsFailureIndication* sfi_ind = new openolt::OnuSignalsFailureIndication;
694
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000695 switch (msg->obj_type) {
696 case BCMOLT_OBJ_ID_ONU:
697 switch (msg->subgroup) {
698 case BCMOLT_ONU_AUTO_SUBGROUP_SFI:
699 {
700 bcmolt_onu_key *key = &((bcmolt_onu_sfi*)msg)->key;
701 bcmolt_onu_sfi_data *data = &((bcmolt_onu_sfi*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400702
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000703 OPENOLT_LOG(WARNING, openolt_log_id, "onu signals failure indication, intf_id %d, onu_id %d, alarm %d, BER %d\n",
704 key->pon_ni, key->onu_id, data->alarm_status, data->ber);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400705
706
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000707 sfi_ind->set_intf_id(key->pon_ni);
708 sfi_ind->set_onu_id(key->onu_id);
709 sfi_ind->set_status(alarm_status_to_string(data->alarm_status));
710 sfi_ind->set_inverse_bit_error_rate(data->ber);
711 alarm_ind->set_allocated_onu_signals_fail_ind(sfi_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400712
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000713 ind.set_allocated_alarm_ind(alarm_ind);
714 }
715 }
716 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400717
718 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000719 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400720}
721
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000722static void OnuTransmissionInterferenceWarningIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400723 openolt::Indication ind;
724 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
725 openolt::OnuTransmissionInterferenceWarning* tiwi_ind = new openolt::OnuTransmissionInterferenceWarning;
726
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000727 switch (msg->obj_type) {
728 case BCMOLT_OBJ_ID_ONU:
729 switch (msg->subgroup) {
730 case BCMOLT_ONU_AUTO_SUBGROUP_TIWI:
731 {
732 bcmolt_onu_key *key = &((bcmolt_onu_tiwi*)msg)->key;
733 bcmolt_onu_tiwi_data *data = &((bcmolt_onu_tiwi*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400734
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000735 OPENOLT_LOG(WARNING, openolt_log_id, "onu transmission interference warning indication, intf_id %d, onu_id %d, alarm %d, drift %d\n",
736 key->pon_ni, key->onu_id, data->alarm_status, data->drift_value);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400737
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000738 tiwi_ind->set_intf_id(key->pon_ni);
739 tiwi_ind->set_onu_id(key->onu_id);
740 tiwi_ind->set_status(alarm_status_to_string(data->alarm_status));
741 tiwi_ind->set_drift(data->drift_value);
742 alarm_ind->set_allocated_onu_tiwi_ind(tiwi_ind);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400743
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000744 ind.set_allocated_alarm_ind(alarm_ind);
745 }
746 }
747 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400748
749 oltIndQ.push(ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000750 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400751}
752
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530753static void OnuActivationCompletedIndication(bcmolt_devid olt, bcmolt_msg *msg) {
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400754 openolt::Indication ind;
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530755 openolt::OnuIndication* onu_ind = new openolt::OnuIndication;
756
757 switch (msg->obj_type) {
758 case BCMOLT_OBJ_ID_ONU:
759 switch (msg->subgroup) {
760 case BCMOLT_ONU_AUTO_SUBGROUP_ONU_ACTIVATION_COMPLETED:
761 {
762 bcmolt_onu_key *key = &((bcmolt_onu_onu_activation_completed*)msg)->key;
763 bcmolt_onu_onu_activation_completed_data*data = &((bcmolt_onu_onu_activation_completed*)msg)->data;
764
765 onu_ind->set_intf_id(key->pon_ni);
766 onu_ind->set_onu_id(key->onu_id);
767 if (ONU_ACTIVATION_COMPLETED_SUCCESS(data->status))
768 onu_ind->set_oper_state("up");
769 if (ONU_ACTIVATION_COMPLETED_FAIL(data->status))
770 onu_ind->set_oper_state("down");
771 // Setting the admin_state state field based on a valid onu_id does not make any sense.
772 // The adapter too does not seem to interpret this seriously.
773 // Legacy code, lets keep this as is for now.
774 (key->onu_id)?onu_ind->set_admin_state("up"):onu_ind->set_admin_state("down");
775 ind.set_allocated_onu_ind(onu_ind);
776 OPENOLT_LOG(INFO, openolt_log_id, "onu indication, pon_ni %d, onu_id %d, onu_state %s, onu_admin %s\n",
777 key->pon_ni, key->onu_id, (data->status==BCMOLT_RESULT_SUCCESS)?"up":"down",
778 (key->onu_id)?"up":"down");
779 }
780 }
781 }
782
783 oltIndQ.push(ind);
784 bcmolt_msg_free(msg);
785}
786
787
788static void OnuDeactivationCompletedIndication(bcmolt_devid olt, bcmolt_msg *msg) {
789 openolt::Indication ind;
790
791 openolt::Indication onu_ind;
792 openolt::OnuIndication* onu_ind_data = new openolt::OnuIndication;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400793
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000794 switch (msg->obj_type) {
795 case BCMOLT_OBJ_ID_ONU:
796 switch (msg->subgroup) {
797 case BCMOLT_ONU_AUTO_SUBGROUP_ONU_DEACTIVATION_COMPLETED:
798 {
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530799 bcmolt_onu_key *key = &((bcmolt_onu_onu_deactivation_completed*)msg)->key;
800 bcmolt_onu_onu_deactivation_completed_data *data =
801 &((bcmolt_onu_onu_deactivation_completed*)msg)->data;
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400802
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530803 OPENOLT_LOG(INFO, openolt_log_id, "Got onu deactivation, intf_id %d, onu_id %d, fail_reason %d, result_status %s\n",
804 key->pon_ni, key->onu_id, data->fail_reason, bcmolt_result_to_string(data->status).c_str());
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400805
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530806 onu_ind_data->set_intf_id(key->pon_ni);
807 onu_ind_data->set_onu_id(key->onu_id);
808 onu_ind_data->set_oper_state("down");
809 onu_ind_data->set_admin_state("down");
810 onu_ind.set_allocated_onu_ind(onu_ind_data);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000811 }
812 }
813 }
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400814
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530815 oltIndQ.push(onu_ind);
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000816 bcmolt_msg_free(msg);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400817}
818
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000819/* removed by BAL v3.0
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400820bcmos_errno OnuProcessingErrorIndication(bcmbal_obj *obj) {
821 openolt::Indication ind;
822 openolt::AlarmIndication* alarm_ind = new openolt::AlarmIndication;
823 openolt::OnuProcessingErrorIndication* onu_proc_error_ind = new openolt::OnuProcessingErrorIndication;
824
825 bcmbal_subscriber_terminal_key *key =
826 &(((bcmbal_subscriber_terminal_processing_error*)obj)->key);
827
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000828 OPENOLT_LOG(WARNING, openolt_log_id, "onu processing error indication, intf_id %d, onu_id %d\n",
Nicolas Palpacuer967438f2018-09-07 14:41:54 -0400829 key->intf_id, key->sub_term_id);
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400830
831
832 onu_proc_error_ind->set_intf_id(key->intf_id);
833 onu_proc_error_ind->set_onu_id(key->sub_term_id);
834
835 alarm_ind->set_allocated_onu_processing_error_ind(onu_proc_error_ind);
836 ind.set_allocated_alarm_ind(alarm_ind);
837
838 oltIndQ.push(ind);
839 return BCM_ERR_OK;
840}
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000841*/
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400842
Burak Gurdagc78b9e12019-11-29 11:14:51 +0000843static void GroupIndication(bcmolt_devid olt, bcmolt_msg *msg) {
844
845 switch (msg->obj_type) {
846 case BCMOLT_OBJ_ID_GROUP:
847 switch (msg->subgroup) {
848 case BCMOLT_GROUP_AUTO_SUBGROUP_COMPLETE_MEMBERS_UPDATE:
849 {
850 bcmolt_group_key *key = &((bcmolt_group_complete_members_update*)msg)->key;
851 bcmolt_group_complete_members_update_data *data =
852 &((bcmolt_group_complete_members_update*)msg)->data;
853
854 if (data->result == BCMOLT_RESULT_SUCCESS) {
855 OPENOLT_LOG(INFO, openolt_log_id, "Complete members update indication for group %d (successful)\n", key->id);
856 } else {
857 OPENOLT_LOG(ERROR, openolt_log_id, "Complete members update indication for group %d (failed with reason %d)\n", key->id, data->fail_reason);
858 }
859 }
860 }
861 }
862 bcmolt_msg_free(msg);
863}
864
Shad Ansari01b0e652018-04-05 21:02:53 +0000865Status SubscribeIndication() {
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000866 bcmolt_rx_cfg rx_cfg = {};
867 bcmos_errno rc;
Shad Ansari01b0e652018-04-05 21:02:53 +0000868
869 if (subscribed) {
870 return Status::OK;
871 }
872
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000873 rx_cfg.obj_type = BCMOLT_OBJ_ID_DEVICE;
874 rx_cfg.rx_cb = OltOperIndication;
875 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
876 rx_cfg.subgroup = bcmolt_device_auto_subgroup_connection_complete;
877 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
878 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530879 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000880 "Olt connection complete state indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000881
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000882 rx_cfg.obj_type = BCMOLT_OBJ_ID_DEVICE;
883 rx_cfg.rx_cb = OltOperIndication;
884 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
885 rx_cfg.subgroup = bcmolt_device_auto_subgroup_disconnection_complete;
886 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
887 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530888 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000889 "Olt disconnection complete state indication subscribe failed");
890
891 rx_cfg.obj_type = BCMOLT_OBJ_ID_DEVICE;
892 rx_cfg.rx_cb = OltOperIndication;
893 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
894 rx_cfg.subgroup = bcmolt_device_auto_subgroup_connection_failure;
895 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
896 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530897 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000898 "Olt connection failure state indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000899
900 /* Interface LOS indication */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000901 rx_cfg.obj_type = BCMOLT_OBJ_ID_PON_INTERFACE;
902 rx_cfg.rx_cb = LosIndication;
903 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
904 rx_cfg.subgroup = bcmolt_pon_interface_auto_subgroup_los;
905 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
906 if(rc != BCM_ERR_OK)
Shad Ansari01b0e652018-04-05 21:02:53 +0000907 return Status(grpc::StatusCode::INTERNAL, "LOS indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000908
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000909 rx_cfg.obj_type = BCMOLT_OBJ_ID_PON_INTERFACE;
910 rx_cfg.rx_cb = IfOperIndication;
911 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
912 rx_cfg.subgroup = bcmolt_pon_interface_auto_subgroup_state_change_completed;
913 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
914 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530915 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000916 "PON Interface operations state change indication subscribe failed");
Girish Gowdru7c4ec2d2018-10-25 00:29:54 -0700917
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000918 rx_cfg.obj_type = BCMOLT_OBJ_ID_NNI_INTERFACE;
919 rx_cfg.rx_cb = IfOperIndication;
920 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
921 rx_cfg.subgroup = bcmolt_nni_interface_auto_subgroup_state_change;
922 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
923 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530924 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000925 "NNI Interface operations state change indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000926
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000927 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
928 rx_cfg.rx_cb = OnuAlarmIndication;
929 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
930 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_xgpon_alarm;
931 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
932 if(rc != BCM_ERR_OK)
Shad Ansari01b0e652018-04-05 21:02:53 +0000933 return Status(grpc::StatusCode::INTERNAL, "onu alarm indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000934
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000935 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
936 rx_cfg.rx_cb = OnuAlarmIndication;
937 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
938 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_gpon_alarm;
939 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
940 if(rc != BCM_ERR_OK)
941 return Status(grpc::StatusCode::INTERNAL, "onu alarm indication subscribe failed");
942
943 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
944 rx_cfg.rx_cb = OnuDyingGaspIndication;
945 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
946 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_dgi;
947 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
948 if(rc != BCM_ERR_OK)
Shad Ansari01b0e652018-04-05 21:02:53 +0000949 return Status(grpc::StatusCode::INTERNAL, "onu dying-gasp indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000950
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000951 rx_cfg.obj_type = BCMOLT_OBJ_ID_PON_INTERFACE;
952 rx_cfg.rx_cb = OnuDiscoveryIndication;
953 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
954 rx_cfg.subgroup = bcmolt_pon_interface_auto_subgroup_onu_discovered;
955 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
956 if(rc != BCM_ERR_OK)
Shad Ansari01b0e652018-04-05 21:02:53 +0000957 return Status(grpc::StatusCode::INTERNAL, "onu discovery indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000958
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000959 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000960 rx_cfg.rx_cb = OnuStartupFailureIndication;
961 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
962 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_sufi;
963 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
964 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +0530965 return Status(grpc::StatusCode::INTERNAL,
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000966 "onu startup failure indication subscribe failed");
Shad Ansari01b0e652018-04-05 21:02:53 +0000967
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000968 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
969 rx_cfg.rx_cb = OnuSignalDegradeIndication;
970 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
971 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_sdi;
972 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
973 if(rc != BCM_ERR_OK)
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400974 return Status(grpc::StatusCode::INTERNAL, "onu sdi indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400975
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000976 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
977 rx_cfg.rx_cb = OnuDriftOfWindowIndication;
978 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
979 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_dowi;
980 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
981 if(rc != BCM_ERR_OK)
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400982 return Status(grpc::StatusCode::INTERNAL, "onu dowi indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400983
984 /* LOOCI indication */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000985 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
986 rx_cfg.rx_cb = OnuLossOfOmciChannelIndication;
987 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
988 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_looci;
989 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
990 if(rc != BCM_ERR_OK)
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400991 return Status(grpc::StatusCode::INTERNAL, "onu looci indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -0400992
993 /* SFI indication */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +0000994 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
995 rx_cfg.rx_cb = OnuSignalsFailureIndication;
996 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
997 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_sfi;
998 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
999 if(rc != BCM_ERR_OK)
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001000 return Status(grpc::StatusCode::INTERNAL, "onu sfi indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001001
1002 /* TIWI indication */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +00001003 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
1004 rx_cfg.rx_cb = OnuTransmissionInterferenceWarningIndication;
1005 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1006 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_tiwi;
1007 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1008 if(rc != BCM_ERR_OK)
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001009 return Status(grpc::StatusCode::INTERNAL, "onu tiwi indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001010
Girish Gowdra0c0b5c02019-12-16 14:11:08 +05301011 /* ONU Activation Completed Indication */
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +00001012 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
Girish Gowdra0c0b5c02019-12-16 14:11:08 +05301013 rx_cfg.rx_cb = OnuActivationCompletedIndication;
1014 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1015 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_onu_activation_completed;
1016 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1017 if(rc != BCM_ERR_OK)
1018 return Status(grpc::StatusCode::INTERNAL,
1019 "onu activation completed indication subscribe failed");
1020
1021 /* ONU Deactivation Completed Indication */
1022 rx_cfg.obj_type = BCMOLT_OBJ_ID_ONU;
1023 rx_cfg.rx_cb = OnuDeactivationCompletedIndication;
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +00001024 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1025 rx_cfg.subgroup = bcmolt_onu_auto_subgroup_onu_deactivation_completed;
1026 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1027 if(rc != BCM_ERR_OK)
Girish Gowdra0c0b5c02019-12-16 14:11:08 +05301028 return Status(grpc::StatusCode::INTERNAL,
1029 "onu deactivation indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001030
Thiyagarajan Subramani89fffc02019-05-13 21:33:20 +00001031 rx_cfg.obj_type = BCMOLT_OBJ_ID_FLOW;
1032 rx_cfg.rx_cb = PacketIndication;
1033 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1034 rx_cfg.subgroup = bcmolt_flow_auto_subgroup_receive_eth_packet;
1035 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1036 if(rc != BCM_ERR_OK)
1037 return Status(grpc::StatusCode::INTERNAL, "Packet indication subscribe failed");
Nicolas Palpacuerde4325b2018-07-03 11:18:42 -04001038
Girish Gowdra96461052019-11-22 20:13:59 +05301039 rx_cfg.obj_type = BCMOLT_OBJ_ID_ITUPON_ALLOC;
1040 rx_cfg.rx_cb = ItuPonAllocConfigCompletedInd;
1041 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1042 rx_cfg.subgroup = bcmolt_itupon_alloc_auto_subgroup_configuration_completed;
1043 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1044 if(rc != BCM_ERR_OK)
1045 return Status(grpc::StatusCode::INTERNAL, "ITU PON Alloc Configuration \
1046Complete Indication subscribe failed");
1047
Burak Gurdagc78b9e12019-11-29 11:14:51 +00001048 rx_cfg.obj_type = BCMOLT_OBJ_ID_GROUP;
1049 rx_cfg.rx_cb = GroupIndication;
1050 rx_cfg.flags = BCMOLT_AUTO_FLAGS_NONE;
1051 rx_cfg.subgroup = bcmolt_group_auto_subgroup_complete_members_update;
1052 rc = bcmolt_ind_subscribe(current_device, &rx_cfg);
1053 if(rc != BCM_ERR_OK)
1054 return Status(grpc::StatusCode::INTERNAL, "Complete members update indication subscribe failed");
1055
Shad Ansari01b0e652018-04-05 21:02:53 +00001056 subscribed = true;
1057
1058 return Status::OK;
1059}