blob: d1d6b099436d496303217e7ca9153b29c4498fe7 [file] [log] [blame]
Holger Hildebrandtfa074992020-03-27 15:42:06 +00001/*
2 * Copyright 2020-present Open Networking Foundation
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000017//Package adaptercoreonu provides the utility for onu devices, flows and statistics
18package adaptercoreonu
Holger Hildebrandtfa074992020-03-27 15:42:06 +000019
20import (
21 "context"
22 "errors"
23 "fmt"
24 "sync"
25 "time"
26
dbainbri4d3a0dc2020-12-02 00:33:42 +000027 conf "github.com/opencord/voltha-lib-go/v4/pkg/config"
28
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +000029 "github.com/golang/protobuf/ptypes"
dbainbri4d3a0dc2020-12-02 00:33:42 +000030 "github.com/opencord/voltha-lib-go/v4/pkg/adapters/adapterif"
31 "github.com/opencord/voltha-lib-go/v4/pkg/db/kvstore"
Himani Chawlac07fda02020-12-09 16:21:21 +053032 "github.com/opencord/voltha-lib-go/v4/pkg/events/eventif"
dbainbri4d3a0dc2020-12-02 00:33:42 +000033 "github.com/opencord/voltha-lib-go/v4/pkg/kafka"
34 "github.com/opencord/voltha-lib-go/v4/pkg/log"
mpagenkoc8bba412021-01-15 15:38:44 +000035 "github.com/opencord/voltha-protos/v4/go/extension"
dbainbri4d3a0dc2020-12-02 00:33:42 +000036 ic "github.com/opencord/voltha-protos/v4/go/inter_container"
37 "github.com/opencord/voltha-protos/v4/go/openflow_13"
38 oop "github.com/opencord/voltha-protos/v4/go/openolt"
39 "github.com/opencord/voltha-protos/v4/go/voltha"
Holger Hildebrandtfa074992020-03-27 15:42:06 +000040
Matteo Scandolo761f7512020-11-23 15:52:40 -080041 "github.com/opencord/voltha-openonu-adapter-go/internal/pkg/config"
Holger Hildebrandtfa074992020-03-27 15:42:06 +000042)
43
44//OpenONUAC structure holds the ONU core information
45type OpenONUAC struct {
Himani Chawla6d2ae152020-09-02 13:11:20 +053046 deviceHandlers map[string]*deviceHandler
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +000047 deviceHandlersCreateChan map[string]chan bool //channels for deviceHandler create events
Holger Hildebrandt61b24d02020-11-16 13:36:40 +000048 lockDeviceHandlersMap sync.RWMutex
Holger Hildebrandtfa074992020-03-27 15:42:06 +000049 coreProxy adapterif.CoreProxy
50 adapterProxy adapterif.AdapterProxy
Himani Chawlac07fda02020-12-09 16:21:21 +053051 eventProxy eventif.EventProxy
Holger Hildebrandtfa074992020-03-27 15:42:06 +000052 kafkaICProxy kafka.InterContainerProxy
mpagenkoaf801632020-07-03 10:00:42 +000053 kvClient kvstore.Client
Matteo Scandolof1f39a72020-11-24 12:08:11 -080054 cm *conf.ConfigManager
Holger Hildebrandtfa074992020-03-27 15:42:06 +000055 config *config.AdapterFlags
56 numOnus int
Matteo Scandolo127c59d2021-01-28 11:31:18 -080057 KVStoreAddress string
Holger Hildebrandtfa074992020-03-27 15:42:06 +000058 KVStoreType string
mpagenkoaf801632020-07-03 10:00:42 +000059 KVStoreTimeout time.Duration
Holger Hildebrandt61b24d02020-11-16 13:36:40 +000060 mibTemplatesGenerated map[string]bool
61 lockMibTemplateGenerated sync.RWMutex
Holger Hildebrandtfa074992020-03-27 15:42:06 +000062 exitChannel chan int
63 HeartbeatCheckInterval time.Duration
64 HeartbeatFailReportInterval time.Duration
mpagenkodff5dda2020-08-28 11:52:01 +000065 AcceptIncrementalEvto bool
Holger Hildebrandtfa074992020-03-27 15:42:06 +000066 //GrpcTimeoutInterval time.Duration
Himani Chawlad96df182020-09-28 11:12:02 +053067 pSupportedFsms *OmciDeviceFsms
68 maxTimeoutInterAdapterComm time.Duration
Holger Hildebrandt38985dc2021-02-18 16:25:20 +000069 maxTimeoutReconciling time.Duration
mpagenkoc8bba412021-01-15 15:38:44 +000070 pDownloadManager *adapterDownloadManager
Girish Gowdraaf0ad632021-01-27 13:00:01 -080071 metricsEnabled bool
Holger Hildebrandte3677f12021-02-05 14:50:56 +000072 mibAuditInterval time.Duration
Girish Gowdra0b235842021-03-09 13:06:46 -080073 omciTimeout int // in seconds
Himani Chawla075f1642021-03-15 19:23:24 +053074 alarmAuditInterval time.Duration
Holger Hildebrandtfa074992020-03-27 15:42:06 +000075}
76
77//NewOpenONUAC returns a new instance of OpenONU_AC
78func NewOpenONUAC(ctx context.Context, kafkaICProxy kafka.InterContainerProxy,
79 coreProxy adapterif.CoreProxy, adapterProxy adapterif.AdapterProxy,
Himani Chawlac07fda02020-12-09 16:21:21 +053080 eventProxy eventif.EventProxy, kvClient kvstore.Client, cfg *config.AdapterFlags, cm *conf.ConfigManager) *OpenONUAC {
Holger Hildebrandtfa074992020-03-27 15:42:06 +000081 var openOnuAc OpenONUAC
82 openOnuAc.exitChannel = make(chan int, 1)
Himani Chawla6d2ae152020-09-02 13:11:20 +053083 openOnuAc.deviceHandlers = make(map[string]*deviceHandler)
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +000084 openOnuAc.deviceHandlersCreateChan = make(map[string]chan bool)
Holger Hildebrandt61b24d02020-11-16 13:36:40 +000085 openOnuAc.lockDeviceHandlersMap = sync.RWMutex{}
Holger Hildebrandtfa074992020-03-27 15:42:06 +000086 openOnuAc.kafkaICProxy = kafkaICProxy
87 openOnuAc.config = cfg
Matteo Scandolof1f39a72020-11-24 12:08:11 -080088 openOnuAc.cm = cm
Holger Hildebrandtfa074992020-03-27 15:42:06 +000089 openOnuAc.numOnus = cfg.OnuNumber
90 openOnuAc.coreProxy = coreProxy
91 openOnuAc.adapterProxy = adapterProxy
92 openOnuAc.eventProxy = eventProxy
mpagenkoaf801632020-07-03 10:00:42 +000093 openOnuAc.kvClient = kvClient
Matteo Scandolo127c59d2021-01-28 11:31:18 -080094 openOnuAc.KVStoreAddress = cfg.KVStoreAddress
Holger Hildebrandtfa074992020-03-27 15:42:06 +000095 openOnuAc.KVStoreType = cfg.KVStoreType
mpagenkoaf801632020-07-03 10:00:42 +000096 openOnuAc.KVStoreTimeout = cfg.KVStoreTimeout
Holger Hildebrandt61b24d02020-11-16 13:36:40 +000097 openOnuAc.mibTemplatesGenerated = make(map[string]bool)
98 openOnuAc.lockMibTemplateGenerated = sync.RWMutex{}
Holger Hildebrandtfa074992020-03-27 15:42:06 +000099 openOnuAc.HeartbeatCheckInterval = cfg.HeartbeatCheckInterval
100 openOnuAc.HeartbeatFailReportInterval = cfg.HeartbeatFailReportInterval
mpagenkodff5dda2020-08-28 11:52:01 +0000101 openOnuAc.AcceptIncrementalEvto = cfg.AccIncrEvto
Himani Chawlad96df182020-09-28 11:12:02 +0530102 openOnuAc.maxTimeoutInterAdapterComm = cfg.MaxTimeoutInterAdapterComm
Holger Hildebrandt38985dc2021-02-18 16:25:20 +0000103 openOnuAc.maxTimeoutReconciling = cfg.MaxTimeoutReconciling
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000104 //openOnuAc.GrpcTimeoutInterval = cfg.GrpcTimeoutInterval
Girish Gowdraaf0ad632021-01-27 13:00:01 -0800105 openOnuAc.metricsEnabled = cfg.MetricsEnabled
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000106 openOnuAc.mibAuditInterval = cfg.MibAuditInterval
Girish Gowdra0b235842021-03-09 13:06:46 -0800107 // since consumers of OMCI timeout value everywhere in code is in "int seconds", do this useful conversion
108 openOnuAc.omciTimeout = int(cfg.OmciTimeout.Seconds())
Himani Chawla075f1642021-03-15 19:23:24 +0530109 openOnuAc.alarmAuditInterval = cfg.AlarmAuditInterval
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000110
111 openOnuAc.pSupportedFsms = &OmciDeviceFsms{
112 "mib-synchronizer": {
113 //mibSyncFsm, // Implements the MIB synchronization state machine
Himani Chawla6d2ae152020-09-02 13:11:20 +0530114 mibDbVolatileDictImpl, // Implements volatile ME MIB database
Himani Chawla4d908332020-08-31 12:30:20 +0530115 //true, // Advertise events on OpenOMCI event bus
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000116 openOnuAc.mibAuditInterval, // Time to wait between MIB audits. 0 to disable audits.
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000117 // map[string]func() error{
118 // "mib-upload": onuDeviceEntry.MibUploadTask,
119 // "mib-template": onuDeviceEntry.MibTemplateTask,
120 // "get-mds": onuDeviceEntry.GetMdsTask,
121 // "mib-audit": onuDeviceEntry.GetMdsTask,
122 // "mib-resync": onuDeviceEntry.MibResyncTask,
123 // "mib-reconcile": onuDeviceEntry.MibReconcileTask,
124 // },
125 },
126 }
127
mpagenkoc8bba412021-01-15 15:38:44 +0000128 openOnuAc.pDownloadManager = newAdapterDownloadManager(ctx)
129
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000130 return &openOnuAc
131}
132
133//Start starts (logs) the adapter
134func (oo *OpenONUAC) Start(ctx context.Context) error {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000135 logger.Info(ctx, "starting-openonu-adapter")
mpagenkoc8bba412021-01-15 15:38:44 +0000136
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000137 return nil
138}
139
Himani Chawla6d2ae152020-09-02 13:11:20 +0530140/*
141//stop terminates the session
142func (oo *OpenONUAC) stop(ctx context.Context) error {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000143 logger.Info(ctx,"stopping-device-manager")
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000144 oo.exitChannel <- 1
dbainbri4d3a0dc2020-12-02 00:33:42 +0000145 logger.Info(ctx,"device-manager-stopped")
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000146 return nil
147}
Himani Chawla6d2ae152020-09-02 13:11:20 +0530148*/
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000149
Himani Chawla6d2ae152020-09-02 13:11:20 +0530150func (oo *OpenONUAC) addDeviceHandlerToMap(ctx context.Context, agent *deviceHandler) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000151 oo.lockDeviceHandlersMap.Lock()
152 defer oo.lockDeviceHandlersMap.Unlock()
153 if _, exist := oo.deviceHandlers[agent.deviceID]; !exist {
154 oo.deviceHandlers[agent.deviceID] = agent
Himani Chawla6d2ae152020-09-02 13:11:20 +0530155 oo.deviceHandlers[agent.deviceID].start(ctx)
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000156 if _, exist := oo.deviceHandlersCreateChan[agent.deviceID]; exist {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000157 logger.Debugw(ctx, "deviceHandler created - trigger processing of pending ONU_IND_REQUEST", log.Fields{"device-id": agent.deviceID})
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000158 oo.deviceHandlersCreateChan[agent.deviceID] <- true
159 }
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000160 }
161}
162
Himani Chawla6d2ae152020-09-02 13:11:20 +0530163func (oo *OpenONUAC) deleteDeviceHandlerToMap(agent *deviceHandler) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000164 oo.lockDeviceHandlersMap.Lock()
165 defer oo.lockDeviceHandlersMap.Unlock()
166 delete(oo.deviceHandlers, agent.deviceID)
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000167 delete(oo.deviceHandlersCreateChan, agent.deviceID)
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000168}
169
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000170//getDeviceHandler gets the ONU deviceHandler and may wait until it is created
dbainbri4d3a0dc2020-12-02 00:33:42 +0000171func (oo *OpenONUAC) getDeviceHandler(ctx context.Context, deviceID string, aWait bool) *deviceHandler {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000172 oo.lockDeviceHandlersMap.Lock()
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000173 agent, ok := oo.deviceHandlers[deviceID]
174 if aWait && !ok {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000175 logger.Infow(ctx, "Race condition: deviceHandler not present - wait for creation or timeout",
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000176 log.Fields{"device-id": deviceID})
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000177 if _, exist := oo.deviceHandlersCreateChan[deviceID]; !exist {
178 oo.deviceHandlersCreateChan[deviceID] = make(chan bool, 1)
179 }
Girish Gowdra7407a4d2020-11-12 12:44:53 -0800180 deviceCreateChan := oo.deviceHandlersCreateChan[deviceID]
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000181 //keep the read sema short to allow for subsequent write
182 oo.lockDeviceHandlersMap.Unlock()
183 // based on concurrent processing the deviceHandler creation may not yet be finished at his point
184 // so it might be needed to wait here for that event with some timeout
185 select {
186 case <-time.After(1 * time.Second): //timer may be discussed ...
dbainbri4d3a0dc2020-12-02 00:33:42 +0000187 logger.Warnw(ctx, "No valid deviceHandler created after max WaitTime", log.Fields{"device-id": deviceID})
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000188 return nil
Girish Gowdra7407a4d2020-11-12 12:44:53 -0800189 case <-deviceCreateChan:
dbainbri4d3a0dc2020-12-02 00:33:42 +0000190 logger.Debugw(ctx, "deviceHandler is ready now - continue", log.Fields{"device-id": deviceID})
Girish Gowdra7407a4d2020-11-12 12:44:53 -0800191 oo.lockDeviceHandlersMap.RLock()
192 defer oo.lockDeviceHandlersMap.RUnlock()
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000193 return oo.deviceHandlers[deviceID]
194 }
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000195 }
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000196 oo.lockDeviceHandlersMap.Unlock()
197 return agent
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000198}
199
dbainbri4d3a0dc2020-12-02 00:33:42 +0000200func (oo *OpenONUAC) processInterAdapterONUIndReqMessage(ctx context.Context, msg *ic.InterAdapterMessage) error {
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000201 msgBody := msg.GetBody()
202 onuIndication := &oop.OnuIndication{}
203 if err := ptypes.UnmarshalAny(msgBody, onuIndication); err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000204 logger.Warnw(ctx, "onu-ind-request-cannot-unmarshal-msg-body", log.Fields{"error": err})
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000205 return err
206 }
207 //ToDeviceId should address a DeviceHandler instance
208 targetDevice := msg.Header.ToDeviceId
209
210 onuOperstate := onuIndication.GetOperState()
211 waitForDhInstPresent := false
212 if onuOperstate == "up" {
213 //Race condition (relevant in BBSIM-environment only): Due to unsynchronized processing of olt-adapter and rw_core,
214 //ONU_IND_REQUEST msg by olt-adapter could arrive a little bit earlier than rw_core was able to announce the corresponding
215 //ONU by RPC of Adopt_device(). Therefore it could be necessary to wait with processing of ONU_IND_REQUEST until call of
216 //Adopt_device() arrived and DeviceHandler instance was created
217 waitForDhInstPresent = true
218 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000219 if handler := oo.getDeviceHandler(ctx, targetDevice, waitForDhInstPresent); handler != nil {
220 logger.Infow(ctx, "onu-ind-request", log.Fields{"device-id": targetDevice,
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000221 "OnuId": onuIndication.GetOnuId(),
222 "AdminState": onuIndication.GetAdminState(), "OperState": onuOperstate,
223 "SNR": onuIndication.GetSerialNumber()})
224
225 if onuOperstate == "up" {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000226 return handler.createInterface(ctx, onuIndication)
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000227 } else if (onuOperstate == "down") || (onuOperstate == "unreachable") {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000228 return handler.updateInterface(ctx, onuIndication)
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000229 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000230 logger.Errorw(ctx, "unknown-onu-ind-request operState", log.Fields{"OnuId": onuIndication.GetOnuId()})
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000231 return fmt.Errorf("invalidOperState: %s, %s", onuOperstate, targetDevice)
232 }
233 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000234 logger.Warnw(ctx, "no handler found for received onu-ind-request", log.Fields{
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000235 "msgToDeviceId": targetDevice})
236 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", targetDevice))
237}
238
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000239// Adapter interface required methods ############## begin #########
240// #################################################################
241
242// for original content compare: (needs according deviceHandler methods)
243// /voltha-openolt-adapter/adaptercore/openolt.go
244
245// Adopt_device creates a new device handler if not present already and then adopts the device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000246func (oo *OpenONUAC) Adopt_device(ctx context.Context, device *voltha.Device) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000247 if device == nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000248 logger.Warn(ctx, "voltha-device-is-nil")
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000249 return errors.New("nil-device")
250 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000251 logger.Infow(ctx, "adopt-device", log.Fields{"device-id": device.Id})
Himani Chawla6d2ae152020-09-02 13:11:20 +0530252 var handler *deviceHandler
dbainbri4d3a0dc2020-12-02 00:33:42 +0000253 if handler = oo.getDeviceHandler(ctx, device.Id, false); handler == nil {
254 handler := newDeviceHandler(ctx, oo.coreProxy, oo.adapterProxy, oo.eventProxy, device, oo)
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000255 oo.addDeviceHandlerToMap(ctx, handler)
Himani Chawla6d2ae152020-09-02 13:11:20 +0530256 go handler.adoptOrReconcileDevice(ctx, device)
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000257 // Launch the creation of the device topic
258 // go oo.createDeviceTopic(device)
259 }
260 return nil
261}
262
263//Get_ofp_device_info returns OFP information for the given device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000264func (oo *OpenONUAC) Get_ofp_device_info(ctx context.Context, device *voltha.Device) (*ic.SwitchCapability, error) {
265 logger.Errorw(ctx, "device-handler-not-set", log.Fields{"device-id": device.Id})
Andrea Campanella6515c582020-10-05 11:25:00 +0200266 return nil, fmt.Errorf("device-handler-not-set %s", device.Id)
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000267}
268
269//Get_ofp_port_info returns OFP port information for the given device
mpagenkoaf801632020-07-03 10:00:42 +0000270//200630: method removed as per [VOL-3202]: OF port info is now to be delivered within UniPort create
271// cmp changes in onu_uni_port.go::CreateVolthaPort()
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000272
273//Process_inter_adapter_message sends messages to a target device (between adapters)
dbainbri4d3a0dc2020-12-02 00:33:42 +0000274func (oo *OpenONUAC) Process_inter_adapter_message(ctx context.Context, msg *ic.InterAdapterMessage) error {
275 logger.Debugw(ctx, "Process_inter_adapter_message", log.Fields{"msgId": msg.Header.Id,
Holger Hildebrandt80129db2020-11-23 10:49:32 +0000276 "msgProxyDeviceId": msg.Header.ProxyDeviceId, "msgToDeviceId": msg.Header.ToDeviceId, "Type": msg.Header.Type})
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000277
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000278 if msg.Header.Type == ic.InterAdapterMessageType_ONU_IND_REQUEST {
279 // we have to handle ONU_IND_REQUEST already here - see comments in processInterAdapterONUIndReqMessage()
dbainbri4d3a0dc2020-12-02 00:33:42 +0000280 return oo.processInterAdapterONUIndReqMessage(ctx, msg)
Holger Hildebrandt6c1fb0a2020-11-25 15:41:01 +0000281 }
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000282 //ToDeviceId should address a DeviceHandler instance
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000283 targetDevice := msg.Header.ToDeviceId
dbainbri4d3a0dc2020-12-02 00:33:42 +0000284 if handler := oo.getDeviceHandler(ctx, targetDevice, false); handler != nil {
mpagenko1cc3cb42020-07-27 15:24:38 +0000285 /* 200724: modification towards synchronous implementation - possible errors within processing shall be
286 * in the accordingly delayed response, some timing effect might result in Techprofile processing for multiple UNI's
287 */
dbainbri4d3a0dc2020-12-02 00:33:42 +0000288 return handler.processInterAdapterMessage(ctx, msg)
mpagenko1cc3cb42020-07-27 15:24:38 +0000289 /* so far the processing has been in background with according commented error treatment restrictions:
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000290 go handler.ProcessInterAdapterMessage(msg)
291 // error treatment might be more sophisticated
292 // by now let's just accept the message on 'communication layer'
293 // message content problems have to be evaluated then in the handler
294 // and are by now not reported to the calling party (to force what reaction there?)
295 return nil
mpagenko1cc3cb42020-07-27 15:24:38 +0000296 */
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000297 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000298 logger.Warnw(ctx, "no handler found for received Inter-Proxy-message", log.Fields{
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000299 "msgToDeviceId": targetDevice})
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000300 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", targetDevice))
301}
302
303//Adapter_descriptor not implemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000304func (oo *OpenONUAC) Adapter_descriptor(ctx context.Context) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000305 return errors.New("unImplemented")
306}
307
308//Device_types unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000309func (oo *OpenONUAC) Device_types(ctx context.Context) (*voltha.DeviceTypes, error) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000310 return nil, errors.New("unImplemented")
311}
312
313//Health returns unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000314func (oo *OpenONUAC) Health(ctx context.Context) (*voltha.HealthStatus, error) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000315 return nil, errors.New("unImplemented")
316}
317
Holger Hildebrandt9ca8b132020-08-07 14:45:03 +0000318//Reconcile_device is called once when the adapter needs to re-create device - usually on core restart
dbainbri4d3a0dc2020-12-02 00:33:42 +0000319func (oo *OpenONUAC) Reconcile_device(ctx context.Context, device *voltha.Device) error {
Holger Hildebrandtf41a1602020-08-19 09:52:50 +0000320 if device == nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000321 logger.Warn(ctx, "reconcile-device-voltha-device-is-nil")
Holger Hildebrandtf41a1602020-08-19 09:52:50 +0000322 return errors.New("nil-device")
323 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000324 logger.Infow(ctx, "reconcile-device", log.Fields{"device-id": device.Id})
Himani Chawla6d2ae152020-09-02 13:11:20 +0530325 var handler *deviceHandler
dbainbri4d3a0dc2020-12-02 00:33:42 +0000326 if handler = oo.getDeviceHandler(ctx, device.Id, false); handler == nil {
327 handler := newDeviceHandler(ctx, oo.coreProxy, oo.adapterProxy, oo.eventProxy, device, oo)
Holger Hildebrandtf41a1602020-08-19 09:52:50 +0000328 oo.addDeviceHandlerToMap(ctx, handler)
329 handler.device = device
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000330 handler.startReconciling(ctx, false)
Himani Chawla6d2ae152020-09-02 13:11:20 +0530331 go handler.adoptOrReconcileDevice(ctx, handler.device)
Holger Hildebrandtf41a1602020-08-19 09:52:50 +0000332 // reconcilement will be continued after onu-device entry is added
Holger Hildebrandt9ca8b132020-08-07 14:45:03 +0000333 } else {
Holger Hildebrandtf41a1602020-08-19 09:52:50 +0000334 return fmt.Errorf(fmt.Sprintf("device-already-reconciled-or-active-%s", device.Id))
Holger Hildebrandt9ca8b132020-08-07 14:45:03 +0000335 }
336 return nil
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000337}
338
339//Abandon_device unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000340func (oo *OpenONUAC) Abandon_device(ctx context.Context, device *voltha.Device) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000341 return errors.New("unImplemented")
342}
343
344//Disable_device disables the given device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000345func (oo *OpenONUAC) Disable_device(ctx context.Context, device *voltha.Device) error {
346 logger.Infow(ctx, "disable-device", log.Fields{"device-id": device.Id})
347 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
348 go handler.disableDevice(ctx, device)
ozgecanetsiafce57b12020-05-25 14:39:35 +0300349 return nil
350 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000351 logger.Warnw(ctx, "no handler found for device-disable", log.Fields{"device-id": device.Id})
ozgecanetsiafce57b12020-05-25 14:39:35 +0300352 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", device.Id))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000353}
354
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000355//Reenable_device enables the onu device after disable
dbainbri4d3a0dc2020-12-02 00:33:42 +0000356func (oo *OpenONUAC) Reenable_device(ctx context.Context, device *voltha.Device) error {
357 logger.Infow(ctx, "reenable-device", log.Fields{"device-id": device.Id})
358 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
359 go handler.reEnableDevice(ctx, device)
ozgecanetsiafce57b12020-05-25 14:39:35 +0300360 return nil
361 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000362 logger.Warnw(ctx, "no handler found for device-reenable", log.Fields{"device-id": device.Id})
ozgecanetsiafce57b12020-05-25 14:39:35 +0300363 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", device.Id))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000364}
365
366//Reboot_device reboots the given device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000367func (oo *OpenONUAC) Reboot_device(ctx context.Context, device *voltha.Device) error {
368 logger.Infow(ctx, "reboot-device", log.Fields{"device-id": device.Id})
369 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
mpagenko15ff4a52021-03-02 10:09:20 +0000370 go handler.rebootDevice(ctx, true, device) //reboot request with device checking
ozgecanetsiae11479f2020-07-06 09:44:47 +0300371 return nil
372 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000373 logger.Warnw(ctx, "no handler found for device-reboot", log.Fields{"device-id": device.Id})
ozgecanetsiae11479f2020-07-06 09:44:47 +0300374 return fmt.Errorf(fmt.Sprintf("handler-not-found-#{device.Id}"))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000375}
376
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000377//Self_test_device unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000378func (oo *OpenONUAC) Self_test_device(ctx context.Context, device *voltha.Device) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000379 return errors.New("unImplemented")
380}
381
Himani Chawla6d2ae152020-09-02 13:11:20 +0530382// Delete_device deletes the given device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000383func (oo *OpenONUAC) Delete_device(ctx context.Context, device *voltha.Device) error {
384 logger.Infow(ctx, "delete-device", log.Fields{"device-id": device.Id, "SerialNumber": device.SerialNumber})
385 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
Girish Gowdra0e533642021-03-02 22:02:51 -0800386 var errorsList []error
Holger Hildebrandtff05b682021-03-16 15:02:05 +0000387
388 handler.mutexDeletionInProgressFlag.Lock()
389 handler.deletionInProgress = true
390 handler.mutexDeletionInProgressFlag.Unlock()
391
Girish Gowdra0e533642021-03-02 22:02:51 -0800392 if err := handler.deleteDevicePersistencyData(ctx); err != nil {
393 errorsList = append(errorsList, err)
394 }
Girish Gowdra6afb56a2021-04-27 17:47:57 -0700395 select {
396 case handler.stopCollector <- true: // stop the metric collector routine
397 logger.Debugw(ctx, "sent stop signal to metric collector routine", log.Fields{"device-id": device.Id})
398 default:
399 logger.Warnw(ctx, "metric collector routine not waiting on stop signal", log.Fields{"device-id": device.Id})
400 }
401 select {
402 case handler.stopAlarmManager <- true: //stop the alarm manager.
403 logger.Debugw(ctx, "sent stop signal to alarm manager", log.Fields{"device-id": device.Id})
404 default:
405 logger.Warnw(ctx, "alarm manager not waiting on stop signal", log.Fields{"device-id": device.Id})
406 }
Girish Gowdra0e533642021-03-02 22:02:51 -0800407 if handler.pOnuMetricsMgr != nil {
408 if err := handler.pOnuMetricsMgr.clearAllPmData(ctx); err != nil {
409 errorsList = append(errorsList, err)
410 }
411 }
Girish Gowdra6afb56a2021-04-27 17:47:57 -0700412 select {
413 case handler.pSelfTestHdlr.stopSelfTestModule <- true:
414 logger.Debugw(ctx, "sent stop signal to self test handler module", log.Fields{"device-id": device.Id})
415 default:
416 logger.Warnw(ctx, "self test handler module not waiting on stop signal", log.Fields{"device-id": device.Id})
417 }
Holger Hildebrandtf07b44a2020-11-10 13:07:54 +0000418 //don't leave any garbage - even in error case
419 oo.deleteDeviceHandlerToMap(handler)
Girish Gowdra0e533642021-03-02 22:02:51 -0800420 if len(errorsList) > 0 {
421 logger.Errorw(ctx, "one-or-more-error-during-device-delete", log.Fields{"device-id": device.Id})
422 return fmt.Errorf("one-or-more-error-during-device-delete, errors:%v", errorsList)
423 }
424 return nil
Holger Hildebrandt9ca8b132020-08-07 14:45:03 +0000425 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000426 logger.Warnw(ctx, "no handler found for device-deletion", log.Fields{"device-id": device.Id})
mpagenko2418ab02020-11-12 12:58:06 +0000427 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", device.Id))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000428}
429
430//Get_device_details unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000431func (oo *OpenONUAC) Get_device_details(ctx context.Context, device *voltha.Device) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000432 return errors.New("unImplemented")
433}
434
435//Update_flows_bulk returns
dbainbri4d3a0dc2020-12-02 00:33:42 +0000436func (oo *OpenONUAC) Update_flows_bulk(ctx context.Context, device *voltha.Device, flows *voltha.Flows, groups *voltha.FlowGroups, flowMetadata *voltha.FlowMetadata) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000437 return errors.New("unImplemented")
438}
439
440//Update_flows_incrementally updates (add/remove) the flows on a given device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000441func (oo *OpenONUAC) Update_flows_incrementally(ctx context.Context, device *voltha.Device,
mpagenkodff5dda2020-08-28 11:52:01 +0000442 flows *openflow_13.FlowChanges, groups *openflow_13.FlowGroupChanges, flowMetadata *voltha.FlowMetadata) error {
mpagenkofc4f56e2020-11-04 17:17:49 +0000443
dbainbri4d3a0dc2020-12-02 00:33:42 +0000444 logger.Infow(ctx, "update-flows-incrementally", log.Fields{"device-id": device.Id})
mpagenkofc4f56e2020-11-04 17:17:49 +0000445 //flow config is relayed to handler even if the device might be in some 'inactive' state
446 // let the handler or related FSM's decide, what to do with the modified flow state info
447 // at least the flow-remove must be done in respect to internal data, while OMCI activity might not be needed here
mpagenkodff5dda2020-08-28 11:52:01 +0000448
449 // For now, there is no support for group changes (as in the actual Py-adapter code)
mpagenkofc4f56e2020-11-04 17:17:49 +0000450 // but processing is continued for flowUpdate possibly also set in the request
mpagenkodff5dda2020-08-28 11:52:01 +0000451 if groups.ToAdd != nil && groups.ToAdd.Items != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000452 logger.Warnw(ctx, "Update-flow-incr: group add not supported (ignored)", log.Fields{"device-id": device.Id})
mpagenkodff5dda2020-08-28 11:52:01 +0000453 }
454 if groups.ToRemove != nil && groups.ToRemove.Items != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000455 logger.Warnw(ctx, "Update-flow-incr: group remove not supported (ignored)", log.Fields{"device-id": device.Id})
mpagenkodff5dda2020-08-28 11:52:01 +0000456 }
457 if groups.ToUpdate != nil && groups.ToUpdate.Items != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000458 logger.Warnw(ctx, "Update-flow-incr: group update not supported (ignored)", log.Fields{"device-id": device.Id})
mpagenkodff5dda2020-08-28 11:52:01 +0000459 }
460
dbainbri4d3a0dc2020-12-02 00:33:42 +0000461 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
462 err := handler.FlowUpdateIncremental(ctx, flows, groups, flowMetadata)
mpagenkodff5dda2020-08-28 11:52:01 +0000463 return err
464 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000465 logger.Warnw(ctx, "no handler found for incremental flow update", log.Fields{"device-id": device.Id})
mpagenkodff5dda2020-08-28 11:52:01 +0000466 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", device.Id))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000467}
468
469//Update_pm_config returns PmConfigs nil or error
dbainbri4d3a0dc2020-12-02 00:33:42 +0000470func (oo *OpenONUAC) Update_pm_config(ctx context.Context, device *voltha.Device, pmConfigs *voltha.PmConfigs) error {
Girish Gowdrae09a6202021-01-12 18:10:59 -0800471 logger.Infow(ctx, "update-pm-config", log.Fields{"device-id": device.Id})
472 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
Girish Gowdra5a7c4922021-01-22 18:33:41 -0800473 return handler.updatePmConfig(ctx, pmConfigs)
Girish Gowdrae09a6202021-01-12 18:10:59 -0800474 }
Girish Gowdra5a7c4922021-01-22 18:33:41 -0800475 logger.Warnw(ctx, "no handler found for update-pm-config", log.Fields{"device-id": device.Id})
476 return fmt.Errorf(fmt.Sprintf("handler-not-found-%s", device.Id))
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000477}
478
479//Receive_packet_out sends packet out to the device
dbainbri4d3a0dc2020-12-02 00:33:42 +0000480func (oo *OpenONUAC) Receive_packet_out(ctx context.Context, deviceID string, egressPortNo int, packet *openflow_13.OfpPacketOut) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000481 return errors.New("unImplemented")
482}
483
484//Suppress_event unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000485func (oo *OpenONUAC) Suppress_event(ctx context.Context, filter *voltha.EventFilter) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000486 return errors.New("unImplemented")
487}
488
489//Unsuppress_event unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000490func (oo *OpenONUAC) Unsuppress_event(ctx context.Context, filter *voltha.EventFilter) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000491 return errors.New("unImplemented")
492}
493
Andrea Campanella71e546a2021-02-26 11:09:33 +0100494//Download_image requests downloading some image according to indications as given in request
495//The ImageDownload needs to be called `request`due to library reflection requirements
496func (oo *OpenONUAC) Download_image(ctx context.Context, device *voltha.Device, request *voltha.ImageDownload) (*voltha.ImageDownload, error) {
mpagenko15ff4a52021-03-02 10:09:20 +0000497 if request != nil && (*request).Name != "" {
498 if !oo.pDownloadManager.imageExists(ctx, request) {
499 logger.Debugw(ctx, "start image download", log.Fields{"image-description": request})
500 // Download_image is not supposed to be blocking, anyway let's call the DownloadManager still synchronously to detect 'fast' problems
501 // the download itself is later done in background
502 err := oo.pDownloadManager.startDownload(ctx, request)
503 return request, err
504 }
505 // image already exists
506 logger.Debugw(ctx, "image already downloaded", log.Fields{"image-description": request})
507 return request, nil
mpagenkoc8bba412021-01-15 15:38:44 +0000508 }
mpagenko15ff4a52021-03-02 10:09:20 +0000509 return request, errors.New("invalid image definition")
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000510}
511
512//Get_image_download_status unimplemented
Andrea Campanella71e546a2021-02-26 11:09:33 +0100513//The ImageDownload needs to be called `request`due to library reflection requirements
dbainbri4d3a0dc2020-12-02 00:33:42 +0000514func (oo *OpenONUAC) Get_image_download_status(ctx context.Context, device *voltha.Device, request *voltha.ImageDownload) (*voltha.ImageDownload, error) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000515 return nil, errors.New("unImplemented")
516}
517
518//Cancel_image_download unimplemented
Andrea Campanella71e546a2021-02-26 11:09:33 +0100519//The ImageDownload needs to be called `request`due to library reflection requirements
dbainbri4d3a0dc2020-12-02 00:33:42 +0000520func (oo *OpenONUAC) Cancel_image_download(ctx context.Context, device *voltha.Device, request *voltha.ImageDownload) (*voltha.ImageDownload, error) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000521 return nil, errors.New("unImplemented")
522}
523
mpagenko057889c2021-01-21 16:51:58 +0000524//Activate_image_update requests downloading some Onu Software image to the INU via OMCI
Andrea Campanella71e546a2021-02-26 11:09:33 +0100525// according to indications as given in request and on success activate the image on the ONU
526//The ImageDownload needs to be called `request`due to library reflection requirements
527func (oo *OpenONUAC) Activate_image_update(ctx context.Context, device *voltha.Device, request *voltha.ImageDownload) (*voltha.ImageDownload, error) {
mpagenko15ff4a52021-03-02 10:09:20 +0000528 if request != nil && (*request).Name != "" {
529 if oo.pDownloadManager.imageLocallyDownloaded(ctx, request) {
530 if handler := oo.getDeviceHandler(ctx, device.Id, false); handler != nil {
531 logger.Debugw(ctx, "image download on omci requested", log.Fields{
532 "image-description": request, "device-id": device.Id})
533 err := handler.doOnuSwUpgrade(ctx, request, oo.pDownloadManager)
534 return request, err
535 }
536 logger.Warnw(ctx, "no handler found for image activation", log.Fields{"device-id": device.Id})
537 return request, fmt.Errorf(fmt.Sprintf("handler-not-found - device-id: %s", device.Id))
mpagenko057889c2021-01-21 16:51:58 +0000538 }
mpagenko15ff4a52021-03-02 10:09:20 +0000539 logger.Debugw(ctx, "image not yet downloaded on activate request", log.Fields{"image-description": request})
540 return request, fmt.Errorf(fmt.Sprintf("image-not-yet-downloaded - device-id: %s", device.Id))
mpagenkoc8bba412021-01-15 15:38:44 +0000541 }
mpagenko15ff4a52021-03-02 10:09:20 +0000542 return request, errors.New("invalid image definition")
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000543}
544
545//Revert_image_update unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000546func (oo *OpenONUAC) Revert_image_update(ctx context.Context, device *voltha.Device, request *voltha.ImageDownload) (*voltha.ImageDownload, error) {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000547 return nil, errors.New("unImplemented")
548}
549
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000550// Enable_port to Enable PON/NNI interface - seems not to be used/required according to python code
dbainbri4d3a0dc2020-12-02 00:33:42 +0000551func (oo *OpenONUAC) Enable_port(ctx context.Context, deviceID string, port *voltha.Port) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000552 return errors.New("unImplemented")
553}
554
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000555// Disable_port to Disable pon/nni interface - seems not to be used/required according to python code
dbainbri4d3a0dc2020-12-02 00:33:42 +0000556func (oo *OpenONUAC) Disable_port(ctx context.Context, deviceID string, port *voltha.Port) error {
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000557 return errors.New("unImplemented")
558}
559
Himani Chawla6d2ae152020-09-02 13:11:20 +0530560//Child_device_lost - unimplemented
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000561//needed for if update >= 3.1.x
Matteo Scandolo3f2bdc82021-03-18 18:18:22 -0700562func (oo *OpenONUAC) Child_device_lost(ctx context.Context, device *voltha.Device) error {
Matteo Scandolo2e6f1e32020-04-15 11:28:45 -0700563 return errors.New("unImplemented")
564}
565
Himani Chawla6d2ae152020-09-02 13:11:20 +0530566// Start_omci_test unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000567func (oo *OpenONUAC) Start_omci_test(ctx context.Context, device *voltha.Device, request *voltha.OmciTestRequest) (*voltha.TestResponse, error) {
Matteo Scandolo2e6f1e32020-04-15 11:28:45 -0700568 return nil, errors.New("unImplemented")
569}
570
Himani Chawla6d2ae152020-09-02 13:11:20 +0530571// Get_ext_value - unimplemented
dbainbri4d3a0dc2020-12-02 00:33:42 +0000572func (oo *OpenONUAC) Get_ext_value(ctx context.Context, deviceID string, device *voltha.Device, valueparam voltha.ValueType_Type) (*voltha.ReturnValues, error) {
Matteo Scandolod132c0e2020-04-24 17:06:25 -0700573 return nil, errors.New("unImplemented")
574}
575
kesavandfdf77632021-01-26 23:40:33 -0500576//Single_get_value_request handles the core request to retrieve uni status
mpagenkoc8bba412021-01-15 15:38:44 +0000577func (oo *OpenONUAC) Single_get_value_request(ctx context.Context, request extension.SingleGetValueRequest) (*extension.SingleGetValueResponse, error) {
kesavandfdf77632021-01-26 23:40:33 -0500578 logger.Infow(ctx, "Single_get_value_request", log.Fields{"request": request})
579
580 if handler := oo.getDeviceHandler(ctx, request.TargetId, false); handler != nil {
581 switch reqType := request.GetRequest().GetRequest().(type) {
582 case *extension.GetValueRequest_UniInfo:
583 return handler.getUniPortStatus(ctx, reqType.UniInfo), nil
Girish Gowdra6afb56a2021-04-27 17:47:57 -0700584 case *extension.GetValueRequest_OnuOpticalInfo:
585 commChan := make(chan Message)
586 respChan := make(chan extension.SingleGetValueResponse)
587 // Initiate the self test request
588 if err := handler.pSelfTestHdlr.SelfTestRequestStart(ctx, request, commChan, respChan); err != nil {
589 return &extension.SingleGetValueResponse{
590 Response: &extension.GetValueResponse{
591 Status: extension.GetValueResponse_ERROR,
592 ErrReason: extension.GetValueResponse_INTERNAL_ERROR,
593 },
594 }, err
595 }
596 // The timeout handling is already implemented in omci_self_test_handler module
597 resp := <-respChan
598 return &resp, nil
kesavandfdf77632021-01-26 23:40:33 -0500599 default:
600 return postUniStatusErrResponse(extension.GetValueResponse_UNSUPPORTED), nil
601
602 }
603 }
604 logger.Errorw(ctx, "Single_get_value_request failed ", log.Fields{"request": request})
605 return postUniStatusErrResponse(extension.GetValueResponse_INVALID_DEVICE_ID), nil
mpagenkoc8bba412021-01-15 15:38:44 +0000606}
607
mpagenko83144272021-04-27 10:06:22 +0000608//if update >= 4.3.0
609
610// Download_onu_image downloads (and optionally activates and commits) the indicated ONU image to the requested ONU(s)
611// if the image is not yet present on the adapter it has to be automatically downloaded
612func (oo *OpenONUAC) Download_onu_image(ctx context.Context, request *voltha.DeviceImageDownloadRequest) (*voltha.DeviceImageResponse, error) {
613 return nil, errors.New("unImplemented")
614}
615
616// Get_onu_image_status delivers the adapter-related information about the download/activation/commitment
617// status for the requested image
618func (oo *OpenONUAC) Get_onu_image_status(ctx context.Context, in *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
619 return nil, errors.New("unImplemented")
620}
621
622// Abort_onu_image_upgrade stops the actual download/activation/commitment process (on next possibly step)
623func (oo *OpenONUAC) Abort_onu_image_upgrade(ctx context.Context, in *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
624 return nil, errors.New("unImplemented")
625}
626
627// Get_onu_images retrieves the ONU SW image status information via OMCI
628func (oo *OpenONUAC) Get_onu_images(ctx context.Context, deviceID string) (*voltha.OnuImages, error) {
629 return nil, errors.New("unImplemented")
630}
631
632// Activate_onu_image initiates the activation of the image for the requested ONU(s)
633// precondition: image downloaded and not yet activated
634func (oo *OpenONUAC) Activate_onu_image(ctx context.Context, in *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
635 return nil, errors.New("unImplemented")
636}
637
638// Commit_onu_image enforces the commitment of the image for the requested ONU(s)
639// precondition: image activated and not yet committed
640func (oo *OpenONUAC) Commit_onu_image(ctx context.Context, in *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
641 return nil, errors.New("unImplemented")
642}
643
Holger Hildebrandtfa074992020-03-27 15:42:06 +0000644// Adapter interface required methods ################ end #########
645// #################################################################