blob: 91c9ced7c60216614ff366b6968db6eca8c58582 [file] [log] [blame]
Phaneendra Manda4c62c802019-03-06 21:37:49 +05301/*
2 * Copyright 2018-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 */
Girish Gowdru6a80bbd2019-07-02 07:36:09 -070016
Scott Bakerdbd960e2020-02-28 08:57:51 -080017//Package core provides the utility for olt devices, flows and statistics
18package core
Phaneendra Manda4c62c802019-03-06 21:37:49 +053019
20import (
cuilin20187b2a8c32019-03-26 19:52:28 -070021 "context"
Matt Jeanneretceea2e02020-03-27 14:19:57 -040022 "encoding/binary"
Matt Jeanneret1359c732019-08-01 21:40:02 -040023 "encoding/hex"
cuilin20187b2a8c32019-03-26 19:52:28 -070024 "fmt"
25 "io"
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -040026 "net"
cuilin20187b2a8c32019-03-26 19:52:28 -070027 "strconv"
28 "strings"
29 "sync"
30 "time"
Phaneendra Manda4c62c802019-03-06 21:37:49 +053031
Shrey Baid807a2a02020-04-09 12:52:45 +053032 "github.com/opencord/voltha-lib-go/v3/pkg/flows"
33
Matteo Scandolo945e4012019-12-12 14:16:11 -080034 "github.com/cenkalti/backoff/v3"
cuilin20187b2a8c32019-03-26 19:52:28 -070035 "github.com/gogo/protobuf/proto"
36 "github.com/golang/protobuf/ptypes"
Esin Karamanccb714b2019-11-29 15:02:06 +000037 "github.com/opencord/voltha-lib-go/v3/pkg/adapters/adapterif"
38 "github.com/opencord/voltha-lib-go/v3/pkg/log"
39 "github.com/opencord/voltha-lib-go/v3/pkg/pmmetrics"
Thomas Lee S94109f12020-03-03 16:39:29 +053040 "github.com/opencord/voltha-openolt-adapter/internal/pkg/olterrors"
Scott Bakerdbd960e2020-02-28 08:57:51 -080041 rsrcMgr "github.com/opencord/voltha-openolt-adapter/internal/pkg/resourcemanager"
Esin Karamanccb714b2019-11-29 15:02:06 +000042 "github.com/opencord/voltha-protos/v3/go/common"
43 ic "github.com/opencord/voltha-protos/v3/go/inter_container"
44 of "github.com/opencord/voltha-protos/v3/go/openflow_13"
45 oop "github.com/opencord/voltha-protos/v3/go/openolt"
46 "github.com/opencord/voltha-protos/v3/go/voltha"
cuilin20187b2a8c32019-03-26 19:52:28 -070047 "google.golang.org/grpc"
Devmalya Paula1efa642020-04-20 01:36:43 -040048 "google.golang.org/grpc/codes"
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -040049 "google.golang.org/grpc/status"
Phaneendra Manda4c62c802019-03-06 21:37:49 +053050)
51
salmansiddiqui7ac62132019-08-22 03:58:50 +000052// Constants for number of retries and for timeout
Manikkaraj kb1d51442019-07-23 10:41:02 -040053const (
salmansiddiqui7ac62132019-08-22 03:58:50 +000054 MaxRetry = 10
55 MaxTimeOutInMs = 500
Girish Gowdracefae192020-03-19 18:14:10 -070056 InvalidPort = 0xffffffff
Manikkaraj kb1d51442019-07-23 10:41:02 -040057)
58
Girish Gowdracefae192020-03-19 18:14:10 -070059// pendingFlowRemoveDataKey is key to pendingFlowRemoveDataPerSubscriber map
60type pendingFlowRemoveDataKey struct {
61 intfID uint32
62 onuID uint32
63 uniID uint32
64}
65
66// pendingFlowRemoveData is value stored in pendingFlowRemoveDataPerSubscriber map
67// This holds the number of pending flow removes and also a signal channel to
68// to indicate the receiver when all flow removes are handled
69type pendingFlowRemoveData struct {
70 pendingFlowRemoveCount uint32
71 allFlowsRemoved chan struct{}
72}
73
Phaneendra Manda4c62c802019-03-06 21:37:49 +053074//DeviceHandler will interact with the OLT device.
75type DeviceHandler struct {
cuilin20187b2a8c32019-03-26 19:52:28 -070076 device *voltha.Device
kdarapu381c6902019-07-31 18:23:16 +053077 coreProxy adapterif.CoreProxy
78 AdapterProxy adapterif.AdapterProxy
79 EventProxy adapterif.EventProxy
cuilin20187b2a8c32019-03-26 19:52:28 -070080 openOLT *OpenOLT
cuilin20187b2a8c32019-03-26 19:52:28 -070081 exitChannel chan int
82 lockDevice sync.RWMutex
manikkaraj kbf256be2019-03-25 00:13:48 +053083 Client oop.OpenoltClient
cuilin20187b2a8c32019-03-26 19:52:28 -070084 transitionMap *TransitionMap
85 clientCon *grpc.ClientConn
manikkaraj kbf256be2019-03-25 00:13:48 +053086 flowMgr *OpenOltFlowMgr
Devmalya Paulfb990a52019-07-09 10:01:49 -040087 eventMgr *OpenOltEventMgr
manikkaraj kbf256be2019-03-25 00:13:48 +053088 resourceMgr *rsrcMgr.OpenOltResourceMgr
Naga Manjunatha8dc9372019-10-31 23:01:18 +053089
Girish Gowdra3ab6d212020-03-24 17:33:15 -070090 discOnus sync.Map
91 onus sync.Map
92 portStats *OpenOltStatisticsMgr
93 metrics *pmmetrics.PmMetrics
94 stopCollector chan bool
95 stopHeartbeatCheck chan bool
96 activePorts sync.Map
97 stopIndications chan bool
98 isReadIndicationRoutineActive bool
Girish Gowdracefae192020-03-19 18:14:10 -070099
100 // pendingFlowRemoveDataPerSubscriber map is used to maintain the context on a per
101 // subscriber basis for the number of pending flow removes. This data is used
102 // to process all the flow removes for a subscriber before handling flow adds.
103 // Interleaving flow delete and flow add processing has known to cause PON resource
104 // management contentions on a per subscriber bases, so we need ensure ordering.
105 pendingFlowRemoveDataPerSubscriber map[pendingFlowRemoveDataKey]pendingFlowRemoveData
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700106}
107
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700108//OnuDevice represents ONU related info
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700109type OnuDevice struct {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700110 deviceID string
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700111 deviceType string
112 serialNumber string
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700113 onuID uint32
114 intfID uint32
115 proxyDeviceID string
A R Karthick1f85b802019-10-11 05:06:05 +0000116 uniPorts map[uint32]struct{}
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +0530117 losRaised bool
Devmalya Paula1efa642020-04-20 01:36:43 -0400118 rdiRaised bool
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700119}
120
Naga Manjunath7615e552019-10-11 22:35:47 +0530121var pmNames = []string{
122 "rx_bytes",
123 "rx_packets",
124 "rx_mcast_packets",
125 "rx_bcast_packets",
126 "tx_bytes",
127 "tx_packets",
128 "tx_mcast_packets",
129 "tx_bcast_packets",
130}
131
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700132//NewOnuDevice creates a new Onu Device
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +0530133func NewOnuDevice(devID, deviceTp, serialNum string, onuID, intfID uint32, proxyDevID string, losRaised bool) *OnuDevice {
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700134 var device OnuDevice
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700135 device.deviceID = devID
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700136 device.deviceType = deviceTp
137 device.serialNumber = serialNum
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700138 device.onuID = onuID
139 device.intfID = intfID
140 device.proxyDeviceID = proxyDevID
A R Karthick1f85b802019-10-11 05:06:05 +0000141 device.uniPorts = make(map[uint32]struct{})
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +0530142 device.losRaised = losRaised
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700143 return &device
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530144}
145
146//NewDeviceHandler creates a new device handler
kdarapu381c6902019-07-31 18:23:16 +0530147func NewDeviceHandler(cp adapterif.CoreProxy, ap adapterif.AdapterProxy, ep adapterif.EventProxy, device *voltha.Device, adapter *OpenOLT) *DeviceHandler {
cuilin20187b2a8c32019-03-26 19:52:28 -0700148 var dh DeviceHandler
149 dh.coreProxy = cp
Girish Gowdru0c588b22019-04-23 23:24:56 -0400150 dh.AdapterProxy = ap
Devmalya Paulfb990a52019-07-09 10:01:49 -0400151 dh.EventProxy = ep
cuilin20187b2a8c32019-03-26 19:52:28 -0700152 cloned := (proto.Clone(device)).(*voltha.Device)
cuilin20187b2a8c32019-03-26 19:52:28 -0700153 dh.device = cloned
154 dh.openOLT = adapter
155 dh.exitChannel = make(chan int, 1)
156 dh.lockDevice = sync.RWMutex{}
Naga Manjunath7615e552019-10-11 22:35:47 +0530157 dh.stopCollector = make(chan bool, 2)
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +0530158 dh.stopHeartbeatCheck = make(chan bool, 2)
Naga Manjunath7615e552019-10-11 22:35:47 +0530159 dh.metrics = pmmetrics.NewPmMetrics(cloned.Id, pmmetrics.Frequency(150), pmmetrics.FrequencyOverride(false), pmmetrics.Grouped(false), pmmetrics.Metrics(pmNames))
Chaitrashree G Sef088112020-02-03 21:39:27 -0500160 dh.activePorts = sync.Map{}
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400161 dh.stopIndications = make(chan bool, 1)
Girish Gowdracefae192020-03-19 18:14:10 -0700162 dh.pendingFlowRemoveDataPerSubscriber = make(map[pendingFlowRemoveDataKey]pendingFlowRemoveData)
163
cuilin20187b2a8c32019-03-26 19:52:28 -0700164 //TODO initialize the support classes.
165 return &dh
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530166}
167
168// start save the device to the data model
169func (dh *DeviceHandler) start(ctx context.Context) {
cuilin20187b2a8c32019-03-26 19:52:28 -0700170 dh.lockDevice.Lock()
171 defer dh.lockDevice.Unlock()
Girish Kumar2ad402b2020-03-20 19:45:12 +0000172 logger.Debugw("starting-device-agent", log.Fields{"device": dh.device})
cuilin20187b2a8c32019-03-26 19:52:28 -0700173 // Add the initial device to the local model
Girish Kumar2ad402b2020-03-20 19:45:12 +0000174 logger.Debug("device-agent-started")
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530175}
176
177// stop stops the device dh. Not much to do for now
178func (dh *DeviceHandler) stop(ctx context.Context) {
cuilin20187b2a8c32019-03-26 19:52:28 -0700179 dh.lockDevice.Lock()
180 defer dh.lockDevice.Unlock()
Girish Kumar2ad402b2020-03-20 19:45:12 +0000181 logger.Debug("stopping-device-agent")
cuilin20187b2a8c32019-03-26 19:52:28 -0700182 dh.exitChannel <- 1
Girish Kumar2ad402b2020-03-20 19:45:12 +0000183 logger.Debug("device-agent-stopped")
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530184}
185
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400186func macifyIP(ip net.IP) string {
187 if len(ip) > 0 {
188 oct1 := strconv.FormatInt(int64(ip[12]), 16)
189 oct2 := strconv.FormatInt(int64(ip[13]), 16)
190 oct3 := strconv.FormatInt(int64(ip[14]), 16)
191 oct4 := strconv.FormatInt(int64(ip[15]), 16)
192 return fmt.Sprintf("00:00:%02v:%02v:%02v:%02v", oct1, oct2, oct3, oct4)
193 }
194 return ""
195}
196
197func generateMacFromHost(host string) (string, error) {
198 var genmac string
199 var addr net.IP
200 var ips []string
201 var err error
202
Girish Kumar2ad402b2020-03-20 19:45:12 +0000203 logger.Debugw("generating-mac-from-host", log.Fields{"host": host})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400204
205 if addr = net.ParseIP(host); addr == nil {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000206 logger.Debugw("looking-up-hostname", log.Fields{"host": host})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400207
208 if ips, err = net.LookupHost(host); err == nil {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000209 logger.Debugw("dns-result-ips", log.Fields{"ips": ips})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400210 if addr = net.ParseIP(ips[0]); addr == nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000211 return "", olterrors.NewErrInvalidValue(log.Fields{"ip": ips[0]}, nil)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400212 }
213 genmac = macifyIP(addr)
Shrey Baid807a2a02020-04-09 12:52:45 +0530214 logger.Debugw("using-ip-as-mac",
215 log.Fields{"host": ips[0],
216 "mac": genmac})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400217 return genmac, nil
218 }
Girish Kumarf26e4882020-03-05 06:49:10 +0000219 return "", olterrors.NewErrAdapter("cannot-resolve-hostname-to-ip", log.Fields{"host": host}, err)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400220 }
221
222 genmac = macifyIP(addr)
Shrey Baid807a2a02020-04-09 12:52:45 +0530223 logger.Debugw("using-ip-as-mac",
224 log.Fields{"host": host,
225 "mac": genmac})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400226 return genmac, nil
227}
228
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530229func macAddressToUint32Array(mac string) []uint32 {
cuilin20187b2a8c32019-03-26 19:52:28 -0700230 slist := strings.Split(mac, ":")
231 result := make([]uint32, len(slist))
232 var err error
233 var tmp int64
234 for index, val := range slist {
235 if tmp, err = strconv.ParseInt(val, 16, 32); err != nil {
236 return []uint32{1, 2, 3, 4, 5, 6}
237 }
238 result[index] = uint32(tmp)
239 }
240 return result
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530241}
242
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700243//GetportLabel returns the label for the NNI and the PON port based on port number and port type
David K. Bainbridge794735f2020-02-11 21:01:37 -0800244func GetportLabel(portNum uint32, portType voltha.Port_PortType) (string, error) {
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530245
David K. Bainbridge794735f2020-02-11 21:01:37 -0800246 switch portType {
247 case voltha.Port_ETHERNET_NNI:
248 return fmt.Sprintf("nni-%d", portNum), nil
249 case voltha.Port_PON_OLT:
250 return fmt.Sprintf("pon-%d", portNum), nil
cuilin20187b2a8c32019-03-26 19:52:28 -0700251 }
David K. Bainbridge794735f2020-02-11 21:01:37 -0800252
Girish Kumarf26e4882020-03-05 06:49:10 +0000253 return "", olterrors.NewErrInvalidValue(log.Fields{"port-type": portType}, nil)
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530254}
255
David K. Bainbridge794735f2020-02-11 21:01:37 -0800256func (dh *DeviceHandler) addPort(intfID uint32, portType voltha.Port_PortType, state string) error {
Esin Karamanccb714b2019-11-29 15:02:06 +0000257 var operStatus common.OperStatus_Types
cuilin20187b2a8c32019-03-26 19:52:28 -0700258 if state == "up" {
259 operStatus = voltha.OperStatus_ACTIVE
kesavand39e0aa32020-01-28 20:58:50 -0500260 //populating the intfStatus map
Chaitrashree G Sef088112020-02-03 21:39:27 -0500261 dh.activePorts.Store(intfID, true)
cuilin20187b2a8c32019-03-26 19:52:28 -0700262 } else {
263 operStatus = voltha.OperStatus_DISCOVERED
Chaitrashree G Sef088112020-02-03 21:39:27 -0500264 dh.activePorts.Store(intfID, false)
cuilin20187b2a8c32019-03-26 19:52:28 -0700265 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700266 portNum := IntfIDToPortNo(intfID, portType)
Chaitrashree G Sc0878ec2020-05-21 04:59:53 -0400267 label, err := GetportLabel(intfID, portType)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800268 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000269 return olterrors.NewErrNotFound("port-label", log.Fields{"port-number": portNum, "port-type": portType}, err)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400270 }
Chaitrashree G Sded0a832020-01-09 20:21:48 -0500271
272 device, err := dh.coreProxy.GetDevice(context.TODO(), dh.device.Id, dh.device.Id)
273 if err != nil || device == nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000274 return olterrors.NewErrNotFound("device", log.Fields{"device-id": dh.device.Id}, err)
Chaitrashree G Sded0a832020-01-09 20:21:48 -0500275 }
276 if device.Ports != nil {
277 for _, dPort := range device.Ports {
278 if dPort.Type == portType && dPort.PortNo == portNum {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000279 logger.Debug("port-already-exists-updating-oper-status-of-port")
Chaitrashree G Sded0a832020-01-09 20:21:48 -0500280 if err := dh.coreProxy.PortStateUpdate(context.TODO(), dh.device.Id, portType, portNum, operStatus); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530281 return olterrors.NewErrAdapter("failed-to-update-port-state", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800282 "device-id": dh.device.Id,
283 "port-type": portType,
284 "port-number": portNum,
Girish Kumarf26e4882020-03-05 06:49:10 +0000285 "oper-status": operStatus}, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800286
Chaitrashree G Sded0a832020-01-09 20:21:48 -0500287 }
David K. Bainbridge794735f2020-02-11 21:01:37 -0800288 return nil
Chaitrashree G Sded0a832020-01-09 20:21:48 -0500289 }
290 }
291 }
Girish Gowdra631ef3d2020-06-15 10:45:52 -0700292 capacity := uint32(of.OfpPortFeatures_OFPPF_1GB_FD | of.OfpPortFeatures_OFPPF_FIBER)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400293 // Now create Port
294 port := &voltha.Port{
cuilin20187b2a8c32019-03-26 19:52:28 -0700295 PortNo: portNum,
296 Label: label,
297 Type: portType,
298 OperStatus: operStatus,
Girish Gowdra631ef3d2020-06-15 10:45:52 -0700299 OfpPort: &of.OfpPort{
300 HwAddr: macAddressToUint32Array(dh.device.MacAddress),
301 Config: 0,
302 State: uint32(of.OfpPortState_OFPPS_LIVE),
303 Curr: capacity,
304 Advertised: capacity,
305 Peer: capacity,
306 CurrSpeed: uint32(of.OfpPortFeatures_OFPPF_1GB_FD),
307 MaxSpeed: uint32(of.OfpPortFeatures_OFPPF_1GB_FD),
308 },
cuilin20187b2a8c32019-03-26 19:52:28 -0700309 }
Shrey Baid807a2a02020-04-09 12:52:45 +0530310 logger.Debugw("sending-port-update-to-core", log.Fields{"port": port})
cuilin20187b2a8c32019-03-26 19:52:28 -0700311 // Synchronous call to update device - this method is run in its own go routine
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700312 if err := dh.coreProxy.PortCreated(context.TODO(), dh.device.Id, port); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000313 return olterrors.NewErrAdapter("error-creating-port", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800314 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +0000315 "port-type": portType}, err)
Girish Gowdru1110ef22019-06-24 11:17:59 -0400316 }
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530317 go dh.updateLocalDevice()
318 return nil
319}
320
321func (dh *DeviceHandler) updateLocalDevice() error {
322 dh.lockDevice.Lock()
323 defer dh.lockDevice.Unlock()
324 device, err := dh.coreProxy.GetDevice(context.TODO(), dh.device.Id, dh.device.Id)
325 if err != nil || device == nil {
326 logger.Errorf("device", log.Fields{"device-id": dh.device.Id}, err)
327 return olterrors.NewErrNotFound("device", log.Fields{"device-id": dh.device.Id}, err)
328 }
329 dh.device = device
David K. Bainbridge794735f2020-02-11 21:01:37 -0800330 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530331}
332
David Bainbridge95a3fcf2020-06-09 10:49:31 -0700333// nolint: gocyclo
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530334// readIndications to read the indications from the OLT device
David K. Bainbridge794735f2020-02-11 21:01:37 -0800335func (dh *DeviceHandler) readIndications(ctx context.Context) error {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000336 defer logger.Debugw("indications-ended", log.Fields{"device-id": dh.device.Id})
Girish Gowdra3ab6d212020-03-24 17:33:15 -0700337 defer func() {
338 dh.lockDevice.Lock()
339 dh.isReadIndicationRoutineActive = false
340 dh.lockDevice.Unlock()
341 }()
Girish Gowdra3f974912020-03-23 20:35:18 -0700342 indications, err := dh.startOpenOltIndicationStream(ctx)
cuilin20187b2a8c32019-03-26 19:52:28 -0700343 if err != nil {
Girish Gowdra3f974912020-03-23 20:35:18 -0700344 return err
cuilin20187b2a8c32019-03-26 19:52:28 -0700345 }
Girish Gowdru5ba46c92019-04-25 05:00:05 -0400346 /* get device state */
npujarec5762e2020-01-01 14:08:48 +0530347 device, err := dh.coreProxy.GetDevice(ctx, dh.device.Id, dh.device.Id)
Girish Gowdru5ba46c92019-04-25 05:00:05 -0400348 if err != nil || device == nil {
349 /*TODO: needs to handle error scenarios */
Girish Kumarf26e4882020-03-05 06:49:10 +0000350 return olterrors.NewErrNotFound("device", log.Fields{"device-id": dh.device.Id}, err)
Girish Gowdru5ba46c92019-04-25 05:00:05 -0400351 }
Girish Gowdru5ba46c92019-04-25 05:00:05 -0400352
David Bainbridgef5879ca2019-12-13 21:17:54 +0000353 // Create an exponential backoff around re-enabling indications. The
354 // maximum elapsed time for the back off is set to 0 so that we will
355 // continue to retry. The max interval defaults to 1m, but is set
356 // here for code clarity
357 indicationBackoff := backoff.NewExponentialBackOff()
358 indicationBackoff.MaxElapsedTime = 0
359 indicationBackoff.MaxInterval = 1 * time.Minute
Girish Gowdra3f974912020-03-23 20:35:18 -0700360
Girish Gowdra3ab6d212020-03-24 17:33:15 -0700361 dh.lockDevice.Lock()
362 dh.isReadIndicationRoutineActive = true
363 dh.lockDevice.Unlock()
364
Girish Gowdra3f974912020-03-23 20:35:18 -0700365Loop:
cuilin20187b2a8c32019-03-26 19:52:28 -0700366 for {
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400367 select {
368 case <-dh.stopIndications:
Thomas Lee S985938d2020-05-04 11:40:41 +0530369 logger.Debugw("stopping-collecting-indications-for-olt", log.Fields{"deviceID:": dh.device.Id})
Girish Gowdra3f974912020-03-23 20:35:18 -0700370 break Loop
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400371 default:
372 indication, err := indications.Recv()
373 if err == io.EOF {
Shrey Baid807a2a02020-04-09 12:52:45 +0530374 logger.Infow("eof-for-indications",
375 log.Fields{"err": err,
Thomas Lee S985938d2020-05-04 11:40:41 +0530376 "device-id": dh.device.Id})
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400377 // Use an exponential back off to prevent getting into a tight loop
378 duration := indicationBackoff.NextBackOff()
379 if duration == backoff.Stop {
380 // If we reach a maximum then warn and reset the backoff
381 // timer and keep attempting.
Shrey Baid807a2a02020-04-09 12:52:45 +0530382 logger.Warnw("maximum-indication-backoff-reached--resetting-backoff-timer",
383 log.Fields{"max-indication-backoff": indicationBackoff.MaxElapsedTime,
Thomas Lee S985938d2020-05-04 11:40:41 +0530384 "device-id": dh.device.Id})
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400385 indicationBackoff.Reset()
386 }
David Bainbridge95a3fcf2020-06-09 10:49:31 -0700387
388 // On failure process a backoff timer while watching for stopIndications
389 // events
390 backoff := time.NewTimer(indicationBackoff.NextBackOff())
391 select {
392 case <-dh.stopIndications:
393 logger.Debugw("stopping-collecting-indications-for-olt", log.Fields{"deviceID:": dh.device.Id})
394 if !backoff.Stop() {
395 <-backoff.C
396 }
397 break Loop
398 case <-backoff.C:
399 // backoff expired continue
400 }
Girish Gowdra3f974912020-03-23 20:35:18 -0700401 if indications, err = dh.startOpenOltIndicationStream(ctx); err != nil {
402 return err
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400403 }
404 continue
David Bainbridgef5879ca2019-12-13 21:17:54 +0000405 }
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +0530406 if err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +0530407 logger.Errorw("read-indication-error",
408 log.Fields{"err": err,
Thomas Lee S985938d2020-05-04 11:40:41 +0530409 "device-id": dh.device.Id})
410 if device.AdminState == voltha.AdminState_DELETED {
Shrey Baid807a2a02020-04-09 12:52:45 +0530411 logger.Debug("device-deleted--stopping-the-read-indication-thread")
Girish Gowdra3f974912020-03-23 20:35:18 -0700412 break Loop
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400413 }
Girish Gowdra3f974912020-03-23 20:35:18 -0700414 // Close the stream, and re-initialize it
415 if err = indications.CloseSend(); err != nil {
416 // Ok to ignore here, because we landed here due to a problem on the stream
417 // In all probability, the closeSend call may fail
Shrey Baid807a2a02020-04-09 12:52:45 +0530418 logger.Debugw("error-closing-send stream--error-ignored",
419 log.Fields{"err": err,
Thomas Lee S985938d2020-05-04 11:40:41 +0530420 "device-id": dh.device.Id})
Girish Gowdra3f974912020-03-23 20:35:18 -0700421 }
422 if indications, err = dh.startOpenOltIndicationStream(ctx); err != nil {
423 return err
424 }
425 // once we re-initialized the indication stream, continue to read indications
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400426 continue
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +0530427 }
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400428 // Reset backoff if we have a successful receive
429 indicationBackoff.Reset()
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400430 // When OLT is admin down, ignore all indications.
Thomas Lee S985938d2020-05-04 11:40:41 +0530431 if device.AdminState == voltha.AdminState_DISABLED && !isIndicationAllowedDuringOltAdminDown(indication) {
Shrey Baid807a2a02020-04-09 12:52:45 +0530432 logger.Debugw("olt-is-admin-down, ignore indication",
433 log.Fields{"indication": indication,
Thomas Lee S985938d2020-05-04 11:40:41 +0530434 "device-id": dh.device.Id})
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400435 continue
Devmalya Paul495b94a2019-08-27 19:42:00 -0400436 }
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400437 dh.handleIndication(ctx, indication)
cuilin20187b2a8c32019-03-26 19:52:28 -0700438 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700439 }
Girish Gowdra3f974912020-03-23 20:35:18 -0700440 // Close the send stream
441 _ = indications.CloseSend() // Ok to ignore error, as we stopping the readIndication anyway
Girish Gowdra3ab6d212020-03-24 17:33:15 -0700442
Girish Gowdra3f974912020-03-23 20:35:18 -0700443 return nil
444}
445
446func (dh *DeviceHandler) startOpenOltIndicationStream(ctx context.Context) (oop.Openolt_EnableIndicationClient, error) {
447
448 indications, err := dh.Client.EnableIndication(ctx, new(oop.Empty))
449 if err != nil {
450 return nil, olterrors.NewErrCommunication("indication-read-failure", log.Fields{"device-id": dh.device.Id}, err).Log()
451 }
452 if indications == nil {
453 return nil, olterrors.NewErrInvalidValue(log.Fields{"indications": nil, "device-id": dh.device.Id}, nil).Log()
454 }
455
456 return indications, nil
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400457}
458
459// isIndicationAllowedDuringOltAdminDown returns true if the indication is allowed during OLT Admin down, else false
460func isIndicationAllowedDuringOltAdminDown(indication *oop.Indication) bool {
461 switch indication.Data.(type) {
462 case *oop.Indication_OltInd, *oop.Indication_IntfInd, *oop.Indication_IntfOperInd:
463 return true
464
465 default:
466 return false
467 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700468}
469
David K. Bainbridge794735f2020-02-11 21:01:37 -0800470func (dh *DeviceHandler) handleOltIndication(ctx context.Context, oltIndication *oop.OltIndication) error {
Daniele Rossi051466a2019-07-26 13:39:37 +0000471 raisedTs := time.Now().UnixNano()
Gamze Abakaa1a50522019-10-03 19:28:27 +0000472 if oltIndication.OperState == "up" && dh.transitionMap.currentDeviceState != deviceStateUp {
npujarec5762e2020-01-01 14:08:48 +0530473 dh.transitionMap.Handle(ctx, DeviceUpInd)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700474 } else if oltIndication.OperState == "down" {
npujarec5762e2020-01-01 14:08:48 +0530475 dh.transitionMap.Handle(ctx, DeviceDownInd)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700476 }
Daniele Rossi051466a2019-07-26 13:39:37 +0000477 // Send or clear Alarm
Thomas Lee S985938d2020-05-04 11:40:41 +0530478 if err := dh.eventMgr.oltUpDownIndication(oltIndication, dh.device.Id, raisedTs); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530479 return olterrors.NewErrAdapter("failed-indication", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +0530480 "device_id": dh.device.Id,
David K. Bainbridge794735f2020-02-11 21:01:37 -0800481 "indication": oltIndication,
Girish Kumarf26e4882020-03-05 06:49:10 +0000482 "timestamp": raisedTs}, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800483 }
484 return nil
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700485}
486
David K. Bainbridge794735f2020-02-11 21:01:37 -0800487// nolint: gocyclo
npujarec5762e2020-01-01 14:08:48 +0530488func (dh *DeviceHandler) handleIndication(ctx context.Context, indication *oop.Indication) {
Devmalya Paulfb990a52019-07-09 10:01:49 -0400489 raisedTs := time.Now().UnixNano()
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700490 switch indication.Data.(type) {
491 case *oop.Indication_OltInd:
David K. Bainbridge794735f2020-02-11 21:01:37 -0800492 if err := dh.handleOltIndication(ctx, indication.GetOltInd()); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530493 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "olt", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800494 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700495 case *oop.Indication_IntfInd:
496 intfInd := indication.GetIntfInd()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800497 go func() {
498 if err := dh.addPort(intfInd.GetIntfId(), voltha.Port_PON_OLT, intfInd.GetOperState()); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530499 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "interface", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800500 }
501 }()
Thomas Lee S985938d2020-05-04 11:40:41 +0530502 logger.Infow("received-interface-indication", log.Fields{"InterfaceInd": intfInd, "device-id": dh.device.Id})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700503 case *oop.Indication_IntfOperInd:
504 intfOperInd := indication.GetIntfOperInd()
505 if intfOperInd.GetType() == "nni" {
David K. Bainbridge794735f2020-02-11 21:01:37 -0800506 go func() {
507 if err := dh.addPort(intfOperInd.GetIntfId(), voltha.Port_ETHERNET_NNI, intfOperInd.GetOperState()); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530508 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "interface-oper-nni", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800509 }
510 }()
npujarec5762e2020-01-01 14:08:48 +0530511 dh.resourceMgr.AddNNIToKVStore(ctx, intfOperInd.GetIntfId())
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700512 } else if intfOperInd.GetType() == "pon" {
513 // TODO: Check what needs to be handled here for When PON PORT down, ONU will be down
514 // Handle pon port update
David K. Bainbridge794735f2020-02-11 21:01:37 -0800515 go func() {
516 if err := dh.addPort(intfOperInd.GetIntfId(), voltha.Port_PON_OLT, intfOperInd.GetOperState()); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530517 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "interface-oper-pon", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800518 }
519 }()
Thomas Lee S985938d2020-05-04 11:40:41 +0530520 go dh.eventMgr.oltIntfOperIndication(indication.GetIntfOperInd(), dh.device.Id, raisedTs)
cuilin20187b2a8c32019-03-26 19:52:28 -0700521 }
Shrey Baid807a2a02020-04-09 12:52:45 +0530522 logger.Infow("received-interface-oper-indication",
523 log.Fields{"interfaceOperInd": intfOperInd,
Thomas Lee S985938d2020-05-04 11:40:41 +0530524 "device-id": dh.device.Id})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700525 case *oop.Indication_OnuDiscInd:
526 onuDiscInd := indication.GetOnuDiscInd()
Thomas Lee S985938d2020-05-04 11:40:41 +0530527 logger.Infow("received-onu-discovery-indication", log.Fields{"OnuDiscInd": onuDiscInd, "device-id": dh.device.Id})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700528 sn := dh.stringifySerialNumber(onuDiscInd.SerialNumber)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800529 go func() {
530 if err := dh.onuDiscIndication(ctx, onuDiscInd, sn); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530531 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "onu-discovery", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800532 }
533 }()
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700534 case *oop.Indication_OnuInd:
535 onuInd := indication.GetOnuInd()
Thomas Lee S985938d2020-05-04 11:40:41 +0530536 logger.Infow("received-onu-indication", log.Fields{"OnuInd": onuInd, "device-id": dh.device.Id})
David K. Bainbridge794735f2020-02-11 21:01:37 -0800537 go func() {
538 if err := dh.onuIndication(onuInd); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530539 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "onu", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800540 }
541 }()
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700542 case *oop.Indication_OmciInd:
543 omciInd := indication.GetOmciInd()
Matteo Scandolo92186242020-06-12 10:54:18 -0700544 logger.Debugw("received-omci-indication", log.Fields{"intf-id": omciInd.IntfId, "onu-id": omciInd.OnuId, "device-id": dh.device.Id})
David K. Bainbridge794735f2020-02-11 21:01:37 -0800545 go func() {
546 if err := dh.omciIndication(omciInd); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530547 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "omci", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800548 }
549 }()
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700550 case *oop.Indication_PktInd:
551 pktInd := indication.GetPktInd()
Matteo Scandolo92186242020-06-12 10:54:18 -0700552 logger.Debugw("received-packet-indication", log.Fields{
553 "intf-type": pktInd.IntfId,
554 "intf-id": pktInd.IntfId,
555 "gem-port-id": pktInd.GemportId,
556 "port-no": pktInd.PortNo,
557 "device-id": dh.device.Id,
558 })
559
560 if logger.V(log.DebugLevel) {
561 logger.Debugw("received-packet-indication-packet", log.Fields{
562 "intf-type": pktInd.IntfId,
563 "intf-id": pktInd.IntfId,
564 "gem-port-id": pktInd.GemportId,
565 "port-no": pktInd.PortNo,
566 "packet": hex.EncodeToString(pktInd.Pkt),
567 "device-id": dh.device.Id,
568 })
569 }
570
David K. Bainbridge794735f2020-02-11 21:01:37 -0800571 go func() {
572 if err := dh.handlePacketIndication(ctx, pktInd); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530573 olterrors.NewErrAdapter("handle-indication-error", log.Fields{"type": "packet", "device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800574 }
575 }()
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700576 case *oop.Indication_PortStats:
577 portStats := indication.GetPortStats()
Naga Manjunath7615e552019-10-11 22:35:47 +0530578 go dh.portStats.PortStatisticsIndication(portStats, dh.resourceMgr.DevInfo.GetPonPorts())
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700579 case *oop.Indication_FlowStats:
580 flowStats := indication.GetFlowStats()
Thomas Lee S985938d2020-05-04 11:40:41 +0530581 logger.Infow("received-flow-stats", log.Fields{"FlowStats": flowStats, "device-id": dh.device.Id})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700582 case *oop.Indication_AlarmInd:
583 alarmInd := indication.GetAlarmInd()
Thomas Lee S985938d2020-05-04 11:40:41 +0530584 logger.Infow("received-alarm-indication", log.Fields{"AlarmInd": alarmInd, "device-id": dh.device.Id})
585 go dh.eventMgr.ProcessEvents(alarmInd, dh.device.Id, raisedTs)
cuilin20187b2a8c32019-03-26 19:52:28 -0700586 }
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530587}
588
589// doStateUp handle the olt up indication and update to voltha core
npujarec5762e2020-01-01 14:08:48 +0530590func (dh *DeviceHandler) doStateUp(ctx context.Context) error {
Thomas Lee S85f37312020-04-03 17:06:12 +0530591 //starting the stat collector
592 go startCollector(dh)
593
Girish Gowdru0c588b22019-04-23 23:24:56 -0400594 // Synchronous call to update device state - this method is run in its own go routine
npujarec5762e2020-01-01 14:08:48 +0530595 if err := dh.coreProxy.DeviceStateUpdate(ctx, dh.device.Id, voltha.ConnectStatus_REACHABLE,
Girish Gowdru0c588b22019-04-23 23:24:56 -0400596 voltha.OperStatus_ACTIVE); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000597 return olterrors.NewErrAdapter("device-update-failed", log.Fields{"device-id": dh.device.Id}, err)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400598 }
599 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530600}
601
602// doStateDown handle the olt down indication
npujarec5762e2020-01-01 14:08:48 +0530603func (dh *DeviceHandler) doStateDown(ctx context.Context) error {
serkant.uluderya245caba2019-09-24 23:15:29 -0700604 dh.lockDevice.Lock()
605 defer dh.lockDevice.Unlock()
Thomas Lee S985938d2020-05-04 11:40:41 +0530606 logger.Debugw("do-state-down-start", log.Fields{"device-id": dh.device.Id})
Girish Gowdrud4245152019-05-10 00:47:31 -0400607
npujarec5762e2020-01-01 14:08:48 +0530608 device, err := dh.coreProxy.GetDevice(ctx, dh.device.Id, dh.device.Id)
Girish Gowdrud4245152019-05-10 00:47:31 -0400609 if err != nil || device == nil {
610 /*TODO: needs to handle error scenarios */
Girish Kumarf26e4882020-03-05 06:49:10 +0000611 return olterrors.NewErrNotFound("device", log.Fields{"device-id": dh.device.Id}, err)
Girish Gowdrud4245152019-05-10 00:47:31 -0400612 }
613
614 cloned := proto.Clone(device).(*voltha.Device)
Girish Gowdrud4245152019-05-10 00:47:31 -0400615
616 //Update the device oper state and connection status
617 cloned.OperStatus = voltha.OperStatus_UNKNOWN
Girish Gowdrud4245152019-05-10 00:47:31 -0400618 dh.device = cloned
619
David K. Bainbridge794735f2020-02-11 21:01:37 -0800620 if err = dh.coreProxy.DeviceStateUpdate(ctx, cloned.Id, cloned.ConnectStatus, cloned.OperStatus); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000621 return olterrors.NewErrAdapter("state-update-failed", log.Fields{"device-id": device.Id}, err)
Girish Gowdrud4245152019-05-10 00:47:31 -0400622 }
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -0400623
624 //get the child device for the parent device
npujarec5762e2020-01-01 14:08:48 +0530625 onuDevices, err := dh.coreProxy.GetChildDevices(ctx, dh.device.Id)
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -0400626 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000627 return olterrors.NewErrAdapter("child-device-fetch-failed", log.Fields{"device-id": dh.device.Id}, err)
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -0400628 }
629 for _, onuDevice := range onuDevices.Items {
630
631 // Update onu state as down in onu adapter
632 onuInd := oop.OnuIndication{}
633 onuInd.OperState = "down"
David K. Bainbridge794735f2020-02-11 21:01:37 -0800634 err := dh.AdapterProxy.SendInterAdapterMessage(ctx, &onuInd, ic.InterAdapterMessageType_ONU_IND_REQUEST,
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700635 "openolt", onuDevice.Type, onuDevice.Id, onuDevice.ProxyAddress.DeviceId, "")
David K. Bainbridge794735f2020-02-11 21:01:37 -0800636 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530637 olterrors.NewErrCommunication("inter-adapter-send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800638 "source": "openolt",
639 "onu-indicator": onuInd,
640 "device-type": onuDevice.Type,
641 "device-id": onuDevice.Id}, err).LogAt(log.ErrorLevel)
serkant.uluderya245caba2019-09-24 23:15:29 -0700642 //Do not return here and continue to process other ONUs
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700643 }
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -0400644 }
serkant.uluderya245caba2019-09-24 23:15:29 -0700645 /* Discovered ONUs entries need to be cleared , since after OLT
646 is up, it starts sending discovery indications again*/
Naga Manjunatha8dc9372019-10-31 23:01:18 +0530647 dh.discOnus = sync.Map{}
Girish Kumar2ad402b2020-03-20 19:45:12 +0000648 logger.Debugw("do-state-down-end", log.Fields{"device-id": device.Id})
cuilin20187b2a8c32019-03-26 19:52:28 -0700649 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530650}
651
652// doStateInit dial the grpc before going to init state
npujarec5762e2020-01-01 14:08:48 +0530653func (dh *DeviceHandler) doStateInit(ctx context.Context) error {
Girish Gowdru0c588b22019-04-23 23:24:56 -0400654 var err error
David K. Bainbridge794735f2020-02-11 21:01:37 -0800655 if dh.clientCon, err = grpc.Dial(dh.device.GetHostAndPort(), grpc.WithInsecure(), grpc.WithBlock()); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530656 return olterrors.NewErrCommunication("dial-failure", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +0530657 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +0000658 "host-and-port": dh.device.GetHostAndPort()}, err)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400659 }
660 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530661}
662
663// postInit create olt client instance to invoke RPC on the olt device
npujarec5762e2020-01-01 14:08:48 +0530664func (dh *DeviceHandler) postInit(ctx context.Context) error {
Girish Gowdru0c588b22019-04-23 23:24:56 -0400665 dh.Client = oop.NewOpenoltClient(dh.clientCon)
npujarec5762e2020-01-01 14:08:48 +0530666 dh.transitionMap.Handle(ctx, GrpcConnected)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400667 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530668}
669
670// doStateConnected get the device info and update to voltha core
npujarec5762e2020-01-01 14:08:48 +0530671func (dh *DeviceHandler) doStateConnected(ctx context.Context) error {
Thomas Lee S985938d2020-05-04 11:40:41 +0530672 var err error
673 logger.Debugw("olt-device-connected", log.Fields{"device-id": dh.device.Id})
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400674
675 // Case where OLT is disabled and then rebooted.
Thomas Lee S985938d2020-05-04 11:40:41 +0530676 device, err := dh.coreProxy.GetDevice(ctx, dh.device.Id, dh.device.Id)
677 if err != nil || device == nil {
678 /*TODO: needs to handle error scenarios */
679 return olterrors.NewErrAdapter("device-fetch-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
680 }
681 if device.AdminState == voltha.AdminState_DISABLED {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000682 logger.Debugln("do-state-connected--device-admin-state-down")
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400683
684 cloned := proto.Clone(device).(*voltha.Device)
685 cloned.ConnectStatus = voltha.ConnectStatus_REACHABLE
686 cloned.OperStatus = voltha.OperStatus_UNKNOWN
687 dh.device = cloned
Thomas Lee S985938d2020-05-04 11:40:41 +0530688 if err = dh.coreProxy.DeviceStateUpdate(ctx, cloned.Id, cloned.ConnectStatus, cloned.OperStatus); err != nil {
689 return olterrors.NewErrAdapter("device-state-update-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400690 }
691
Chaitrashree G S44124192019-08-07 20:21:36 -0400692 // Since the device was disabled before the OLT was rebooted, enforce the OLT to be Disabled after re-connection.
npujarec5762e2020-01-01 14:08:48 +0530693 _, err = dh.Client.DisableOlt(ctx, new(oop.Empty))
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400694 if err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530695 return olterrors.NewErrAdapter("olt-disable-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400696 }
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400697 // We should still go ahead an initialize various device handler modules so that when OLT is re-enabled, we have
698 // all the modules initialized and ready to handle incoming ONUs.
699
Thomas Lee S985938d2020-05-04 11:40:41 +0530700 err = dh.initializeDeviceHandlerModules(ctx)
701 if err != nil {
702 return olterrors.NewErrAdapter("device-handler-initialization-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400703 }
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400704
705 // Start reading indications
David K. Bainbridge794735f2020-02-11 21:01:37 -0800706 go func() {
Thomas Lee S985938d2020-05-04 11:40:41 +0530707 if err = dh.readIndications(ctx); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530708 olterrors.NewErrAdapter("indication-read-failure", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800709 }
710 }()
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -0400711 return nil
712 }
713
Thomas Lee S985938d2020-05-04 11:40:41 +0530714 device, err = dh.coreProxy.GetDevice(context.TODO(), dh.device.Id, dh.device.Id)
Girish Gowdrud4245152019-05-10 00:47:31 -0400715 if err != nil || device == nil {
716 /*TODO: needs to handle error scenarios */
Girish Kumarf26e4882020-03-05 06:49:10 +0000717 return olterrors.NewErrAdapter("fetch-device-failed", log.Fields{"device-id": dh.device.Id}, err)
Girish Gowdrud4245152019-05-10 00:47:31 -0400718 }
kesavand39e0aa32020-01-28 20:58:50 -0500719 dh.populateActivePorts(device)
kdarapu1afeceb2020-02-12 01:38:09 -0500720 if err := dh.disableAdminDownPorts(device); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000721 return olterrors.NewErrAdapter("port-status-update-failed", log.Fields{"device": device}, err)
Girish Gowdrud4245152019-05-10 00:47:31 -0400722 }
723
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400724 if err := dh.initializeDeviceHandlerModules(ctx); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +0530725 return olterrors.NewErrAdapter("device-handler-initialization-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
Girish Gowdru0c588b22019-04-23 23:24:56 -0400726 }
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530727
cuilin20187b2a8c32019-03-26 19:52:28 -0700728 // Start reading indications
David K. Bainbridge794735f2020-02-11 21:01:37 -0800729 go func() {
730 if err := dh.readIndications(ctx); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530731 olterrors.NewErrAdapter("read-indications-failure", log.Fields{"device-id": dh.device.Id}, err).Log()
David K. Bainbridge794735f2020-02-11 21:01:37 -0800732 }
733 }()
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530734 go dh.updateLocalDevice()
Rohan Agrawalda5e0b22020-05-20 11:10:26 +0000735
736 if device.PmConfigs != nil {
737 dh.UpdatePmConfig(device.PmConfigs)
738 }
cuilin20187b2a8c32019-03-26 19:52:28 -0700739 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530740}
741
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400742func (dh *DeviceHandler) initializeDeviceHandlerModules(ctx context.Context) error {
743 deviceInfo, err := dh.populateDeviceInfo()
744
745 if err != nil {
746 return olterrors.NewErrAdapter("populate-device-info-failed", log.Fields{"device-id": dh.device.Id}, err)
747 }
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400748 // Instantiate resource manager
Neha Sharma3f221ae2020-04-29 19:02:12 +0000749 if dh.resourceMgr = rsrcMgr.NewResourceMgr(ctx, dh.device.Id, dh.openOLT.KVStoreAddress, dh.openOLT.KVStoreType, dh.device.Type, deviceInfo); dh.resourceMgr == nil {
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400750 return olterrors.ErrResourceManagerInstantiating
751 }
752
753 // Instantiate flow manager
754 if dh.flowMgr = NewFlowManager(ctx, dh, dh.resourceMgr); dh.flowMgr == nil {
755 return olterrors.ErrResourceManagerInstantiating
756
757 }
758 /* TODO: Instantiate Alarm , stats , BW managers */
759 /* Instantiating Event Manager to handle Alarms and KPIs */
760 dh.eventMgr = NewEventMgr(dh.EventProxy, dh)
761
762 // Stats config for new device
763 dh.portStats = NewOpenOltStatsMgr(dh)
764
765 return nil
766
767}
768
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400769func (dh *DeviceHandler) populateDeviceInfo() (*oop.DeviceInfo, error) {
770 var err error
771 var deviceInfo *oop.DeviceInfo
772
773 deviceInfo, err = dh.Client.GetDeviceInfo(context.Background(), new(oop.Empty))
774
775 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000776 return nil, olterrors.NewErrPersistence("get", "device", 0, nil, err)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400777 }
778 if deviceInfo == nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000779 return nil, olterrors.NewErrInvalidValue(log.Fields{"device": nil}, nil)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400780 }
781
Thomas Lee S985938d2020-05-04 11:40:41 +0530782 logger.Debugw("fetched-device-info", log.Fields{"deviceInfo": deviceInfo, "device-id": dh.device.Id})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400783 dh.device.Root = true
784 dh.device.Vendor = deviceInfo.Vendor
785 dh.device.Model = deviceInfo.Model
786 dh.device.SerialNumber = deviceInfo.DeviceSerialNumber
787 dh.device.HardwareVersion = deviceInfo.HardwareVersion
788 dh.device.FirmwareVersion = deviceInfo.FirmwareVersion
789
790 if deviceInfo.DeviceId == "" {
Girish Kumar2ad402b2020-03-20 19:45:12 +0000791 logger.Warnw("no-device-id-provided-using-host", log.Fields{"hostport": dh.device.GetHostAndPort()})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400792 host := strings.Split(dh.device.GetHostAndPort(), ":")[0]
793 genmac, err := generateMacFromHost(host)
794 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000795 return nil, olterrors.NewErrAdapter("failed-to-generate-mac-host", log.Fields{"host": host}, err)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400796 }
Girish Kumar2ad402b2020-03-20 19:45:12 +0000797 logger.Debugw("using-host-for-mac-address", log.Fields{"host": host, "mac": genmac})
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400798 dh.device.MacAddress = genmac
799 } else {
800 dh.device.MacAddress = deviceInfo.DeviceId
801 }
802
803 // Synchronous call to update device - this method is run in its own go routine
804 if err := dh.coreProxy.DeviceUpdate(context.TODO(), dh.device); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000805 return nil, olterrors.NewErrAdapter("device-update-failed", log.Fields{"device-id": dh.device.Id}, err)
Matt Jeanneretf4fdcd72019-07-19 20:03:23 -0400806 }
807
808 return deviceInfo, nil
809}
810
Naga Manjunath7615e552019-10-11 22:35:47 +0530811func startCollector(dh *DeviceHandler) {
Shrey Baid807a2a02020-04-09 12:52:45 +0530812 logger.Debugf("starting-collector")
Naga Manjunath7615e552019-10-11 22:35:47 +0530813 for {
814 select {
815 case <-dh.stopCollector:
Thomas Lee S985938d2020-05-04 11:40:41 +0530816 logger.Debugw("stopping-collector-for-olt", log.Fields{"deviceID:": dh.device.Id})
Naga Manjunath7615e552019-10-11 22:35:47 +0530817 return
Rohan Agrawalda5e0b22020-05-20 11:10:26 +0000818 case <-time.After(time.Duration(dh.metrics.ToPmConfigs().DefaultFreq) * time.Second):
Girish Gowdra34815db2020-05-11 17:18:04 -0700819
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530820 ports := make([]*voltha.Port, len(dh.device.Ports))
821 copy(ports, dh.device.Ports)
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530822 for _, port := range ports {
823 // NNI Stats
824 if port.Type == voltha.Port_ETHERNET_NNI {
825 intfID := PortNoToIntfID(port.PortNo, voltha.Port_ETHERNET_NNI)
826 cmnni := dh.portStats.collectNNIMetrics(intfID)
827 logger.Debugw("collect-nni-metrics", log.Fields{"metrics": cmnni})
Girish Gowdra34815db2020-05-11 17:18:04 -0700828 go dh.portStats.publishMetrics(cmnni, port, dh.device.Id, dh.device.Type)
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530829 logger.Debugw("publish-nni-metrics", log.Fields{"nni-port": port.Label})
830 }
831 // PON Stats
832 if port.Type == voltha.Port_PON_OLT {
833 intfID := PortNoToIntfID(port.PortNo, voltha.Port_PON_OLT)
834 if val, ok := dh.activePorts.Load(intfID); ok && val == true {
835 cmpon := dh.portStats.collectPONMetrics(intfID)
836 logger.Debugw("collect-pon-metrics", log.Fields{"metrics": cmpon})
Girish Gowdra34815db2020-05-11 17:18:04 -0700837 go dh.portStats.publishMetrics(cmpon, port, dh.device.Id, dh.device.Type)
Kishore Darapuaaf9c102020-05-04 13:06:57 +0530838 }
839 logger.Debugw("publish-pon-metrics", log.Fields{"pon-port": port.Label})
Chaitrashree G Sef088112020-02-03 21:39:27 -0500840 }
Naga Manjunath7615e552019-10-11 22:35:47 +0530841 }
842 }
843 }
844}
845
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700846//AdoptDevice adopts the OLT device
npujarec5762e2020-01-01 14:08:48 +0530847func (dh *DeviceHandler) AdoptDevice(ctx context.Context, device *voltha.Device) {
Girish Gowdru0c588b22019-04-23 23:24:56 -0400848 dh.transitionMap = NewTransitionMap(dh)
Shrey Baid807a2a02020-04-09 12:52:45 +0530849 logger.Infow("adopt-device", log.Fields{"device-id": device.Id, "Address": device.GetHostAndPort()})
npujarec5762e2020-01-01 14:08:48 +0530850 dh.transitionMap.Handle(ctx, DeviceInit)
Naga Manjunath7615e552019-10-11 22:35:47 +0530851
852 // Now, set the initial PM configuration for that device
853 if err := dh.coreProxy.DevicePMConfigUpdate(nil, dh.metrics.ToPmConfigs()); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530854 olterrors.NewErrAdapter("error-updating-performance-metrics", log.Fields{"device-id": device.Id}, err).LogAt(log.ErrorLevel)
Naga Manjunath7615e552019-10-11 22:35:47 +0530855 }
856
Chaitrashree G Sa4649252020-03-11 21:24:11 -0400857 go startHeartbeatCheck(ctx, dh)
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530858}
859
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700860//GetOfpDeviceInfo Gets the Ofp information of the given device
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530861func (dh *DeviceHandler) GetOfpDeviceInfo(device *voltha.Device) (*ic.SwitchCapability, error) {
cuilin20187b2a8c32019-03-26 19:52:28 -0700862 return &ic.SwitchCapability{
863 Desc: &of.OfpDesc{
Devmalya Paul70dd4972019-06-10 15:19:17 +0530864 MfrDesc: "VOLTHA Project",
cuilin20187b2a8c32019-03-26 19:52:28 -0700865 HwDesc: "open_pon",
866 SwDesc: "open_pon",
867 SerialNum: dh.device.SerialNumber,
868 },
869 SwitchFeatures: &of.OfpSwitchFeatures{
870 NBuffers: 256,
871 NTables: 2,
872 Capabilities: uint32(of.OfpCapabilities_OFPC_FLOW_STATS |
873 of.OfpCapabilities_OFPC_TABLE_STATS |
874 of.OfpCapabilities_OFPC_PORT_STATS |
875 of.OfpCapabilities_OFPC_GROUP_STATS),
876 },
877 }, nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530878}
879
David K. Bainbridge794735f2020-02-11 21:01:37 -0800880func (dh *DeviceHandler) omciIndication(omciInd *oop.OmciIndication) error {
Matteo Scandolo92186242020-06-12 10:54:18 -0700881 logger.Debugw("omci-indication", log.Fields{"intf-id": omciInd.IntfId, "onu-id": omciInd.OnuId, "device-id": dh.device.Id})
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700882 var deviceType string
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700883 var deviceID string
884 var proxyDeviceID string
cuilin20187b2a8c32019-03-26 19:52:28 -0700885
Matt Jeanneretceea2e02020-03-27 14:19:57 -0400886 transid := extractOmciTransactionID(omciInd.Pkt)
Matteo Scandolo92186242020-06-12 10:54:18 -0700887 if logger.V(log.DebugLevel) {
888 logger.Debugw("recv-omci-msg", log.Fields{"intf-id": omciInd.IntfId, "onu-id": omciInd.OnuId, "device-id": dh.device.Id,
889 "omci-transaction-id": transid, "omci-msg": hex.EncodeToString(omciInd.Pkt)})
890 }
Matt Jeanneretceea2e02020-03-27 14:19:57 -0400891
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700892 onuKey := dh.formOnuKey(omciInd.IntfId, omciInd.OnuId)
Naga Manjunatha8dc9372019-10-31 23:01:18 +0530893
894 if onuInCache, ok := dh.onus.Load(onuKey); !ok {
895
Matteo Scandolo92186242020-06-12 10:54:18 -0700896 logger.Debugw("omci-indication-for-a-device-not-in-cache.", log.Fields{"intf-id": omciInd.IntfId, "onu-id": omciInd.OnuId, "device-id": dh.device.Id})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700897 ponPort := IntfIDToPortNo(omciInd.GetIntfId(), voltha.Port_PON_OLT)
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700898 kwargs := make(map[string]interface{})
899 kwargs["onu_id"] = omciInd.OnuId
900 kwargs["parent_port_no"] = ponPort
cuilin20187b2a8c32019-03-26 19:52:28 -0700901
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700902 onuDevice, err := dh.coreProxy.GetChildDevice(context.TODO(), dh.device.Id, kwargs)
903 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530904 return olterrors.NewErrNotFound("onu", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -0700905 "intf-id": omciInd.IntfId,
906 "onu-id": omciInd.OnuId}, err)
cuilin20187b2a8c32019-03-26 19:52:28 -0700907 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700908 deviceType = onuDevice.Type
909 deviceID = onuDevice.Id
910 proxyDeviceID = onuDevice.ProxyAddress.DeviceId
911 //if not exist in cache, then add to cache.
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +0530912 dh.onus.Store(onuKey, NewOnuDevice(deviceID, deviceType, onuDevice.SerialNumber, omciInd.OnuId, omciInd.IntfId, proxyDeviceID, false))
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700913 } else {
914 //found in cache
Matteo Scandolo92186242020-06-12 10:54:18 -0700915 logger.Debugw("omci-indication-for-a-device-in-cache.", log.Fields{"intf-id": omciInd.IntfId, "onu-id": omciInd.OnuId, "device-id": dh.device.Id})
Naga Manjunatha8dc9372019-10-31 23:01:18 +0530916 deviceType = onuInCache.(*OnuDevice).deviceType
917 deviceID = onuInCache.(*OnuDevice).deviceID
918 proxyDeviceID = onuInCache.(*OnuDevice).proxyDeviceID
cuilin20187b2a8c32019-03-26 19:52:28 -0700919 }
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700920
921 omciMsg := &ic.InterAdapterOmciMessage{Message: omciInd.Pkt}
David K. Bainbridge794735f2020-02-11 21:01:37 -0800922 if err := dh.AdapterProxy.SendInterAdapterMessage(context.Background(), omciMsg,
Thomas Lee S985938d2020-05-04 11:40:41 +0530923 ic.InterAdapterMessageType_OMCI_REQUEST, dh.device.Type, deviceType,
David K. Bainbridge794735f2020-02-11 21:01:37 -0800924 deviceID, proxyDeviceID, ""); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530925 return olterrors.NewErrCommunication("omci-request", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +0530926 "source": dh.device.Type,
David K. Bainbridge794735f2020-02-11 21:01:37 -0800927 "destination": deviceType,
928 "onu-id": deviceID,
Girish Kumarf26e4882020-03-05 06:49:10 +0000929 "proxy-device-id": proxyDeviceID}, err)
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700930 }
David K. Bainbridge794735f2020-02-11 21:01:37 -0800931 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530932}
933
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700934//ProcessInterAdapterMessage sends the proxied messages to the target device
935// If the proxy address is not found in the unmarshalled message, it first fetches the onu device for which the message
936// is meant, and then send the unmarshalled omci message to this onu
937func (dh *DeviceHandler) ProcessInterAdapterMessage(msg *ic.InterAdapterMessage) error {
Shrey Baid807a2a02020-04-09 12:52:45 +0530938 logger.Debugw("process-inter-adapter-message", log.Fields{"msgID": msg.Header.Id})
cuilin20187b2a8c32019-03-26 19:52:28 -0700939 if msg.Header.Type == ic.InterAdapterMessageType_OMCI_REQUEST {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700940 msgID := msg.Header.Id
cuilin20187b2a8c32019-03-26 19:52:28 -0700941 fromTopic := msg.Header.FromTopic
942 toTopic := msg.Header.ToTopic
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700943 toDeviceID := msg.Header.ToDeviceId
944 proxyDeviceID := msg.Header.ProxyDeviceId
cuilin20187b2a8c32019-03-26 19:52:28 -0700945
Shrey Baid807a2a02020-04-09 12:52:45 +0530946 logger.Debugw("omci-request-message-header", log.Fields{"msgID": msgID, "fromTopic": fromTopic, "toTopic": toTopic, "toDeviceID": toDeviceID, "proxyDeviceID": proxyDeviceID})
cuilin20187b2a8c32019-03-26 19:52:28 -0700947
948 msgBody := msg.GetBody()
949
950 omciMsg := &ic.InterAdapterOmciMessage{}
951 if err := ptypes.UnmarshalAny(msgBody, omciMsg); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +0000952 return olterrors.NewErrAdapter("cannot-unmarshal-omci-msg-body", log.Fields{"msgbody": msgBody}, err)
cuilin20187b2a8c32019-03-26 19:52:28 -0700953 }
954
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700955 if omciMsg.GetProxyAddress() == nil {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700956 onuDevice, err := dh.coreProxy.GetDevice(context.TODO(), dh.device.Id, toDeviceID)
957 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530958 return olterrors.NewErrNotFound("onu", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800959 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +0000960 "onu-device-id": toDeviceID}, err)
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700961 }
Shrey Baid807a2a02020-04-09 12:52:45 +0530962 logger.Debugw("device-retrieved-from-core", log.Fields{"msgID": msgID, "fromTopic": fromTopic, "toTopic": toTopic, "toDeviceID": toDeviceID, "proxyDeviceID": proxyDeviceID})
David K. Bainbridge794735f2020-02-11 21:01:37 -0800963 if err := dh.sendProxiedMessage(onuDevice, omciMsg); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530964 return olterrors.NewErrCommunication("send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800965 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +0000966 "onu-device-id": toDeviceID}, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800967 }
cuilin20187b2a8c32019-03-26 19:52:28 -0700968 } else {
Shrey Baid807a2a02020-04-09 12:52:45 +0530969 logger.Debugw("proxy-address-found-in-omci-message", log.Fields{"msgID": msgID, "fromTopic": fromTopic, "toTopic": toTopic, "toDeviceID": toDeviceID, "proxyDeviceID": proxyDeviceID})
David K. Bainbridge794735f2020-02-11 21:01:37 -0800970 if err := dh.sendProxiedMessage(nil, omciMsg); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +0530971 return olterrors.NewErrCommunication("send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -0800972 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +0000973 "onu-device-id": toDeviceID}, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -0800974 }
cuilin20187b2a8c32019-03-26 19:52:28 -0700975 }
976
977 } else {
Girish Kumarf26e4882020-03-05 06:49:10 +0000978 return olterrors.NewErrInvalidValue(log.Fields{"inter-adapter-message-type": msg.Header.Type}, nil)
cuilin20187b2a8c32019-03-26 19:52:28 -0700979 }
980 return nil
Phaneendra Manda4c62c802019-03-06 21:37:49 +0530981}
982
David K. Bainbridge794735f2020-02-11 21:01:37 -0800983func (dh *DeviceHandler) sendProxiedMessage(onuDevice *voltha.Device, omciMsg *ic.InterAdapterOmciMessage) error {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700984 var intfID uint32
985 var onuID uint32
Esin Karamanccb714b2019-11-29 15:02:06 +0000986 var connectStatus common.ConnectStatus_Types
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700987 if onuDevice != nil {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700988 intfID = onuDevice.ProxyAddress.GetChannelId()
989 onuID = onuDevice.ProxyAddress.GetOnuId()
990 connectStatus = onuDevice.ConnectStatus
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700991 } else {
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700992 intfID = omciMsg.GetProxyAddress().GetChannelId()
993 onuID = omciMsg.GetProxyAddress().GetOnuId()
994 connectStatus = omciMsg.GetConnectStatus()
Mahir Gunyela3f9add2019-06-06 15:13:19 -0700995 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -0700996 if connectStatus != voltha.ConnectStatus_REACHABLE {
Matteo Scandolo92186242020-06-12 10:54:18 -0700997 logger.Debugw("onu-not-reachable--cannot-send-omci", log.Fields{"intf-id": intfID, "onu-id": onuID})
David K. Bainbridge794735f2020-02-11 21:01:37 -0800998
Thomas Lee S94109f12020-03-03 16:39:29 +0530999 return olterrors.NewErrCommunication("unreachable", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001000 "intf-id": intfID,
1001 "onu-id": onuID}, nil)
cuilin20187b2a8c32019-03-26 19:52:28 -07001002 }
1003
Matt Jeanneretceea2e02020-03-27 14:19:57 -04001004 // TODO: OpenOLT Agent oop.OmciMsg expects a hex encoded string for OMCI packets rather than the actual bytes.
1005 // Fix this in the agent and then we can pass byte array as Pkt: omciMsg.Message.
lcuie24ef182019-04-29 22:58:36 -07001006 var omciMessage *oop.OmciMsg
Matt Jeanneretceea2e02020-03-27 14:19:57 -04001007 hexPkt := make([]byte, hex.EncodedLen(len(omciMsg.Message)))
1008 hex.Encode(hexPkt, omciMsg.Message)
1009 omciMessage = &oop.OmciMsg{IntfId: intfID, OnuId: onuID, Pkt: hexPkt}
1010
1011 // TODO: Below logging illustrates the "stringify" of the omci Pkt.
1012 // once above is fixed this log line can change to just use hex.EncodeToString(omciMessage.Pkt)
1013 transid := extractOmciTransactionID(omciMsg.Message)
Matteo Scandolo92186242020-06-12 10:54:18 -07001014 logger.Debugw("sent-omci-msg", log.Fields{"intf-id": intfID, "onu-id": onuID,
Matt Jeanneretceea2e02020-03-27 14:19:57 -04001015 "omciTransactionID": transid, "omciMsg": string(omciMessage.Pkt)})
cuilin20187b2a8c32019-03-26 19:52:28 -07001016
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001017 _, err := dh.Client.OmciMsgOut(context.Background(), omciMessage)
1018 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301019 return olterrors.NewErrCommunication("omci-send-failed", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001020 "intf-id": intfID,
1021 "onu-id": onuID,
1022 "message": omciMessage}, err)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001023 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001024 return nil
cuilin20187b2a8c32019-03-26 19:52:28 -07001025}
1026
David K. Bainbridge794735f2020-02-11 21:01:37 -08001027func (dh *DeviceHandler) activateONU(ctx context.Context, intfID uint32, onuID int64, serialNum *oop.SerialNumber, serialNumber string) error {
Matteo Scandolo92186242020-06-12 10:54:18 -07001028 logger.Debugw("activate-onu", log.Fields{"intf-id": intfID, "onu-id": onuID, "serialNum": serialNum, "serialNumber": serialNumber, "device-id": dh.device.Id})
Andrea Campanellab83b39d2020-03-30 11:41:16 +02001029 if err := dh.flowMgr.UpdateOnuInfo(ctx, intfID, uint32(onuID), serialNumber); err != nil {
Matteo Scandolo92186242020-06-12 10:54:18 -07001030 return olterrors.NewErrAdapter("onu-activate-failed", log.Fields{"onu": onuID, "intf-id": intfID}, err)
Andrea Campanellab83b39d2020-03-30 11:41:16 +02001031 }
cuilin20187b2a8c32019-03-26 19:52:28 -07001032 // TODO: need resource manager
1033 var pir uint32 = 1000000
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001034 Onu := oop.Onu{IntfId: intfID, OnuId: uint32(onuID), SerialNumber: serialNum, Pir: pir}
npujarec5762e2020-01-01 14:08:48 +05301035 if _, err := dh.Client.ActivateOnu(ctx, &Onu); err != nil {
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -04001036 st, _ := status.FromError(err)
1037 if st.Code() == codes.AlreadyExists {
Matteo Scandolo92186242020-06-12 10:54:18 -07001038 logger.Debugw("onu-activation-in-progress", log.Fields{"SerialNumber": serialNumber, "onu-id": onuID, "device-id": dh.device.Id})
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -04001039 } else {
Thomas Lee S985938d2020-05-04 11:40:41 +05301040 return olterrors.NewErrAdapter("onu-activate-failed", log.Fields{"onu": Onu, "device-id": dh.device.Id}, err)
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -04001041 }
cuilin20187b2a8c32019-03-26 19:52:28 -07001042 } else {
Thomas Lee S985938d2020-05-04 11:40:41 +05301043 logger.Infow("activated-onu", log.Fields{"SerialNumber": serialNumber, "device-id": dh.device.Id})
cuilin20187b2a8c32019-03-26 19:52:28 -07001044 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001045 return nil
cuilin20187b2a8c32019-03-26 19:52:28 -07001046}
1047
David K. Bainbridge794735f2020-02-11 21:01:37 -08001048func (dh *DeviceHandler) onuDiscIndication(ctx context.Context, onuDiscInd *oop.OnuDiscIndication, sn string) error {
Matteo Scandolo945e4012019-12-12 14:16:11 -08001049
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001050 channelID := onuDiscInd.GetIntfId()
1051 parentPortNo := IntfIDToPortNo(onuDiscInd.GetIntfId(), voltha.Port_PON_OLT)
Matt Jeanneret53539512019-07-20 14:47:02 -04001052
Girish Kumar2ad402b2020-03-20 19:45:12 +00001053 logger.Infow("new-discovery-indication", log.Fields{"sn": sn})
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301054
cuilin20187b2a8c32019-03-26 19:52:28 -07001055 kwargs := make(map[string]interface{})
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -04001056 if sn != "" {
1057 kwargs["serial_number"] = sn
Chaitrashree G S35b5d802019-07-08 23:12:03 -04001058 } else {
Girish Kumarf26e4882020-03-05 06:49:10 +00001059 return olterrors.NewErrInvalidValue(log.Fields{"serial-number": sn}, nil)
Chaitrashree G S35b5d802019-07-08 23:12:03 -04001060 }
1061
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +05301062 var alarmInd oop.OnuAlarmIndication
1063 raisedTs := time.Now().UnixNano()
Amit Ghoshe5c6a852020-02-10 15:09:46 +00001064 if _, loaded := dh.discOnus.LoadOrStore(sn, true); loaded {
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +05301065
1066 /* When PON cable disconnected and connected back from OLT, it was expected OnuAlarmIndication
1067 with "los_status: off" should be raised but BAL does not raise this Alarm hence manually sending
1068 OnuLosClear event on receiving OnuDiscoveryIndication for the Onu after checking whether
1069 OnuLosRaise event sent for it */
1070 dh.onus.Range(func(Onukey interface{}, onuInCache interface{}) bool {
1071 if onuInCache.(*OnuDevice).serialNumber == sn && onuInCache.(*OnuDevice).losRaised {
1072 if onuDiscInd.GetIntfId() != onuInCache.(*OnuDevice).intfID {
Shrey Baid807a2a02020-04-09 12:52:45 +05301073 logger.Warnw("onu-is-on-a-different-intf-id-now", log.Fields{
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +05301074 "previousIntfId": onuInCache.(*OnuDevice).intfID,
1075 "currentIntfId": onuDiscInd.GetIntfId()})
1076 // TODO:: Should we need to ignore raising OnuLosClear event
1077 // when onu connected to different PON?
1078 }
1079 alarmInd.IntfId = onuInCache.(*OnuDevice).intfID
1080 alarmInd.OnuId = onuInCache.(*OnuDevice).onuID
1081 alarmInd.LosStatus = statusCheckOff
1082 go dh.eventMgr.onuAlarmIndication(&alarmInd, onuInCache.(*OnuDevice).deviceID, raisedTs)
1083 }
1084 return true
1085 })
1086
Girish Kumar2ad402b2020-03-20 19:45:12 +00001087 logger.Warnw("onu-sn-is-already-being-processed", log.Fields{"sn": sn})
David K. Bainbridge794735f2020-02-11 21:01:37 -08001088 return nil
Amit Ghoshe5c6a852020-02-10 15:09:46 +00001089 }
1090
Chaitrashree G S35b5d802019-07-08 23:12:03 -04001091 var onuID uint32
Matteo Scandolo945e4012019-12-12 14:16:11 -08001092
1093 // check the ONU is already know to the OLT
1094 // NOTE the second time the ONU is discovered this should return a device
1095 onuDevice, err := dh.coreProxy.GetChildDevice(ctx, dh.device.Id, kwargs)
1096
1097 if err != nil {
Andrea Campanella8c9b4f62020-05-18 18:43:13 +02001098 logger.Debugw("core-proxy-get-child-device-failed", log.Fields{"parentDevice": dh.device.Id, "err": err, "sn": sn})
Matteo Scandolo945e4012019-12-12 14:16:11 -08001099 if e, ok := status.FromError(err); ok {
Andrea Campanella8c9b4f62020-05-18 18:43:13 +02001100 logger.Debugw("core-proxy-get-child-device-failed-with-code", log.Fields{"errCode": e.Code(), "sn": sn})
Matteo Scandolo945e4012019-12-12 14:16:11 -08001101 switch e.Code() {
1102 case codes.Internal:
1103 // this probably means NOT FOUND, so just create a new device
1104 onuDevice = nil
1105 case codes.DeadlineExceeded:
1106 // if the call times out, cleanup and exit
1107 dh.discOnus.Delete(sn)
Girish Kumarf26e4882020-03-05 06:49:10 +00001108 return olterrors.NewErrTimeout("get-child-device", log.Fields{"device-id": dh.device.Id}, err)
Matteo Scandolo945e4012019-12-12 14:16:11 -08001109 }
1110 }
1111 }
1112
1113 if onuDevice == nil {
1114 // NOTE this should happen a single time, and only if GetChildDevice returns NotFound
Andrea Campanella8c9b4f62020-05-18 18:43:13 +02001115 logger.Debugw("creating-new-onu", log.Fields{"sn": sn})
Matteo Scandolo945e4012019-12-12 14:16:11 -08001116 // we need to create a new ChildDevice
Matt Jeanneret53539512019-07-20 14:47:02 -04001117 ponintfid := onuDiscInd.GetIntfId()
1118 dh.lockDevice.Lock()
npujarec5762e2020-01-01 14:08:48 +05301119 onuID, err = dh.resourceMgr.GetONUID(ctx, ponintfid)
Matt Jeanneret53539512019-07-20 14:47:02 -04001120 dh.lockDevice.Unlock()
Chaitrashree G S35b5d802019-07-08 23:12:03 -04001121
Girish Kumar2ad402b2020-03-20 19:45:12 +00001122 logger.Infow("creating-new-onu-got-onu-id", log.Fields{"sn": sn, "onuId": onuID})
Matteo Scandolo945e4012019-12-12 14:16:11 -08001123
1124 if err != nil {
1125 // if we can't create an ID in resource manager,
1126 // cleanup and exit
Matteo Scandolo945e4012019-12-12 14:16:11 -08001127 dh.discOnus.Delete(sn)
Girish Kumarf26e4882020-03-05 06:49:10 +00001128 return olterrors.NewErrAdapter("resource-manager-get-onu-id-failed", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001129 "pon-intf-id": ponintfid,
1130 "serial-number": sn}, err)
Matteo Scandolo945e4012019-12-12 14:16:11 -08001131 }
1132
1133 if onuDevice, err = dh.coreProxy.ChildDeviceDetected(context.TODO(), dh.device.Id, int(parentPortNo),
1134 "", int(channelID), string(onuDiscInd.SerialNumber.GetVendorId()), sn, int64(onuID)); err != nil {
Matteo Scandolo945e4012019-12-12 14:16:11 -08001135 dh.discOnus.Delete(sn)
1136 dh.resourceMgr.FreeonuID(ctx, ponintfid, []uint32{onuID}) // NOTE I'm not sure this method is actually cleaning up the right thing
Thomas Lee S94109f12020-03-03 16:39:29 +05301137 return olterrors.NewErrAdapter("core-proxy-child-device-detected-failed", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001138 "pon-intf-id": ponintfid,
1139 "serial-number": sn}, err)
Matteo Scandolo945e4012019-12-12 14:16:11 -08001140 }
Amit Ghosh75f0e292020-05-14 11:31:54 +01001141 dh.eventMgr.OnuDiscoveryIndication(onuDiscInd, dh.device.Id, onuDevice.Id, onuID, sn, time.Now().UnixNano())
Shrey Baid807a2a02020-04-09 12:52:45 +05301142 logger.Infow("onu-child-device-added",
1143 log.Fields{"onuDevice": onuDevice,
1144 "sn": sn,
Matteo Scandolo92186242020-06-12 10:54:18 -07001145 "onu-id": onuID,
Thomas Lee S985938d2020-05-04 11:40:41 +05301146 "device-id": dh.device.Id})
Chaitrashree G Sbe6ab942019-05-24 06:42:49 -04001147 }
Matteo Scandolo945e4012019-12-12 14:16:11 -08001148
1149 // we can now use the existing ONU Id
1150 onuID = onuDevice.ProxyAddress.OnuId
Mahir Gunyele77977b2019-06-27 05:36:22 -07001151 //Insert the ONU into cache to use in OnuIndication.
1152 //TODO: Do we need to remove this from the cache on ONU change, or wait for overwritten on next discovery.
Shrey Baid807a2a02020-04-09 12:52:45 +05301153 logger.Debugw("onu-discovery-indication-key-create",
Matteo Scandolo92186242020-06-12 10:54:18 -07001154 log.Fields{"onu-id": onuID,
Shrey Baid807a2a02020-04-09 12:52:45 +05301155 "intfId": onuDiscInd.GetIntfId(),
1156 "sn": sn})
Mahir Gunyele77977b2019-06-27 05:36:22 -07001157 onuKey := dh.formOnuKey(onuDiscInd.GetIntfId(), onuID)
Matt Jeanneret53539512019-07-20 14:47:02 -04001158
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +05301159 onuDev := NewOnuDevice(onuDevice.Id, onuDevice.Type, onuDevice.SerialNumber, onuID, onuDiscInd.GetIntfId(), onuDevice.ProxyAddress.DeviceId, false)
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301160 dh.onus.Store(onuKey, onuDev)
Shrey Baid807a2a02020-04-09 12:52:45 +05301161 logger.Debugw("new-onu-device-discovered",
1162 log.Fields{"onu": onuDev,
1163 "sn": sn})
Chaitrashree G S35b5d802019-07-08 23:12:03 -04001164
David K. Bainbridge794735f2020-02-11 21:01:37 -08001165 if err = dh.coreProxy.DeviceStateUpdate(ctx, onuDevice.Id, common.ConnectStatus_REACHABLE, common.OperStatus_DISCOVERED); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301166 return olterrors.NewErrAdapter("failed-to-update-device-state", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001167 "device-id": onuDevice.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00001168 "serial-number": sn}, err)
cuilin20187b2a8c32019-03-26 19:52:28 -07001169 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301170 logger.Infow("onu-discovered-reachable", log.Fields{"device-id": onuDevice.Id, "sn": sn})
David K. Bainbridge794735f2020-02-11 21:01:37 -08001171 if err = dh.activateONU(ctx, onuDiscInd.IntfId, int64(onuID), onuDiscInd.SerialNumber, sn); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301172 return olterrors.NewErrAdapter("onu-activation-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001173 "device-id": onuDevice.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00001174 "serial-number": sn}, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -08001175 }
1176 return nil
cuilin20187b2a8c32019-03-26 19:52:28 -07001177}
1178
David K. Bainbridge794735f2020-02-11 21:01:37 -08001179func (dh *DeviceHandler) onuIndication(onuInd *oop.OnuIndication) error {
cuilin20187b2a8c32019-03-26 19:52:28 -07001180 serialNumber := dh.stringifySerialNumber(onuInd.SerialNumber)
1181
1182 kwargs := make(map[string]interface{})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001183 ponPort := IntfIDToPortNo(onuInd.GetIntfId(), voltha.Port_PON_OLT)
Mahir Gunyele77977b2019-06-27 05:36:22 -07001184 var onuDevice *voltha.Device
David K. Bainbridge794735f2020-02-11 21:01:37 -08001185 var err error
Mahir Gunyele77977b2019-06-27 05:36:22 -07001186 foundInCache := false
Shrey Baid807a2a02020-04-09 12:52:45 +05301187 logger.Debugw("onu-indication-key-create",
1188 log.Fields{"onuId": onuInd.OnuId,
1189 "intfId": onuInd.GetIntfId(),
Thomas Lee S985938d2020-05-04 11:40:41 +05301190 "device-id": dh.device.Id})
Mahir Gunyele77977b2019-06-27 05:36:22 -07001191 onuKey := dh.formOnuKey(onuInd.GetIntfId(), onuInd.OnuId)
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301192
David K. Bainbridge794735f2020-02-11 21:01:37 -08001193 errFields := log.Fields{"device-id": dh.device.Id}
1194
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301195 if onuInCache, ok := dh.onus.Load(onuKey); ok {
1196
Mahir Gunyele77977b2019-06-27 05:36:22 -07001197 //If ONU id is discovered before then use GetDevice to get onuDevice because it is cheaper.
1198 foundInCache = true
David K. Bainbridge794735f2020-02-11 21:01:37 -08001199 errFields["onu-id"] = onuInCache.(*OnuDevice).deviceID
1200 onuDevice, err = dh.coreProxy.GetDevice(nil, dh.device.Id, onuInCache.(*OnuDevice).deviceID)
cuilin20187b2a8c32019-03-26 19:52:28 -07001201 } else {
Mahir Gunyele77977b2019-06-27 05:36:22 -07001202 //If ONU not found in adapter cache then we have to use GetChildDevice to get onuDevice
1203 if serialNumber != "" {
1204 kwargs["serial_number"] = serialNumber
David K. Bainbridge794735f2020-02-11 21:01:37 -08001205 errFields["serial-number"] = serialNumber
Mahir Gunyele77977b2019-06-27 05:36:22 -07001206 } else {
1207 kwargs["onu_id"] = onuInd.OnuId
1208 kwargs["parent_port_no"] = ponPort
David K. Bainbridge794735f2020-02-11 21:01:37 -08001209 errFields["onu-id"] = onuInd.OnuId
1210 errFields["parent-port-no"] = ponPort
Mahir Gunyele77977b2019-06-27 05:36:22 -07001211 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001212 onuDevice, err = dh.coreProxy.GetChildDevice(context.TODO(), dh.device.Id, kwargs)
cuilin20187b2a8c32019-03-26 19:52:28 -07001213 }
Mahir Gunyele77977b2019-06-27 05:36:22 -07001214
David K. Bainbridge794735f2020-02-11 21:01:37 -08001215 if err != nil || onuDevice == nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001216 return olterrors.NewErrNotFound("onu-device", errFields, err)
cuilin20187b2a8c32019-03-26 19:52:28 -07001217 }
1218
David K. Bainbridge794735f2020-02-11 21:01:37 -08001219 if onuDevice.ParentPortNo != ponPort {
Shrey Baid807a2a02020-04-09 12:52:45 +05301220 logger.Warnw("onu-is-on-a-different-intf-id-now", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001221 "previousIntfId": onuDevice.ParentPortNo,
1222 "currentIntfId": ponPort})
1223 }
1224
1225 if onuDevice.ProxyAddress.OnuId != onuInd.OnuId {
Shrey Baid807a2a02020-04-09 12:52:45 +05301226 logger.Warnw("onu-id-mismatch-possible-if-voltha-and-olt-rebooted", log.Fields{
1227 "expected-onu-id": onuDevice.ProxyAddress.OnuId,
1228 "received-onu-id": onuInd.OnuId,
Thomas Lee S985938d2020-05-04 11:40:41 +05301229 "device-id": dh.device.Id})
David K. Bainbridge794735f2020-02-11 21:01:37 -08001230 }
1231 if !foundInCache {
1232 onuKey := dh.formOnuKey(onuInd.GetIntfId(), onuInd.GetOnuId())
1233
Thiyagarajan Subramani34a00282020-03-10 20:19:31 +05301234 dh.onus.Store(onuKey, NewOnuDevice(onuDevice.Id, onuDevice.Type, onuDevice.SerialNumber, onuInd.GetOnuId(), onuInd.GetIntfId(), onuDevice.ProxyAddress.DeviceId, false))
David K. Bainbridge794735f2020-02-11 21:01:37 -08001235
1236 }
Amit Ghosh9bbc5652020-02-17 13:37:32 +00001237 if err := dh.updateOnuStates(onuDevice, onuInd); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001238 return olterrors.NewErrCommunication("state-update-failed", errFields, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -08001239 }
1240 return nil
cuilin20187b2a8c32019-03-26 19:52:28 -07001241}
1242
Amit Ghosh9bbc5652020-02-17 13:37:32 +00001243func (dh *DeviceHandler) updateOnuStates(onuDevice *voltha.Device, onuInd *oop.OnuIndication) error {
npujarec5762e2020-01-01 14:08:48 +05301244 ctx := context.TODO()
Shrey Baid807a2a02020-04-09 12:52:45 +05301245 logger.Debugw("onu-indication-for-state", log.Fields{"onuIndication": onuInd, "device-id": onuDevice.Id, "operStatus": onuDevice.OperStatus, "adminStatus": onuDevice.AdminState})
Girish Gowdraa6415dd2020-07-01 10:27:52 -07001246 if onuInd.AdminState == "down" || onuInd.OperState == "down" {
1247 // The ONU has gone admin_state "down" or oper_state "down" - we expect the ONU to send discovery again
1248 // The ONU admin_state is "up" while "oper_state" is down in cases where ONU activation fails. In this case
1249 // the ONU sends Discovery again.
Girish Gowdra429f9502020-05-04 13:22:16 -07001250 dh.discOnus.Delete(onuDevice.SerialNumber)
Amit Ghosh9bbc5652020-02-17 13:37:32 +00001251 // Tests have shown that we sometimes get OperState as NOT down even if AdminState is down, forcing it
1252 if onuInd.OperState != "down" {
Shrey Baid807a2a02020-04-09 12:52:45 +05301253 logger.Warnw("onu-admin-state-down", log.Fields{"operState": onuInd.OperState})
Amit Ghosh9bbc5652020-02-17 13:37:32 +00001254 onuInd.OperState = "down"
1255 }
1256 }
1257
David K. Bainbridge794735f2020-02-11 21:01:37 -08001258 switch onuInd.OperState {
1259 case "down":
Shrey Baid807a2a02020-04-09 12:52:45 +05301260 logger.Debugw("sending-interadapter-onu-indication", log.Fields{"onuIndication": onuInd, "device-id": onuDevice.Id, "operStatus": onuDevice.OperStatus, "adminStatus": onuDevice.AdminState})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001261 // TODO NEW CORE do not hardcode adapter name. Handler needs Adapter reference
npujarec5762e2020-01-01 14:08:48 +05301262 err := dh.AdapterProxy.SendInterAdapterMessage(ctx, onuInd, ic.InterAdapterMessageType_ONU_IND_REQUEST,
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001263 "openolt", onuDevice.Type, onuDevice.Id, onuDevice.ProxyAddress.DeviceId, "")
1264 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301265 return olterrors.NewErrCommunication("inter-adapter-send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001266 "onu-indicator": onuInd,
1267 "source": "openolt",
1268 "device-type": onuDevice.Type,
Girish Kumarf26e4882020-03-05 06:49:10 +00001269 "device-id": onuDevice.Id}, err)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001270 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001271 case "up":
Shrey Baid807a2a02020-04-09 12:52:45 +05301272 logger.Debugw("sending-interadapter-onu-indication", log.Fields{"onuIndication": onuInd, "device-id": onuDevice.Id, "operStatus": onuDevice.OperStatus, "adminStatus": onuDevice.AdminState})
Matt Jeanneret53539512019-07-20 14:47:02 -04001273 // TODO NEW CORE do not hardcode adapter name. Handler needs Adapter reference
npujarec5762e2020-01-01 14:08:48 +05301274 err := dh.AdapterProxy.SendInterAdapterMessage(ctx, onuInd, ic.InterAdapterMessageType_ONU_IND_REQUEST,
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001275 "openolt", onuDevice.Type, onuDevice.Id, onuDevice.ProxyAddress.DeviceId, "")
1276 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301277 return olterrors.NewErrCommunication("inter-adapter-send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001278 "onu-indicator": onuInd,
1279 "source": "openolt",
1280 "device-type": onuDevice.Type,
Girish Kumarf26e4882020-03-05 06:49:10 +00001281 "device-id": onuDevice.Id}, err)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001282 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001283 default:
Girish Kumarf26e4882020-03-05 06:49:10 +00001284 return olterrors.NewErrInvalidValue(log.Fields{"oper-state": onuInd.OperState}, nil)
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001285 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001286 return nil
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001287}
1288
cuilin20187b2a8c32019-03-26 19:52:28 -07001289func (dh *DeviceHandler) stringifySerialNumber(serialNum *oop.SerialNumber) string {
1290 if serialNum != nil {
1291 return string(serialNum.VendorId) + dh.stringifyVendorSpecific(serialNum.VendorSpecific)
cuilin20187b2a8c32019-03-26 19:52:28 -07001292 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001293 return ""
cuilin20187b2a8c32019-03-26 19:52:28 -07001294}
Chaitrashree G S1a55b882020-02-04 17:35:35 -05001295func (dh *DeviceHandler) deStringifySerialNumber(serialNum string) (*oop.SerialNumber, error) {
1296 decodedStr, err := hex.DecodeString(serialNum[4:])
1297 if err != nil {
1298 return nil, err
1299 }
1300 return &oop.SerialNumber{
1301 VendorId: []byte(serialNum[:4]),
1302 VendorSpecific: []byte(decodedStr),
1303 }, nil
1304}
cuilin20187b2a8c32019-03-26 19:52:28 -07001305
1306func (dh *DeviceHandler) stringifyVendorSpecific(vendorSpecific []byte) string {
1307 tmp := fmt.Sprintf("%x", (uint32(vendorSpecific[0])>>4)&0x0f) +
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001308 fmt.Sprintf("%x", uint32(vendorSpecific[0]&0x0f)) +
cuilin20187b2a8c32019-03-26 19:52:28 -07001309 fmt.Sprintf("%x", (uint32(vendorSpecific[1])>>4)&0x0f) +
1310 fmt.Sprintf("%x", (uint32(vendorSpecific[1]))&0x0f) +
1311 fmt.Sprintf("%x", (uint32(vendorSpecific[2])>>4)&0x0f) +
1312 fmt.Sprintf("%x", (uint32(vendorSpecific[2]))&0x0f) +
1313 fmt.Sprintf("%x", (uint32(vendorSpecific[3])>>4)&0x0f) +
1314 fmt.Sprintf("%x", (uint32(vendorSpecific[3]))&0x0f)
1315 return tmp
1316}
1317
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001318//UpdateFlowsBulk upates the bulk flow
1319func (dh *DeviceHandler) UpdateFlowsBulk() error {
Thomas Lee S94109f12020-03-03 16:39:29 +05301320 return olterrors.ErrNotImplemented
cuilin20187b2a8c32019-03-26 19:52:28 -07001321}
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001322
1323//GetChildDevice returns the child device for given parent port and onu id
David K. Bainbridge794735f2020-02-11 21:01:37 -08001324func (dh *DeviceHandler) GetChildDevice(parentPort, onuID uint32) (*voltha.Device, error) {
Shrey Baid807a2a02020-04-09 12:52:45 +05301325 logger.Debugw("getchilddevice",
1326 log.Fields{"pon-port": parentPort,
Matteo Scandolo92186242020-06-12 10:54:18 -07001327 "onu-id": onuID,
Thomas Lee S985938d2020-05-04 11:40:41 +05301328 "device-id": dh.device.Id})
Girish Gowdru0c588b22019-04-23 23:24:56 -04001329 kwargs := make(map[string]interface{})
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001330 kwargs["onu_id"] = onuID
Girish Gowdru0c588b22019-04-23 23:24:56 -04001331 kwargs["parent_port_no"] = parentPort
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001332 onuDevice, err := dh.coreProxy.GetChildDevice(context.TODO(), dh.device.Id, kwargs)
Girish Gowdru0c588b22019-04-23 23:24:56 -04001333 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001334 return nil, olterrors.NewErrNotFound("onu-device", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001335 "intf-id": parentPort,
1336 "onu-id": onuID}, err)
Girish Gowdru0c588b22019-04-23 23:24:56 -04001337 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301338 logger.Debugw("successfully-received-child-device-from-core", log.Fields{"child-device-id": onuDevice.Id, "child-device-sn": onuDevice.SerialNumber})
David K. Bainbridge794735f2020-02-11 21:01:37 -08001339 return onuDevice, nil
manikkaraj kbf256be2019-03-25 00:13:48 +05301340}
1341
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001342// SendPacketInToCore sends packet-in to core
1343// For this, it calls SendPacketIn of the core-proxy which uses a device specific topic to send the request.
1344// The adapter handling the device creates a device specific topic
David K. Bainbridge794735f2020-02-11 21:01:37 -08001345func (dh *DeviceHandler) SendPacketInToCore(logicalPort uint32, packetPayload []byte) error {
Matteo Scandolo92186242020-06-12 10:54:18 -07001346 if logger.V(log.DebugLevel) {
1347 logger.Debugw("send-packet-in-to-core", log.Fields{
1348 "port": logicalPort,
1349 "packet": hex.EncodeToString(packetPayload),
1350 "device-id": dh.device.Id,
1351 })
1352 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001353 if err := dh.coreProxy.SendPacketIn(context.TODO(), dh.device.Id, logicalPort, packetPayload); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301354 return olterrors.NewErrCommunication("packet-send-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001355 "source": "adapter",
1356 "destination": "core",
1357 "device-id": dh.device.Id,
1358 "logical-port": logicalPort,
Girish Kumarf26e4882020-03-05 06:49:10 +00001359 "packet": hex.EncodeToString(packetPayload)}, err)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001360 }
Matteo Scandolo92186242020-06-12 10:54:18 -07001361 if logger.V(log.DebugLevel) {
1362 logger.Debugw("sent-packet-in-to-core-successfully", log.Fields{
1363 "packet": hex.EncodeToString(packetPayload),
1364 "device-id": dh.device.Id,
1365 })
1366 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001367 return nil
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001368}
1369
A R Karthick1f85b802019-10-11 05:06:05 +00001370// AddUniPortToOnu adds the uni port to the onu device
1371func (dh *DeviceHandler) AddUniPortToOnu(intfID, onuID, uniPort uint32) {
1372 onuKey := dh.formOnuKey(intfID, onuID)
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301373
1374 if onuDevice, ok := dh.onus.Load(onuKey); ok {
A R Karthick1f85b802019-10-11 05:06:05 +00001375 // add it to the uniPort map for the onu device
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301376 if _, ok = onuDevice.(*OnuDevice).uniPorts[uniPort]; !ok {
1377 onuDevice.(*OnuDevice).uniPorts[uniPort] = struct{}{}
Matteo Scandolo92186242020-06-12 10:54:18 -07001378 logger.Debugw("adding-uni-port", log.Fields{"port": uniPort, "intf-id": intfID, "onuId": onuID})
A R Karthick1f85b802019-10-11 05:06:05 +00001379 }
1380 }
1381}
1382
Rohan Agrawalda5e0b22020-05-20 11:10:26 +00001383// UpdatePmConfig updates the pm metrics.
1384func (dh *DeviceHandler) UpdatePmConfig(pmConfigs *voltha.PmConfigs) {
1385
1386 logger.Infow("update-pm-configs", log.Fields{"device-id": dh.device.Id, "pm-configs": pmConfigs})
1387
1388 if pmConfigs.DefaultFreq != dh.metrics.ToPmConfigs().DefaultFreq {
1389 dh.metrics.UpdateFrequency(pmConfigs.DefaultFreq)
1390 logger.Debugf("frequency-updated")
1391 }
1392
1393 if pmConfigs.Grouped == false {
1394 metrics := dh.metrics.GetSubscriberMetrics()
1395 for _, m := range pmConfigs.Metrics {
1396 metrics[m.Name].Enabled = m.Enabled
1397
1398 }
1399 }
1400}
1401
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001402//UpdateFlowsIncrementally updates the device flow
npujarec5762e2020-01-01 14:08:48 +05301403func (dh *DeviceHandler) UpdateFlowsIncrementally(ctx context.Context, device *voltha.Device, flows *of.FlowChanges, groups *of.FlowGroupChanges, flowMetadata *voltha.FlowMetadata) error {
Shrey Baid807a2a02020-04-09 12:52:45 +05301404 logger.Debugw("received-incremental-flowupdate-in-device-handler", log.Fields{"device-id": device.Id, "flows": flows, "groups": groups, "flowMetadata": flowMetadata})
Andrea Campanellac63bba92020-03-10 17:01:04 +01001405
1406 var errorsList []error
1407
Girish Gowdru0c588b22019-04-23 23:24:56 -04001408 if flows != nil {
Manjunath Vanarajulu28c3e822019-05-16 11:14:28 -04001409 for _, flow := range flows.ToRemove.Items {
Girish Gowdracefae192020-03-19 18:14:10 -07001410 dh.incrementActiveFlowRemoveCount(flow)
1411
Shrey Baid807a2a02020-04-09 12:52:45 +05301412 logger.Debugw("removing-flow",
1413 log.Fields{"device-id": device.Id,
1414 "flowToRemove": flow})
Girish Gowdracefae192020-03-19 18:14:10 -07001415 err := dh.flowMgr.RemoveFlow(ctx, flow)
1416 if err != nil {
1417 errorsList = append(errorsList, err)
1418 }
1419
1420 dh.decrementActiveFlowRemoveCount(flow)
Manjunath Vanarajulu28c3e822019-05-16 11:14:28 -04001421 }
Girish Gowdra3d633032019-12-10 16:37:05 +05301422
1423 for _, flow := range flows.ToAdd.Items {
Shrey Baid807a2a02020-04-09 12:52:45 +05301424 logger.Debugw("adding-flow",
1425 log.Fields{"device-id": device.Id,
1426 "flowToAdd": flow})
Girish Gowdracefae192020-03-19 18:14:10 -07001427 // If there are active Flow Remove in progress for a given subscriber, wait until it completes
1428 dh.waitForFlowRemoveToFinish(flow)
Andrea Campanellac63bba92020-03-10 17:01:04 +01001429 err := dh.flowMgr.AddFlow(ctx, flow, flowMetadata)
1430 if err != nil {
1431 errorsList = append(errorsList, err)
1432 }
Girish Gowdra3d633032019-12-10 16:37:05 +05301433 }
Girish Gowdru0c588b22019-04-23 23:24:56 -04001434 }
Esin Karamanccb714b2019-11-29 15:02:06 +00001435
Girish Gowdracefae192020-03-19 18:14:10 -07001436 // Whether we need to synchronize multicast group adds and modifies like flow add and delete needs to be investigated
Esin Karamanccb714b2019-11-29 15:02:06 +00001437 if groups != nil {
1438 for _, group := range groups.ToAdd.Items {
Andrea Campanellac63bba92020-03-10 17:01:04 +01001439 err := dh.flowMgr.AddGroup(ctx, group)
1440 if err != nil {
1441 errorsList = append(errorsList, err)
1442 }
Esin Karamanccb714b2019-11-29 15:02:06 +00001443 }
1444 for _, group := range groups.ToUpdate.Items {
Andrea Campanellac63bba92020-03-10 17:01:04 +01001445 err := dh.flowMgr.ModifyGroup(ctx, group)
1446 if err != nil {
1447 errorsList = append(errorsList, err)
1448 }
Esin Karamanccb714b2019-11-29 15:02:06 +00001449 }
1450 if len(groups.ToRemove.Items) != 0 {
Thomas Lee S985938d2020-05-04 11:40:41 +05301451 logger.Debugw("group-delete-operation-not-supported", log.Fields{"device-id": dh.device.Id})
Esin Karamanccb714b2019-11-29 15:02:06 +00001452 }
1453 }
Andrea Campanellac63bba92020-03-10 17:01:04 +01001454 if len(errorsList) > 0 {
1455 return fmt.Errorf("errors-installing-flows-groups, errors:%v", errorsList)
1456 }
Thomas Lee S985938d2020-05-04 11:40:41 +05301457 logger.Debugw("updated-flows-incrementally-successfully", log.Fields{"device-id": dh.device.Id})
Girish Gowdru0c588b22019-04-23 23:24:56 -04001458 return nil
manikkaraj kbf256be2019-03-25 00:13:48 +05301459}
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001460
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001461//DisableDevice disables the given device
1462//It marks the following for the given device:
1463//Device-Handler Admin-State : down
1464//Device Port-State: UNKNOWN
1465//Device Oper-State: UNKNOWN
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001466func (dh *DeviceHandler) DisableDevice(device *voltha.Device) error {
Chaitrashree G S44124192019-08-07 20:21:36 -04001467 /* On device disable ,admin state update has to be done prior sending request to agent since
1468 the indication thread may processes invalid indications of ONU and OLT*/
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001469 if dh.Client != nil {
1470 if _, err := dh.Client.DisableOlt(context.Background(), new(oop.Empty)); err != nil {
1471 if e, ok := status.FromError(err); ok && e.Code() == codes.Internal {
Girish Kumarf26e4882020-03-05 06:49:10 +00001472 return olterrors.NewErrAdapter("olt-disable-failed", log.Fields{"device-id": device.Id}, err)
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001473 }
Chaitrashree G S3b4c0352019-09-09 20:59:29 -04001474 }
Chaitrashree G S44124192019-08-07 20:21:36 -04001475 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301476 logger.Debugw("olt-disabled", log.Fields{"device-id": device.Id})
Chaitrashree G S44124192019-08-07 20:21:36 -04001477 /* Discovered ONUs entries need to be cleared , since on device disable the child devices goes to
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001478 UNREACHABLE state which needs to be configured again*/
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301479
1480 dh.discOnus = sync.Map{}
1481 dh.onus = sync.Map{}
1482
Thomas Lee S85f37312020-04-03 17:06:12 +05301483 //stopping the stats collector
1484 dh.stopCollector <- true
1485
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301486 go dh.notifyChildDevices("unreachable")
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001487 cloned := proto.Clone(device).(*voltha.Device)
Thomas Lee S985938d2020-05-04 11:40:41 +05301488 //Update device Admin state
1489 dh.device = cloned
kdarapu1afeceb2020-02-12 01:38:09 -05001490 // Update the all pon ports state on that device to disable and NNI remains active as NNI remains active in openolt agent.
1491 for _, port := range cloned.Ports {
1492 if port.GetType() == voltha.Port_PON_OLT {
1493 if err := dh.coreProxy.PortStateUpdate(context.TODO(), cloned.Id,
1494 voltha.Port_PON_OLT, port.GetPortNo(), voltha.OperStatus_UNKNOWN); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001495 return olterrors.NewErrAdapter("port-state-update-failed", log.Fields{"device-id": device.Id, "port-number": port.GetPortNo()}, err)
kdarapu1afeceb2020-02-12 01:38:09 -05001496 }
1497 }
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001498 }
1499
Shrey Baid807a2a02020-04-09 12:52:45 +05301500 logger.Debugw("disable-device-end", log.Fields{"device-id": device.Id})
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001501 return nil
1502}
1503
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301504func (dh *DeviceHandler) notifyChildDevices(state string) {
Chaitrashree G S3b4c0352019-09-09 20:59:29 -04001505
1506 // Update onu state as unreachable in onu adapter
1507 onuInd := oop.OnuIndication{}
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301508 onuInd.OperState = state
Chaitrashree G S3b4c0352019-09-09 20:59:29 -04001509 //get the child device for the parent device
1510 onuDevices, err := dh.coreProxy.GetChildDevices(context.TODO(), dh.device.Id)
1511 if err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301512 logger.Errorw("failed-to-get-child-devices-information", log.Fields{"device-id": dh.device.Id, "error": err})
Chaitrashree G S3b4c0352019-09-09 20:59:29 -04001513 }
1514 if onuDevices != nil {
1515 for _, onuDevice := range onuDevices.Items {
1516 err := dh.AdapterProxy.SendInterAdapterMessage(context.TODO(), &onuInd, ic.InterAdapterMessageType_ONU_IND_REQUEST,
1517 "openolt", onuDevice.Type, onuDevice.Id, onuDevice.ProxyAddress.DeviceId, "")
1518 if err != nil {
Girish Kumar2ad402b2020-03-20 19:45:12 +00001519 logger.Errorw("failed-to-send-inter-adapter-message", log.Fields{"OnuInd": onuInd,
Shrey Baid807a2a02020-04-09 12:52:45 +05301520 "From Adapter": "openolt", "DeviceType": onuDevice.Type, "device-id": onuDevice.Id})
Chaitrashree G S3b4c0352019-09-09 20:59:29 -04001521 }
1522
1523 }
1524 }
1525
1526}
1527
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001528//ReenableDevice re-enables the olt device after disable
1529//It marks the following for the given device:
1530//Device-Handler Admin-State : up
1531//Device Port-State: ACTIVE
1532//Device Oper-State: ACTIVE
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001533func (dh *DeviceHandler) ReenableDevice(device *voltha.Device) error {
Abhilash Laxmeshwar5b302e12020-01-09 15:15:14 +05301534
1535 if _, err := dh.Client.ReenableOlt(context.Background(), new(oop.Empty)); err != nil {
1536 if e, ok := status.FromError(err); ok && e.Code() == codes.Internal {
Girish Kumarf26e4882020-03-05 06:49:10 +00001537 return olterrors.NewErrAdapter("olt-reenable-failed", log.Fields{"device-id": dh.device.Id}, err)
Abhilash Laxmeshwar5b302e12020-01-09 15:15:14 +05301538 }
1539 }
Girish Kumar2ad402b2020-03-20 19:45:12 +00001540 logger.Debug("olt-reenabled")
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001541
1542 cloned := proto.Clone(device).(*voltha.Device)
1543 // Update the all ports state on that device to enable
kesavand39e0aa32020-01-28 20:58:50 -05001544
kdarapu1afeceb2020-02-12 01:38:09 -05001545 if err := dh.disableAdminDownPorts(device); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001546 return olterrors.NewErrAdapter("port-status-update-failed-after-olt-reenable", log.Fields{"device": device}, err)
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001547 }
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001548 //Update the device oper status as ACTIVE
1549 cloned.OperStatus = voltha.OperStatus_ACTIVE
1550 dh.device = cloned
1551
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001552 if err := dh.coreProxy.DeviceStateUpdate(context.TODO(), cloned.Id, cloned.ConnectStatus, cloned.OperStatus); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301553 return olterrors.NewErrAdapter("state-update-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001554 "device-id": device.Id,
1555 "connect-status": cloned.ConnectStatus,
Girish Kumarf26e4882020-03-05 06:49:10 +00001556 "oper-status": cloned.OperStatus}, err)
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001557 }
kesavand39e0aa32020-01-28 20:58:50 -05001558
Shrey Baid807a2a02020-04-09 12:52:45 +05301559 logger.Debugw("reenabledevice-end", log.Fields{"device-id": device.Id})
Girish Gowdru5ba46c92019-04-25 05:00:05 -04001560
1561 return nil
1562}
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001563
npujarec5762e2020-01-01 14:08:48 +05301564func (dh *DeviceHandler) clearUNIData(ctx context.Context, onu *rsrcMgr.OnuGemInfo) error {
Devmalya Paul495b94a2019-08-27 19:42:00 -04001565 var uniID uint32
1566 var err error
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301567 for _, port := range onu.UniPorts {
1568 uniID = UniIDFromPortNum(uint32(port))
Matteo Scandolo92186242020-06-12 10:54:18 -07001569 logger.Debugw("clearing-resource-data-for-uni-port", log.Fields{"port": port, "uni-id": uniID})
A R Karthick1f85b802019-10-11 05:06:05 +00001570 /* Delete tech-profile instance from the KV store */
npujarec5762e2020-01-01 14:08:48 +05301571 if err = dh.flowMgr.DeleteTechProfileInstances(ctx, onu.IntfID, onu.OnuID, uniID, onu.SerialNumber); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301572 logger.Debugw("failed-to-remove-tech-profile-instance-for-onu", log.Fields{"onu-id": onu.OnuID})
Devmalya Paul495b94a2019-08-27 19:42:00 -04001573 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301574 logger.Debugw("deleted-tech-profile-instance-for-onu", log.Fields{"onu-id": onu.OnuID})
npujarec5762e2020-01-01 14:08:48 +05301575 flowIDs := dh.resourceMgr.GetCurrentFlowIDsForOnu(ctx, onu.IntfID, int32(onu.OnuID), int32(uniID))
A R Karthick1f85b802019-10-11 05:06:05 +00001576 for _, flowID := range flowIDs {
npujarec5762e2020-01-01 14:08:48 +05301577 dh.resourceMgr.FreeFlowID(ctx, onu.IntfID, int32(onu.OnuID), int32(uniID), flowID)
A R Karthick1f85b802019-10-11 05:06:05 +00001578 }
npujarec5762e2020-01-01 14:08:48 +05301579 tpIDList := dh.resourceMgr.GetTechProfileIDForOnu(ctx, onu.IntfID, onu.OnuID, uniID)
Gamze Abakafee36392019-10-03 11:17:24 +00001580 for _, tpID := range tpIDList {
npujarec5762e2020-01-01 14:08:48 +05301581 if err = dh.resourceMgr.RemoveMeterIDForOnu(ctx, "upstream", onu.IntfID, onu.OnuID, uniID, tpID); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301582 logger.Debugw("failed-to-remove-meter-id-for-onu-upstream", log.Fields{"onu-id": onu.OnuID})
Gamze Abakafee36392019-10-03 11:17:24 +00001583 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301584 logger.Debugw("removed-meter-id-for-onu-upstream", log.Fields{"onu-id": onu.OnuID})
npujarec5762e2020-01-01 14:08:48 +05301585 if err = dh.resourceMgr.RemoveMeterIDForOnu(ctx, "downstream", onu.IntfID, onu.OnuID, uniID, tpID); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301586 logger.Debugw("failed-to-remove-meter-id-for-onu-downstream", log.Fields{"onu-id": onu.OnuID})
Gamze Abakafee36392019-10-03 11:17:24 +00001587 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301588 logger.Debugw("removed-meter-id-for-onu-downstream", log.Fields{"onu-id": onu.OnuID})
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301589 }
npujarec5762e2020-01-01 14:08:48 +05301590 dh.resourceMgr.FreePONResourcesForONU(ctx, onu.IntfID, onu.OnuID, uniID)
1591 if err = dh.resourceMgr.RemoveTechProfileIDsForOnu(ctx, onu.IntfID, onu.OnuID, uniID); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301592 logger.Debugw("failed-to-remove-tech-profile-id-for-onu", log.Fields{"onu-id": onu.OnuID})
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301593 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301594 logger.Debugw("removed-tech-profile-id-for-onu", log.Fields{"onu-id": onu.OnuID})
npujarec5762e2020-01-01 14:08:48 +05301595 if err = dh.resourceMgr.DelGemPortPktIn(ctx, onu.IntfID, onu.OnuID, uint32(port)); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301596 logger.Debugw("failed-to-remove-gemport-pkt-in", log.Fields{"intfid": onu.IntfID, "onuid": onu.OnuID, "uniId": uniID})
A R Karthick1f85b802019-10-11 05:06:05 +00001597 }
Devmalya Paul495b94a2019-08-27 19:42:00 -04001598 }
1599 return nil
1600}
1601
npujarec5762e2020-01-01 14:08:48 +05301602func (dh *DeviceHandler) clearNNIData(ctx context.Context) error {
Devmalya Paul495b94a2019-08-27 19:42:00 -04001603 nniUniID := -1
1604 nniOnuID := -1
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301605
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001606 if dh.resourceMgr == nil {
Thomas Lee S985938d2020-05-04 11:40:41 +05301607 return olterrors.NewErrNotFound("resource-manager", log.Fields{"device-id": dh.device.Id}, nil)
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001608 }
Devmalya Paul495b94a2019-08-27 19:42:00 -04001609 //Free the flow-ids for the NNI port
npujarec5762e2020-01-01 14:08:48 +05301610 nni, err := dh.resourceMgr.GetNNIFromKVStore(ctx)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301611 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001612 return olterrors.NewErrPersistence("get", "nni", 0, nil, err)
Devmalya Paul495b94a2019-08-27 19:42:00 -04001613 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301614 logger.Debugw("nni-", log.Fields{"nni": nni})
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301615 for _, nniIntfID := range nni {
npujarec5762e2020-01-01 14:08:48 +05301616 flowIDs := dh.resourceMgr.GetCurrentFlowIDsForOnu(ctx, uint32(nniIntfID), int32(nniOnuID), int32(nniUniID))
Shrey Baid807a2a02020-04-09 12:52:45 +05301617 logger.Debugw("current-flow-ids-for-nni", log.Fields{"flow-ids": flowIDs})
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301618 for _, flowID := range flowIDs {
npujarec5762e2020-01-01 14:08:48 +05301619 dh.resourceMgr.FreeFlowID(ctx, uint32(nniIntfID), -1, -1, uint32(flowID))
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301620 }
npujarec5762e2020-01-01 14:08:48 +05301621 dh.resourceMgr.RemoveResourceMap(ctx, nniIntfID, int32(nniOnuID), int32(nniUniID))
Devmalya Paul495b94a2019-08-27 19:42:00 -04001622 }
npujarec5762e2020-01-01 14:08:48 +05301623 if err = dh.resourceMgr.DelNNiFromKVStore(ctx); err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001624 return olterrors.NewErrPersistence("clear", "nni", 0, nil, err)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301625 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001626 return nil
Devmalya Paul495b94a2019-08-27 19:42:00 -04001627}
1628
1629// DeleteDevice deletes the device instance from openolt handler array. Also clears allocated resource manager resources. Also reboots the OLT hardware!
npujarec5762e2020-01-01 14:08:48 +05301630func (dh *DeviceHandler) DeleteDevice(ctx context.Context, device *voltha.Device) error {
Shrey Baid807a2a02020-04-09 12:52:45 +05301631 logger.Debug("function-entry-delete-device")
Devmalya Paul495b94a2019-08-27 19:42:00 -04001632 /* Clear the KV store data associated with the all the UNI ports
1633 This clears up flow data and also resource map data for various
1634 other pon resources like alloc_id and gemport_id
1635 */
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001636 go dh.cleanupDeviceResources(ctx)
Shrey Baid807a2a02020-04-09 12:52:45 +05301637 logger.Debug("removed-device-from-Resource-manager-KV-store")
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001638 // Stop the Stats collector
1639 dh.stopCollector <- true
1640 // stop the heartbeat check routine
1641 dh.stopHeartbeatCheck <- true
1642 //Reset the state
1643 if dh.Client != nil {
1644 if _, err := dh.Client.Reboot(ctx, new(oop.Empty)); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +05301645 return olterrors.NewErrAdapter("olt-reboot-failed", log.Fields{"device-id": dh.device.Id}, err).Log()
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001646 }
1647 }
1648 cloned := proto.Clone(device).(*voltha.Device)
1649 cloned.OperStatus = voltha.OperStatus_UNKNOWN
1650 cloned.ConnectStatus = voltha.ConnectStatus_UNREACHABLE
1651 if err := dh.coreProxy.DeviceStateUpdate(ctx, cloned.Id, cloned.ConnectStatus, cloned.OperStatus); err != nil {
1652 return olterrors.NewErrAdapter("device-state-update-failed", log.Fields{
1653 "device-id": device.Id,
1654 "connect-status": cloned.ConnectStatus,
1655 "oper-status": cloned.OperStatus}, err).Log()
1656 }
1657 return nil
1658}
1659func (dh *DeviceHandler) cleanupDeviceResources(ctx context.Context) error {
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001660 if dh.resourceMgr != nil {
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301661 noOfPonPorts := dh.resourceMgr.DevInfo.GetPonPorts()
1662 var ponPort uint32
1663 for ponPort = 0; ponPort < noOfPonPorts; ponPort++ {
1664 var onuGemData []rsrcMgr.OnuGemInfo
npujarec5762e2020-01-01 14:08:48 +05301665 err := dh.resourceMgr.ResourceMgrs[ponPort].GetOnuGemInfo(ctx, ponPort, &onuGemData)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301666 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301667 return olterrors.NewErrNotFound("onu", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001668 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00001669 "pon-port": ponPort}, err)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301670 }
1671 for _, onu := range onuGemData {
Abhilash Laxmeshwar6d1acb92020-01-17 15:43:03 +05301672 onuID := make([]uint32, 1)
Shrey Baid807a2a02020-04-09 12:52:45 +05301673 logger.Debugw("onu-data", log.Fields{"onu": onu})
npujarec5762e2020-01-01 14:08:48 +05301674 if err = dh.clearUNIData(ctx, &onu); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301675 logger.Errorw("failed-to-clear-data-for-onu", log.Fields{"onu-device": onu})
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301676 }
Abhilash Laxmeshwar6d1acb92020-01-17 15:43:03 +05301677 // Clear flowids for gem cache.
1678 for _, gem := range onu.GemPorts {
npujarec5762e2020-01-01 14:08:48 +05301679 dh.resourceMgr.DeleteFlowIDsForGem(ctx, ponPort, gem)
Abhilash Laxmeshwar6d1acb92020-01-17 15:43:03 +05301680 }
1681 onuID[0] = onu.OnuID
npujarec5762e2020-01-01 14:08:48 +05301682 dh.resourceMgr.FreeonuID(ctx, ponPort, onuID)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301683 }
npujarec5762e2020-01-01 14:08:48 +05301684 dh.resourceMgr.DeleteIntfIDGempMapPath(ctx, ponPort)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301685 onuGemData = nil
npujarec5762e2020-01-01 14:08:48 +05301686 err = dh.resourceMgr.DelOnuGemInfoForIntf(ctx, ponPort)
Abhilash Laxmeshwarab0bd522019-10-21 15:05:15 +05301687 if err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05301688 logger.Errorw("failed-to-update-onugem-info", log.Fields{"intfid": ponPort, "onugeminfo": onuGemData})
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001689 }
Devmalya Paul495b94a2019-08-27 19:42:00 -04001690 }
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001691 /* Clear the flows from KV store associated with NNI port.
1692 There are mostly trap rules from NNI port (like LLDP)
1693 */
npujarec5762e2020-01-01 14:08:48 +05301694 if err := dh.clearNNIData(ctx); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +05301695 logger.Errorw("failed-to-clear-data-for-NNI-port", log.Fields{"device-id": dh.device.Id})
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001696 }
A R Karthick1f85b802019-10-11 05:06:05 +00001697
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001698 /* Clear the resource pool for each PON port in the background */
npujarec5762e2020-01-01 14:08:48 +05301699 go dh.resourceMgr.Delete(ctx)
Serkant Uluderya89ff40c2019-10-17 16:02:25 -07001700 }
A R Karthick1f85b802019-10-11 05:06:05 +00001701
Devmalya Paul495b94a2019-08-27 19:42:00 -04001702 /*Delete ONU map for the device*/
Naga Manjunatha8dc9372019-10-31 23:01:18 +05301703 dh.onus.Range(func(key interface{}, value interface{}) bool {
1704 dh.onus.Delete(key)
1705 return true
1706 })
1707
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001708 /*Delete discovered ONU map for the device*/
1709 dh.discOnus.Range(func(key interface{}, value interface{}) bool {
1710 dh.discOnus.Delete(key)
1711 return true
1712 })
1713
Devmalya Paul495b94a2019-08-27 19:42:00 -04001714 return nil
1715}
1716
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001717//RebootDevice reboots the given device
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -04001718func (dh *DeviceHandler) RebootDevice(device *voltha.Device) error {
1719 if _, err := dh.Client.Reboot(context.Background(), new(oop.Empty)); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +05301720 return olterrors.NewErrAdapter("olt-reboot-failed", log.Fields{"device-id": dh.device.Id}, err)
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -04001721 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301722 logger.Debugw("rebooted-device-successfully", log.Fields{"device-id": device.Id})
Girish Gowdru0fe5f7e2019-05-28 05:12:27 -04001723 return nil
1724}
1725
David K. Bainbridge794735f2020-02-11 21:01:37 -08001726func (dh *DeviceHandler) handlePacketIndication(ctx context.Context, packetIn *oop.PacketIndication) error {
Matteo Scandolo92186242020-06-12 10:54:18 -07001727 if logger.V(log.DebugLevel) {
1728 logger.Debugw("received-packet-in", log.Fields{
1729 "packet-indication": *packetIn,
1730 "device-id": dh.device.Id,
1731 "packet": hex.EncodeToString(packetIn.Pkt),
1732 })
1733 }
npujarec5762e2020-01-01 14:08:48 +05301734 logicalPortNum, err := dh.flowMgr.GetLogicalPortFromPacketIn(ctx, packetIn)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001735 if err != nil {
Girish Kumarf26e4882020-03-05 06:49:10 +00001736 return olterrors.NewErrNotFound("logical-port", log.Fields{"packet": hex.EncodeToString(packetIn.Pkt)}, err)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001737 }
Matteo Scandolo92186242020-06-12 10:54:18 -07001738 if logger.V(log.DebugLevel) {
1739 logger.Debugw("sending-packet-in-to-core", log.Fields{
1740 "logical-port-num": logicalPortNum,
1741 "device-id": dh.device.Id,
1742 "packet": hex.EncodeToString(packetIn.Pkt),
1743 })
1744 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001745 if err := dh.coreProxy.SendPacketIn(context.TODO(), dh.device.Id, logicalPortNum, packetIn.Pkt); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301746 return olterrors.NewErrCommunication("send-packet-in", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001747 "destination": "core",
Thomas Lee S985938d2020-05-04 11:40:41 +05301748 "source": dh.device.Type,
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001749 "device-id": dh.device.Id,
1750 "packet": hex.EncodeToString(packetIn.Pkt),
1751 }, err)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001752 }
Matteo Scandolo92186242020-06-12 10:54:18 -07001753 if logger.V(log.DebugLevel) {
1754 logger.Debugw("success-sending-packet-in-to-core!", log.Fields{
1755 "packet": hex.EncodeToString(packetIn.Pkt),
1756 "device-id": dh.device.Id,
1757 })
1758 }
David K. Bainbridge794735f2020-02-11 21:01:37 -08001759 return nil
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001760}
1761
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001762// PacketOut sends packet-out from VOLTHA to OLT on the egress port provided
npujarec5762e2020-01-01 14:08:48 +05301763func (dh *DeviceHandler) PacketOut(ctx context.Context, egressPortNo int, packet *of.OfpPacketOut) error {
Matteo Scandolo92186242020-06-12 10:54:18 -07001764 if logger.V(log.DebugLevel) {
1765 logger.Debugw("incoming-packet-out", log.Fields{
1766 "device-id": dh.device.Id,
1767 "egress-port-no": egressPortNo,
1768 "pkt-length": len(packet.Data),
1769 "packet": hex.EncodeToString(packet.Data),
1770 })
1771 }
Matt Jeanneret1359c732019-08-01 21:40:02 -04001772
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001773 egressPortType := IntfIDToPortTypeName(uint32(egressPortNo))
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001774 if egressPortType == voltha.Port_ETHERNET_UNI {
Matt Jeanneret1359c732019-08-01 21:40:02 -04001775 outerEthType := (uint16(packet.Data[12]) << 8) | uint16(packet.Data[13])
1776 innerEthType := (uint16(packet.Data[16]) << 8) | uint16(packet.Data[17])
Girish Gowdra6e1534a2019-11-15 19:24:04 +05301777 if outerEthType == 0x8942 || outerEthType == 0x88cc {
1778 // Do not packet-out lldp packets on uni port.
1779 // ONOS has no clue about uni/nni ports, it just packets out on all
1780 // available ports on the Logical Switch. It should not be interested
1781 // in the UNI links.
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001782 logger.Debugw("dropping-lldp-packet-out-on-uni", log.Fields{
1783 "device-id": dh.device.Id,
1784 })
Girish Gowdra6e1534a2019-11-15 19:24:04 +05301785 return nil
1786 }
Matt Jeanneret1359c732019-08-01 21:40:02 -04001787 if outerEthType == 0x88a8 || outerEthType == 0x8100 {
1788 if innerEthType == 0x8100 {
1789 // q-in-q 802.1ad or 802.1q double tagged packet.
1790 // slice out the outer tag.
1791 packet.Data = append(packet.Data[:12], packet.Data[16:]...)
Matteo Scandolo92186242020-06-12 10:54:18 -07001792 if logger.V(log.DebugLevel) {
1793 logger.Debugw("packet-now-single-tagged", log.Fields{
1794 "packet-data": hex.EncodeToString(packet.Data),
1795 "device-id": dh.device.Id,
1796 })
1797 }
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001798 }
1799 }
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001800 intfID := IntfIDFromUniPortNum(uint32(egressPortNo))
1801 onuID := OnuIDFromPortNum(uint32(egressPortNo))
Manikkaraj kb1d51442019-07-23 10:41:02 -04001802 uniID := UniIDFromPortNum(uint32(egressPortNo))
1803
npujarec5762e2020-01-01 14:08:48 +05301804 gemPortID, err := dh.flowMgr.GetPacketOutGemPortID(ctx, intfID, onuID, uint32(egressPortNo))
Manikkaraj kb1d51442019-07-23 10:41:02 -04001805 if err != nil {
1806 // In this case the openolt agent will receive the gemPortID as 0.
1807 // The agent tries to retrieve the gemPortID in this case.
1808 // This may not always succeed at the agent and packetOut may fail.
Girish Kumar2ad402b2020-03-20 19:45:12 +00001809 logger.Errorw("failed-to-retrieve-gemport-id-for-packet-out", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07001810 "intf-id": intfID,
1811 "onu-id": onuID,
1812 "uni-id": uniID,
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001813 "packet": hex.EncodeToString(packet.Data),
Thomas Lee S985938d2020-05-04 11:40:41 +05301814 "device-id": dh.device.Id,
Matteo Scandolo6056e822019-11-13 14:05:29 -08001815 })
Manikkaraj kb1d51442019-07-23 10:41:02 -04001816 }
1817
1818 onuPkt := oop.OnuPacket{IntfId: intfID, OnuId: onuID, PortNo: uint32(egressPortNo), GemportId: gemPortID, Pkt: packet.Data}
Matt Jeanneret1359c732019-08-01 21:40:02 -04001819
Matteo Scandolo92186242020-06-12 10:54:18 -07001820 if logger.V(log.DebugLevel) {
1821 logger.Debugw("sending-packet-to-onu", log.Fields{
1822 "egress-port-no": egressPortNo,
1823 "intf-id": intfID,
1824 "onu-id": onuID,
1825 "uni-id": uniID,
1826 "gem-port-id": gemPortID,
1827 "packet": hex.EncodeToString(packet.Data),
1828 "device-id": dh.device.Id,
1829 })
1830 }
Matt Jeanneret1359c732019-08-01 21:40:02 -04001831
npujarec5762e2020-01-01 14:08:48 +05301832 if _, err := dh.Client.OnuPacketOut(ctx, &onuPkt); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301833 return olterrors.NewErrCommunication("packet-out-send", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001834 "source": "adapter",
1835 "destination": "onu",
1836 "egress-port-number": egressPortNo,
Matteo Scandolo92186242020-06-12 10:54:18 -07001837 "intf-id": intfID,
David K. Bainbridge794735f2020-02-11 21:01:37 -08001838 "oni-id": onuID,
1839 "uni-id": uniID,
1840 "gem-port-id": gemPortID,
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001841 "packet": hex.EncodeToString(packet.Data),
1842 "device-id": dh.device.Id,
1843 }, err)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001844 }
1845 } else if egressPortType == voltha.Port_ETHERNET_NNI {
David K. Bainbridge794735f2020-02-11 21:01:37 -08001846 nniIntfID, err := IntfIDFromNniPortNum(uint32(egressPortNo))
1847 if err != nil {
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001848 return olterrors.NewErrInvalidValue(log.Fields{
1849 "egress-nni-port": egressPortNo,
1850 "device-id": dh.device.Id,
1851 }, err)
David K. Bainbridge794735f2020-02-11 21:01:37 -08001852 }
1853 uplinkPkt := oop.UplinkPacket{IntfId: nniIntfID, Pkt: packet.Data}
Matt Jeanneret1359c732019-08-01 21:40:02 -04001854
Matteo Scandolo92186242020-06-12 10:54:18 -07001855 if logger.V(log.DebugLevel) {
1856 logger.Debugw("sending-packet-to-nni", log.Fields{
1857 "uplink-pkt": uplinkPkt,
1858 "packet": hex.EncodeToString(packet.Data),
1859 "device-id": dh.device.Id,
1860 })
1861 }
Matt Jeanneret1359c732019-08-01 21:40:02 -04001862
npujarec5762e2020-01-01 14:08:48 +05301863 if _, err := dh.Client.UplinkPacketOut(ctx, &uplinkPkt); err != nil {
Matteo Scandolod625b4c2020-04-02 16:16:01 -07001864 return olterrors.NewErrCommunication("packet-out-to-nni", log.Fields{
1865 "packet": hex.EncodeToString(packet.Data),
1866 "device-id": dh.device.Id,
1867 }, err)
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001868 }
1869 } else {
Shrey Baid807a2a02020-04-09 12:52:45 +05301870 logger.Warnw("packet-out-to-this-interface-type-not-implemented", log.Fields{
1871 "egress-port-no": egressPortNo,
Matteo Scandolo6056e822019-11-13 14:05:29 -08001872 "egressPortType": egressPortType,
1873 "packet": hex.EncodeToString(packet.Data),
Thomas Lee S985938d2020-05-04 11:40:41 +05301874 "device-id": dh.device.Id,
Matteo Scandolo6056e822019-11-13 14:05:29 -08001875 })
manikkaraj k9eb6cac2019-05-09 12:32:03 -04001876 }
1877 return nil
1878}
Mahir Gunyela3f9add2019-06-06 15:13:19 -07001879
Girish Gowdru6a80bbd2019-07-02 07:36:09 -07001880func (dh *DeviceHandler) formOnuKey(intfID, onuID uint32) string {
1881 return "" + strconv.Itoa(int(intfID)) + "." + strconv.Itoa(int(onuID))
Mahir Gunyela3f9add2019-06-06 15:13:19 -07001882}
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301883
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001884func startHeartbeatCheck(ctx context.Context, dh *DeviceHandler) {
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301885 // start the heartbeat check towards the OLT.
1886 var timerCheck *time.Timer
1887
1888 for {
1889 heartbeatTimer := time.NewTimer(dh.openOLT.HeartbeatCheckInterval)
1890 select {
1891 case <-heartbeatTimer.C:
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001892 ctxWithTimeout, cancel := context.WithTimeout(context.Background(), dh.openOLT.GrpcTimeoutInterval)
1893 if heartBeat, err := dh.Client.HeartbeatCheck(ctxWithTimeout, new(oop.Empty)); err != nil {
Thomas Lee S985938d2020-05-04 11:40:41 +05301894 logger.Warnw("hearbeat-failed", log.Fields{"device-id": dh.device.Id})
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301895 if timerCheck == nil {
1896 // start a after func, when expired will update the state to the core
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001897 timerCheck = time.AfterFunc(dh.openOLT.HeartbeatFailReportInterval, func() { dh.updateStateUnreachable(ctx) })
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301898 }
1899 } else {
1900 if timerCheck != nil {
1901 if timerCheck.Stop() {
Thomas Lee S985938d2020-05-04 11:40:41 +05301902 logger.Debugw("got-hearbeat-within-timeout", log.Fields{"device-id": dh.device.Id})
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301903 }
1904 timerCheck = nil
1905 }
Shrey Baid807a2a02020-04-09 12:52:45 +05301906 logger.Debugw("hearbeat",
1907 log.Fields{"signature": heartBeat,
Thomas Lee S985938d2020-05-04 11:40:41 +05301908 "device-id": dh.device.Id})
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301909 }
1910 cancel()
1911 case <-dh.stopHeartbeatCheck:
Thomas Lee S985938d2020-05-04 11:40:41 +05301912 logger.Debugw("stopping-heart-beat-check", log.Fields{"device-id": dh.device.Id})
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301913 return
1914 }
1915 }
1916}
1917
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001918func (dh *DeviceHandler) updateStateUnreachable(ctx context.Context) {
1919 device, err := dh.coreProxy.GetDevice(ctx, dh.device.Id, dh.device.Id)
1920 if err != nil || device == nil {
1921 olterrors.NewErrNotFound("device", log.Fields{"device-id": dh.device.Id}, err).Log()
1922 }
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301923
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001924 if device.ConnectStatus == voltha.ConnectStatus_REACHABLE {
1925 if err = dh.coreProxy.DeviceStateUpdate(ctx, dh.device.Id, voltha.ConnectStatus_UNREACHABLE, voltha.OperStatus_UNKNOWN); err != nil {
1926 olterrors.NewErrAdapter("device-state-update-failed", log.Fields{"device-id": dh.device.Id}, err).LogAt(log.ErrorLevel)
1927 }
1928 if err = dh.coreProxy.PortsStateUpdate(ctx, dh.device.Id, voltha.OperStatus_UNKNOWN); err != nil {
1929 olterrors.NewErrAdapter("port-update-failed", log.Fields{"device-id": dh.device.Id}, err).Log()
1930 }
1931 go dh.cleanupDeviceResources(ctx)
1932
Girish Gowdra3ab6d212020-03-24 17:33:15 -07001933 dh.lockDevice.RLock()
1934 // Stop the read indication only if it the routine is active
1935 // The read indication would have already stopped due to failure on the gRPC stream following OLT going unreachable
1936 // Sending message on the 'stopIndication' channel again will cause the readIndication routine to immediately stop
1937 // on next execution of the readIndication routine.
1938 if dh.isReadIndicationRoutineActive {
1939 dh.stopIndications <- true
1940 }
1941 dh.lockDevice.RUnlock()
1942
Chaitrashree G Sa4649252020-03-11 21:24:11 -04001943 dh.transitionMap.Handle(ctx, DeviceInit)
1944
Abhilash Laxmeshwarf9942e92020-01-07 15:32:44 +05301945 }
1946}
kesavand39e0aa32020-01-28 20:58:50 -05001947
1948// EnablePort to enable Pon interface
1949func (dh *DeviceHandler) EnablePort(port *voltha.Port) error {
Girish Kumar2ad402b2020-03-20 19:45:12 +00001950 logger.Debugw("enable-port", log.Fields{"Device": dh.device, "port": port})
kdarapu1afeceb2020-02-12 01:38:09 -05001951 return dh.modifyPhyPort(port, true)
kesavand39e0aa32020-01-28 20:58:50 -05001952}
1953
1954// DisablePort to disable pon interface
1955func (dh *DeviceHandler) DisablePort(port *voltha.Port) error {
Girish Kumar2ad402b2020-03-20 19:45:12 +00001956 logger.Debugw("disable-port", log.Fields{"Device": dh.device, "port": port})
kdarapu1afeceb2020-02-12 01:38:09 -05001957 return dh.modifyPhyPort(port, false)
kesavand39e0aa32020-01-28 20:58:50 -05001958}
1959
kdarapu1afeceb2020-02-12 01:38:09 -05001960//modifyPhyPort is common function to enable and disable the port. parm :enablePort, true to enablePort and false to disablePort.
1961func (dh *DeviceHandler) modifyPhyPort(port *voltha.Port, enablePort bool) error {
npujarec5762e2020-01-01 14:08:48 +05301962 ctx := context.Background()
Thomas Lee S985938d2020-05-04 11:40:41 +05301963 logger.Infow("modifyPhyPort", log.Fields{"port": port, "Enable": enablePort, "device-id": dh.device.Id})
kesavand39e0aa32020-01-28 20:58:50 -05001964 if port.GetType() == voltha.Port_ETHERNET_NNI {
1965 // Bug is opened for VOL-2505 to support NNI disable feature.
Girish Kumar2ad402b2020-03-20 19:45:12 +00001966 logger.Infow("voltha-supports-single-nni-hence-disable-of-nni-not-allowed",
Shrey Baid807a2a02020-04-09 12:52:45 +05301967 log.Fields{"device": dh.device, "port": port})
Thomas Lee S94109f12020-03-03 16:39:29 +05301968 return olterrors.NewErrAdapter("illegal-port-request", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001969 "port-type": port.GetType,
Girish Kumarf26e4882020-03-05 06:49:10 +00001970 "enable-state": enablePort}, nil)
kesavand39e0aa32020-01-28 20:58:50 -05001971 }
1972 // fetch interfaceid from PortNo
1973 ponID := PortNoToIntfID(port.GetPortNo(), voltha.Port_PON_OLT)
1974 ponIntf := &oop.Interface{IntfId: ponID}
1975 var operStatus voltha.OperStatus_Types
1976 if enablePort {
1977 operStatus = voltha.OperStatus_ACTIVE
npujarec5762e2020-01-01 14:08:48 +05301978 out, err := dh.Client.EnablePonIf(ctx, ponIntf)
kesavand39e0aa32020-01-28 20:58:50 -05001979
1980 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301981 return olterrors.NewErrAdapter("pon-port-enable-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001982 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00001983 "port": port}, err)
kesavand39e0aa32020-01-28 20:58:50 -05001984 }
1985 // updating interface local cache for collecting stats
Chaitrashree G Sef088112020-02-03 21:39:27 -05001986 dh.activePorts.Store(ponID, true)
Shrey Baid807a2a02020-04-09 12:52:45 +05301987 logger.Infow("enabled-pon-port", log.Fields{"out": out, "device-id": dh.device, "Port": port})
kesavand39e0aa32020-01-28 20:58:50 -05001988 } else {
1989 operStatus = voltha.OperStatus_UNKNOWN
npujarec5762e2020-01-01 14:08:48 +05301990 out, err := dh.Client.DisablePonIf(ctx, ponIntf)
kesavand39e0aa32020-01-28 20:58:50 -05001991 if err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05301992 return olterrors.NewErrAdapter("pon-port-disable-failed", log.Fields{
David K. Bainbridge794735f2020-02-11 21:01:37 -08001993 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00001994 "port": port}, err)
kesavand39e0aa32020-01-28 20:58:50 -05001995 }
1996 // updating interface local cache for collecting stats
Chaitrashree G Sef088112020-02-03 21:39:27 -05001997 dh.activePorts.Store(ponID, false)
Shrey Baid807a2a02020-04-09 12:52:45 +05301998 logger.Infow("disabled-pon-port", log.Fields{"out": out, "device-id": dh.device, "Port": port})
kesavand39e0aa32020-01-28 20:58:50 -05001999 }
Thomas Lee S985938d2020-05-04 11:40:41 +05302000 if err := dh.coreProxy.PortStateUpdate(ctx, dh.device.Id, voltha.Port_PON_OLT, port.PortNo, operStatus); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05302001 return olterrors.NewErrAdapter("port-state-update-failed", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +05302002 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00002003 "port": port.PortNo}, err)
kesavand39e0aa32020-01-28 20:58:50 -05002004 }
2005 return nil
2006}
2007
kdarapu1afeceb2020-02-12 01:38:09 -05002008//disableAdminDownPorts disables the ports, if the corresponding port Adminstate is disabled on reboot and Renable device.
2009func (dh *DeviceHandler) disableAdminDownPorts(device *voltha.Device) error {
kesavand39e0aa32020-01-28 20:58:50 -05002010 cloned := proto.Clone(device).(*voltha.Device)
2011 // Disable the port and update the oper_port_status to core
2012 // if the Admin state of the port is disabled on reboot and re-enable device.
2013 for _, port := range cloned.Ports {
2014 if port.AdminState == common.AdminState_DISABLED {
kdarapu1afeceb2020-02-12 01:38:09 -05002015 if err := dh.DisablePort(port); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05302016 return olterrors.NewErrAdapter("port-disable-failed", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +05302017 "device-id": dh.device.Id,
Girish Kumarf26e4882020-03-05 06:49:10 +00002018 "port": port}, err)
kesavand39e0aa32020-01-28 20:58:50 -05002019 }
2020 }
2021 }
2022 return nil
2023}
2024
2025//populateActivePorts to populate activePorts map
2026func (dh *DeviceHandler) populateActivePorts(device *voltha.Device) {
Shrey Baid807a2a02020-04-09 12:52:45 +05302027 logger.Infow("populateActiveports", log.Fields{"Device": device})
kesavand39e0aa32020-01-28 20:58:50 -05002028 for _, port := range device.Ports {
2029 if port.Type == voltha.Port_ETHERNET_NNI {
2030 if port.OperStatus == voltha.OperStatus_ACTIVE {
Chaitrashree G Sef088112020-02-03 21:39:27 -05002031 dh.activePorts.Store(PortNoToIntfID(port.PortNo, voltha.Port_ETHERNET_NNI), true)
kesavand39e0aa32020-01-28 20:58:50 -05002032 } else {
Chaitrashree G Sef088112020-02-03 21:39:27 -05002033 dh.activePorts.Store(PortNoToIntfID(port.PortNo, voltha.Port_ETHERNET_NNI), false)
kesavand39e0aa32020-01-28 20:58:50 -05002034 }
2035 }
2036 if port.Type == voltha.Port_PON_OLT {
2037 if port.OperStatus == voltha.OperStatus_ACTIVE {
Chaitrashree G Sef088112020-02-03 21:39:27 -05002038 dh.activePorts.Store(PortNoToIntfID(port.PortNo, voltha.Port_PON_OLT), true)
kesavand39e0aa32020-01-28 20:58:50 -05002039 } else {
Chaitrashree G Sef088112020-02-03 21:39:27 -05002040 dh.activePorts.Store(PortNoToIntfID(port.PortNo, voltha.Port_PON_OLT), false)
kesavand39e0aa32020-01-28 20:58:50 -05002041 }
2042 }
2043 }
2044}
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002045
2046// ChildDeviceLost deletes ONU and clears pon resources related to it.
2047func (dh *DeviceHandler) ChildDeviceLost(ctx context.Context, pPortNo uint32, onuID uint32) error {
Girish Kumar2ad402b2020-03-20 19:45:12 +00002048 logger.Debugw("child-device-lost", log.Fields{"pdeviceID": dh.device.Id})
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002049 intfID := PortNoToIntfID(pPortNo, voltha.Port_PON_OLT)
2050 onuKey := dh.formOnuKey(intfID, onuID)
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002051 onuDevice, ok := dh.onus.Load(onuKey)
2052 if !ok {
Thomas Lee S94109f12020-03-03 16:39:29 +05302053 return olterrors.NewErrAdapter("failed-to-load-onu-details",
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002054 log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07002055 "device-id": dh.device.Id,
2056 "onu-id": onuID,
2057 "intf-id": intfID}, nil).Log()
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002058 }
2059 var sn *oop.SerialNumber
2060 var err error
2061 if sn, err = dh.deStringifySerialNumber(onuDevice.(*OnuDevice).serialNumber); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05302062 return olterrors.NewErrAdapter("failed-to-destringify-serial-number",
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002063 log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +05302064 "devicer-id": dh.device.Id,
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002065 "serial-number": onuDevice.(*OnuDevice).serialNumber}, err).Log()
2066 }
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002067
2068 for uniID := 0; uniID < MaxUnisPerOnu; uniID++ {
2069 var flowRemoveData pendingFlowRemoveData
2070 key := pendingFlowRemoveDataKey{intfID: intfID, onuID: onuID, uniID: uint32(uniID)}
2071 dh.lockDevice.RLock()
2072 if flowRemoveData, ok = dh.pendingFlowRemoveDataPerSubscriber[key]; !ok {
2073 dh.lockDevice.RUnlock()
2074 continue
2075 }
2076 dh.lockDevice.RUnlock()
2077
2078 log.Debugw("wait-for-flow-remove-complete-before-processing-child-device-lost",
2079 log.Fields{"int-id": intfID, "onu-id": onuID, "uni-id": uniID})
2080 // Wait for all flow removes to finish first
2081 <-flowRemoveData.allFlowsRemoved
2082 log.Debugw("flow-removes-complete-for-subscriber",
2083 log.Fields{"int-id": intfID, "onu-id": onuID, "uni-id": uniID})
2084 }
2085
2086 onu := &oop.Onu{IntfId: intfID, OnuId: onuID, SerialNumber: sn}
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002087 if _, err := dh.Client.DeleteOnu(context.Background(), onu); err != nil {
Thomas Lee S94109f12020-03-03 16:39:29 +05302088 return olterrors.NewErrAdapter("failed-to-delete-onu", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +05302089 "device-id": dh.device.Id,
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002090 "onu-id": onuID}, err).Log()
2091 }
2092 //clear PON resources associated with ONU
2093 var onuGemData []rsrcMgr.OnuGemInfo
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002094 if onuMgr, ok := dh.resourceMgr.ResourceMgrs[intfID]; !ok {
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002095 logger.Warnw("failed-to-get-resource-manager-for-interface-Id", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07002096 "device-id": dh.device.Id,
2097 "intf-id": intfID})
Chaitrashree G Se420b5f2020-02-23 21:34:54 -05002098 } else {
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002099 if err := onuMgr.GetOnuGemInfo(ctx, intfID, &onuGemData); err != nil {
Shrey Baid807a2a02020-04-09 12:52:45 +05302100 logger.Warnw("failed-to-get-onu-info-for-pon-port", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07002101 "device-id": dh.device.Id,
2102 "intf-id": intfID,
2103 "error": err})
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002104 } else {
2105 for i, onu := range onuGemData {
2106 if onu.OnuID == onuID && onu.SerialNumber == onuDevice.(*OnuDevice).serialNumber {
Shrey Baid807a2a02020-04-09 12:52:45 +05302107 logger.Debugw("onu-data", log.Fields{"onu": onu})
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002108 if err := dh.clearUNIData(ctx, &onu); err != nil {
2109 logger.Warnw("failed-to-clear-uni-data-for-onu", log.Fields{
Thomas Lee S985938d2020-05-04 11:40:41 +05302110 "device-id": dh.device.Id,
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002111 "onu-device": onu,
2112 "error": err})
2113 }
2114 // Clear flowids for gem cache.
2115 for _, gem := range onu.GemPorts {
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002116 dh.resourceMgr.DeleteFlowIDsForGem(ctx, intfID, gem)
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002117 }
2118 onuGemData = append(onuGemData[:i], onuGemData[i+1:]...)
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002119 err := onuMgr.AddOnuGemInfo(ctx, intfID, onuGemData)
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002120 if err != nil {
2121 logger.Warnw("persistence-update-onu-gem-info-failed", log.Fields{
Matteo Scandolo92186242020-06-12 10:54:18 -07002122 "intf-id": intfID,
2123 "onu-device": onu,
2124 "onu-gem": onuGemData,
2125 "error": err})
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002126 //Not returning error on cleanup.
2127 }
Girish Gowdra89ae6d82020-05-28 23:40:53 -07002128 logger.Debugw("removed-onu-gem-info", log.Fields{"intf": intfID, "onu-device": onu, "onugem": onuGemData})
2129 dh.resourceMgr.FreeonuID(ctx, intfID, []uint32{onu.OnuID})
Andrea Campanella668ea5f2020-03-31 13:51:06 +02002130 break
Chaitrashree G Se420b5f2020-02-23 21:34:54 -05002131 }
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002132 }
Chaitrashree G S1a55b882020-02-04 17:35:35 -05002133 }
2134 }
2135 dh.onus.Delete(onuKey)
2136 dh.discOnus.Delete(onuDevice.(*OnuDevice).serialNumber)
2137 return nil
2138}
Girish Gowdracefae192020-03-19 18:14:10 -07002139
2140func getInPortFromFlow(flow *of.OfpFlowStats) uint32 {
2141 for _, field := range flows.GetOfbFields(flow) {
2142 if field.Type == flows.IN_PORT {
2143 return field.GetPort()
2144 }
2145 }
2146 return InvalidPort
2147}
2148
2149func getOutPortFromFlow(flow *of.OfpFlowStats) uint32 {
2150 for _, action := range flows.GetActions(flow) {
2151 if action.Type == flows.OUTPUT {
2152 if out := action.GetOutput(); out != nil {
2153 return out.GetPort()
2154 }
2155 }
2156 }
2157 return InvalidPort
2158}
2159
2160func (dh *DeviceHandler) incrementActiveFlowRemoveCount(flow *of.OfpFlowStats) {
2161 inPort, outPort := getPorts(flow)
Matteo Scandolo92186242020-06-12 10:54:18 -07002162 logger.Debugw("increment-flow-remove-count-for-inPort-out-port", log.Fields{"inPort": inPort, "out-port": outPort})
Girish Gowdracefae192020-03-19 18:14:10 -07002163 if inPort != InvalidPort && outPort != InvalidPort {
2164 _, intfID, onuID, uniID := ExtractAccessFromFlow(inPort, outPort)
2165 key := pendingFlowRemoveDataKey{intfID: intfID, onuID: onuID, uniID: uniID}
Matteo Scandolo92186242020-06-12 10:54:18 -07002166 logger.Debugw("increment-flow-remove-count-for-subscriber", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002167
2168 dh.lockDevice.Lock()
2169 defer dh.lockDevice.Unlock()
2170 flowRemoveData, ok := dh.pendingFlowRemoveDataPerSubscriber[key]
2171 if !ok {
2172 flowRemoveData = pendingFlowRemoveData{
2173 pendingFlowRemoveCount: 0,
2174 allFlowsRemoved: make(chan struct{}),
2175 }
2176 }
2177 flowRemoveData.pendingFlowRemoveCount++
2178 dh.pendingFlowRemoveDataPerSubscriber[key] = flowRemoveData
2179
Shrey Baid807a2a02020-04-09 12:52:45 +05302180 logger.Debugw("current-flow-remove-count–increment",
Matteo Scandolo92186242020-06-12 10:54:18 -07002181 log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID,
Girish Gowdracefae192020-03-19 18:14:10 -07002182 "currCnt": dh.pendingFlowRemoveDataPerSubscriber[key].pendingFlowRemoveCount})
2183 }
2184}
2185
2186func (dh *DeviceHandler) decrementActiveFlowRemoveCount(flow *of.OfpFlowStats) {
2187 inPort, outPort := getPorts(flow)
Matteo Scandolo92186242020-06-12 10:54:18 -07002188 logger.Debugw("decrement-flow-remove-count-for-inPort-out-port", log.Fields{"inPort": inPort, "out-port": outPort})
Girish Gowdracefae192020-03-19 18:14:10 -07002189 if inPort != InvalidPort && outPort != InvalidPort {
2190 _, intfID, onuID, uniID := ExtractAccessFromFlow(uint32(inPort), uint32(outPort))
2191 key := pendingFlowRemoveDataKey{intfID: intfID, onuID: onuID, uniID: uniID}
Matteo Scandolo92186242020-06-12 10:54:18 -07002192 logger.Debugw("decrement-flow-remove-count-for-subscriber", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002193
2194 dh.lockDevice.Lock()
2195 defer dh.lockDevice.Unlock()
2196 if val, ok := dh.pendingFlowRemoveDataPerSubscriber[key]; !ok {
Matteo Scandolo92186242020-06-12 10:54:18 -07002197 logger.Fatalf("flow-remove-key-not-found", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002198 } else {
2199 if val.pendingFlowRemoveCount > 0 {
2200 val.pendingFlowRemoveCount--
2201 }
Shrey Baid807a2a02020-04-09 12:52:45 +05302202 logger.Debugw("current-flow-remove-count-after-decrement",
Matteo Scandolo92186242020-06-12 10:54:18 -07002203 log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID,
Girish Gowdracefae192020-03-19 18:14:10 -07002204 "currCnt": dh.pendingFlowRemoveDataPerSubscriber[key].pendingFlowRemoveCount})
2205 // If all flow removes have finished, then close the channel to signal the receiver
2206 // to go ahead with flow adds.
2207 if val.pendingFlowRemoveCount == 0 {
2208 close(val.allFlowsRemoved)
2209 delete(dh.pendingFlowRemoveDataPerSubscriber, key)
2210 return
2211 }
2212 dh.pendingFlowRemoveDataPerSubscriber[key] = val
2213 }
2214 }
2215}
2216
2217func (dh *DeviceHandler) waitForFlowRemoveToFinish(flow *of.OfpFlowStats) {
2218 var flowRemoveData pendingFlowRemoveData
2219 var ok bool
2220 inPort, outPort := getPorts(flow)
Matteo Scandolo92186242020-06-12 10:54:18 -07002221 logger.Debugw("wait-for-flow-remove-to-finish-for-inPort-out-port", log.Fields{"inPort": inPort, "out-port": outPort})
Girish Gowdracefae192020-03-19 18:14:10 -07002222 if inPort != InvalidPort && outPort != InvalidPort {
2223 _, intfID, onuID, uniID := ExtractAccessFromFlow(inPort, outPort)
2224 key := pendingFlowRemoveDataKey{intfID: intfID, onuID: onuID, uniID: uniID}
Matteo Scandolo92186242020-06-12 10:54:18 -07002225 logger.Debugw("wait-for-flow-remove-to-finish-for-subscriber", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002226
2227 dh.lockDevice.RLock()
2228 if flowRemoveData, ok = dh.pendingFlowRemoveDataPerSubscriber[key]; !ok {
Matteo Scandolo92186242020-06-12 10:54:18 -07002229 logger.Debugw("no-pending-flow-to-remove", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002230 dh.lockDevice.RUnlock()
2231 return
2232 }
2233 dh.lockDevice.RUnlock()
2234
2235 // Wait for all flow removes to finish first
2236 <-flowRemoveData.allFlowsRemoved
2237
Matteo Scandolo92186242020-06-12 10:54:18 -07002238 logger.Debugw("all-flows-cleared--handling-flow-add-now", log.Fields{"intf-id": intfID, "onu-id": onuID, "uni-id": uniID})
Girish Gowdracefae192020-03-19 18:14:10 -07002239 }
2240}
2241
2242func getPorts(flow *of.OfpFlowStats) (uint32, uint32) {
2243 inPort := getInPortFromFlow(flow)
2244 outPort := getOutPortFromFlow(flow)
2245
2246 if inPort == InvalidPort || outPort == InvalidPort {
2247 return inPort, outPort
2248 }
2249
2250 if isControllerFlow := IsControllerBoundFlow(outPort); isControllerFlow {
2251 /* Get UNI port/ IN Port from tunnel ID field for upstream controller bound flows */
2252 if portType := IntfIDToPortTypeName(inPort); portType == voltha.Port_PON_OLT {
2253 if uniPort := flows.GetChildPortFromTunnelId(flow); uniPort != 0 {
2254 return uniPort, outPort
2255 }
2256 }
2257 } else {
2258 // Downstream flow from NNI to PON port , Use tunnel ID as new OUT port / UNI port
2259 if portType := IntfIDToPortTypeName(outPort); portType == voltha.Port_PON_OLT {
2260 if uniPort := flows.GetChildPortFromTunnelId(flow); uniPort != 0 {
2261 return inPort, uniPort
2262 }
2263 // Upstream flow from PON to NNI port , Use tunnel ID as new IN port / UNI port
2264 } else if portType := IntfIDToPortTypeName(inPort); portType == voltha.Port_PON_OLT {
2265 if uniPort := flows.GetChildPortFromTunnelId(flow); uniPort != 0 {
2266 return uniPort, outPort
2267 }
2268 }
2269 }
2270
2271 return InvalidPort, InvalidPort
2272}
Matt Jeanneretceea2e02020-03-27 14:19:57 -04002273
2274func extractOmciTransactionID(omciPkt []byte) uint16 {
2275 if len(omciPkt) > 3 {
2276 d := omciPkt[0:2]
2277 transid := binary.BigEndian.Uint16(d)
2278 return transid
2279 }
2280 return 0
2281}
Mahir Gunyel0f89fd22020-04-11 18:24:42 -07002282
2283// StoreOnuDevice stores the onu parameters to the local cache.
2284func (dh *DeviceHandler) StoreOnuDevice(onuDevice *OnuDevice) {
2285 onuKey := dh.formOnuKey(onuDevice.intfID, onuDevice.onuID)
2286 dh.onus.Store(onuKey, onuDevice)
2287}
Dinesh Belwalkardb587af2020-02-27 15:37:16 -08002288
Devmalya Paula1efa642020-04-20 01:36:43 -04002289// setOnuITUPonAlarmConfig sets the parameters in the openolt agent for raising the ONU ITU PON alarms.
2290func (dh *DeviceHandler) setOnuITUPonAlarmConfig(config *oop.OnuItuPonAlarm) error {
2291 if _, err := dh.Client.OnuItuPonAlarmSet(context.Background(), config); err != nil {
2292 return err
2293 }
2294 logger.Debugw("onu-itu-pon-alarm-config-set-successful", log.Fields{"config": config})
2295 return nil
2296}
2297
Dinesh Belwalkardb587af2020-02-27 15:37:16 -08002298func (dh *DeviceHandler) getExtValue(device *voltha.Device, value voltha.ValueType_Type) (*voltha.ReturnValues, error) {
2299 var err error
Andrea Campanella9931ad62020-04-28 15:11:06 +02002300 var sn *oop.SerialNumber
Gamze Abaka78a1d2a2020-04-27 10:17:27 +00002301 var ID uint32
Dinesh Belwalkardb587af2020-02-27 15:37:16 -08002302 resp := new(voltha.ReturnValues)
2303 valueparam := new(oop.ValueParam)
2304 ctx := context.Background()
2305 log.Infow("getExtValue", log.Fields{"onu-id": device.Id, "pon-intf": device.ParentPortNo})
Dinesh Belwalkardb587af2020-02-27 15:37:16 -08002306 if sn, err = dh.deStringifySerialNumber(device.SerialNumber); err != nil {
2307 return nil, err
2308 }
2309 ID = device.ProxyAddress.GetOnuId()
2310 Onu := oop.Onu{IntfId: device.ParentPortNo, OnuId: ID, SerialNumber: sn}
2311 valueparam.Onu = &Onu
2312 valueparam.Value = value
2313
2314 // This API is unsupported until agent patch is added
2315 resp.Unsupported = uint32(value)
2316 _ = ctx
2317
2318 // Uncomment this code once agent changes are complete and tests
2319 /*
2320 resp, err = dh.Client.GetValue(ctx, valueparam)
2321 if err != nil {
2322 log.Errorw("error-while-getValue", log.Fields{"DeviceID": dh.device, "onu-id": onuid, "error": err})
2323 return nil, err
2324 }
2325 */
2326
2327 log.Infow("get-ext-value", log.Fields{"resp": resp, "device-id": dh.device, "onu-id": device.Id, "pon-intf": device.ParentPortNo})
2328 return resp, nil
2329}