blob: e761a3dc8a95bfc90abb5c0915ab08fbbf786d8a [file] [log] [blame]
/*
* Copyright 2020-2024 Open Networking Foundation (ONF) and the ONF Contributors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
// Package common provides global definitions
package common
import (
"context"
"sync"
"time"
me "github.com/opencord/omci-lib-go/v2/generated"
"github.com/opencord/voltha-lib-go/v7/pkg/db"
"github.com/opencord/voltha-lib-go/v7/pkg/events/eventif"
"github.com/opencord/voltha-openonu-adapter-go/internal/pkg/devdb"
"github.com/opencord/voltha-protos/v5/go/extension"
ia "github.com/opencord/voltha-protos/v5/go/inter_adapter"
"github.com/opencord/voltha-protos/v5/go/openolt"
"github.com/opencord/voltha-protos/v5/go/voltha"
)
// IopenONUAC interface to openONUAC
type IopenONUAC interface {
GetSupportedFsms() *OmciDeviceFsms
LockMutexMibTemplateGenerated()
UnlockMutexMibTemplateGenerated()
GetMibTemplatesGenerated(string) (bool, bool)
SetMibTemplatesGenerated(string, bool)
RLockMutexDeviceHandlersMap()
RUnlockMutexDeviceHandlersMap()
GetDeviceHandler(string) (IdeviceHandler, bool)
GetONUMIBDBMap() devdb.OnuMCmnMEDBMap
RLockMutexMIBDatabaseMap()
RUnlockMutexMIBDatabaseMap()
LockMutexMIBDatabaseMap()
UnlockMutexMIBDatabaseMap()
FetchEntryFromMibDatabaseMap(context.Context, string) (*devdb.OnuCmnMEDB, bool)
CreateEntryAtMibDatabaseMap(context.Context, string) (*devdb.OnuCmnMEDB, error)
ResetEntryFromMibDatabaseMap(context.Context, string)
}
// IdeviceHandler interface to deviceHandler
type IdeviceHandler interface {
GetDeviceID() string
GetLogicalDeviceID() string
GetDevice() *voltha.Device
GetDeviceType() string
GetProxyAddressID() string
GetProxyAddressType() string
GetProxyAddress() *voltha.Device_ProxyAddress
GetEventProxy() eventif.EventProxy
GetOmciTimeout() int
GetAlarmAuditInterval() time.Duration
GetDlToOnuTimeout4M() time.Duration
GetUniEntityMap() *OnuUniPortMap
GetUniPortMask() int
GetPonPortNumber() *uint32
GetOnuIndication() *openolt.OnuIndication
GetUniVlanConfigFsm(uint8) IuniVlanConfigFsm
GetTechProfileInstanceFromParentAdapter(context.Context, uint8, string) (*ia.TechProfileDownloadMessage, error)
GetExtendedOmciSupportEnabled() bool
GetDeviceReasonString() string
ReasonUpdate(context.Context, uint8, bool) error
GetCollectorIsRunning() bool
StartCollector(context.Context, *sync.WaitGroup)
InitPmConfigs()
GetPmConfigs() *voltha.PmConfigs
GetMetricsEnabled() bool
GetOnuMetricsManager() IonuMetricsManager
GetOnuAlarmManager() IonuAlarmManager
GetOnuTP() IonuUniTechProf
GetAlarmManagerIsRunning(context.Context) bool
StartAlarmManager(context.Context)
GetFlowMonitoringIsRunning(uniID uint8) bool
CheckAuditStartCondition(context.Context, UsedOmciConfigFsms) bool
RemoveOnuUpgradeFsm(context.Context, *voltha.ImageState)
DeviceProcStatusUpdate(context.Context, OnuDeviceEvent)
SetReadyForOmciConfig(bool)
IsReadyForOmciConfig() bool
IsOltAvailable() bool
StorePersistentData(context.Context) error
StorePersUniFlowConfig(context.Context, uint8, *[]UniVlanFlowParams, bool) error
StartReconciling(context.Context, bool)
IsReconciling() bool
IsSkipOnuConfigReconciling() bool
SetReconcilingReasonUpdate(bool)
IsReconcilingReasonUpdate() bool
PrepareReconcilingWithActiveAdapter(context.Context)
ReconcileDeviceTechProf(context.Context) bool
ReconcileDeviceFlowConfig(context.Context)
GetReconcileExpiryVlanConfigAbort() time.Duration
SendChUniVlanConfigFinished(value uint16)
VerifyUniVlanConfigRequest(context.Context, *OnuUniPort, uint8)
VerifyVlanConfigRequest(context.Context, uint8, uint8)
HandleAniConfigFSMFailure(ctx context.Context, uniID uint8)
AddAllUniPorts(context.Context)
RemoveVlanFilterFsm(context.Context, *OnuUniPort)
EnableUniPortStateUpdate(context.Context)
DisableUniPortStateUpdate(context.Context)
SetBackend(context.Context, string) *db.Backend
GetBackendPathPrefix() string
RLockMutexDeletionInProgressFlag()
RUnlockMutexDeletionInProgressFlag()
GetDeletionInProgress() bool
SendOMCIRequest(context.Context, string, *ia.OmciMessage) error
SendOnuSwSectionsOfWindow(context.Context, string, *ia.OmciMessages) error
CreatePortInCore(context.Context, *voltha.Port) error
PerOnuFlowHandlerRoutine(uniID uint8)
GetDeviceDeleteCommChan(context.Context) chan bool
GetSkipOnuConfigEnabled() bool
}
// IonuDeviceEntry interface to onuDeviceEntry
type IonuDeviceEntry interface {
GetDevOmciCC() *OmciCC
GetOnuDB() *devdb.OnuDeviceDB
GetPersSerialNumber() string
GetPersVendorID() string
GetPersVersion() string
GetPersEquipmentID() string
GetPersIsExtOmciSupported() bool
GetMibUploadFsmCommChan() chan Message
GetMibDownloadFsmCommChan() chan Message
GetOmciRebootMsgRevChan() chan Message
WaitForRebootResponse(context.Context, chan Message) error
IncrementMibDataSync(context.Context)
GetActiveImageMeID(context.Context) (uint16, error)
HandleSwImageIndications(context.Context, uint16, me.AttributeValueMap) bool
GetPersActiveSwVersion() string
SetPersActiveSwVersion(string)
GetActiveImageVersion(context.Context) string
ModifySwImageInactiveVersion(context.Context, string)
ModifySwImageActiveCommit(context.Context, uint8)
AllocateFreeTcont(context.Context, uint16) (uint16, bool, error)
FreeTcont(context.Context, uint16)
SendOnuDeviceEvent(context.Context, string, string)
}
// IonuMetricsManager interface to onuMetricsManager
type IonuMetricsManager interface {
AddGemPortForPerfMonitoring(context.Context, uint16)
RemoveGemPortForPerfMonitoring(context.Context, uint16)
}
// IonuAlarmManager interface to onuAlarmManager
type IonuAlarmManager interface {
HandleOmciAlarmNotificationMessage(context.Context, OmciMessage)
ResetAlarmUploadCounters()
GetAlarmMgrEventChannel() chan Message
GetAlarmUploadSeqNo() uint16
IncrementAlarmUploadSeqNo()
GetOnuActiveAlarms(ctx context.Context) *extension.SingleGetValueResponse
}
// IonuUniTechProf interface to onuUniTechProf
type IonuUniTechProf interface {
GetAllBidirectionalGemPortIDsForOnu() []uint16
GetNumberOfConfiguredUsGemPorts(ctx context.Context) int
SetProfileToDelete(uint8, uint8, bool)
}
// IuniVlanConfigFsm interface to uniVlanConfigFsm
type IuniVlanConfigFsm interface {
IsFlowRemovePending(context.Context, chan<- bool) bool
}
// [EOF]