devices

Nov 10, 2023

Changes in this version

type OltDevice

+ func (o *OltDevice) GetPonInterfaceInfo(context context.Context, packet *openolt.Interface) (*openolt.PonIntfInfo, error)

type PonPort

+ func (p *PonPort) GetAllOnus() []*Onu

type Service

+ func (s *Service) AddGroupAddress(addr string, ctag int)

+ func (s *Service) RemoveGroupAddress(addr string)

Apr 14, 2022

Changes in this version

type PotsPort

+ func (p *PotsPort) GetID() uint32

type PotsPortIf

+ GetID func() uint32

type UniPort

+ func (u *UniPort) GetID() uint32

type UniPortIf

+ GetID func() uint32

Mar 11, 2022

Changes in this version

type OltDevice

+ NniDhcpTrapVid int

Feb 24, 2022

Changes in this version

+ const OltInternalStateCreated

+ const OltInternalStateDeleted

+ const OltInternalStateDisabled

+ const OltInternalStateEnabled

+ const OltInternalStateInitialized

+ const OltInternalTxDelete

+ const OltInternalTxDisable

+ const OltInternalTxEnable

+ const OltInternalTxInitialize

type AllocIDKey

+ EntityID uint16

+ OnuID uint32

+ PonID uint32

+ type AllocIDVal struct

+ AllocID uint16

+ OnuSn *openolt.SerialNumber

type OltDevice

+ NniSpeed uint32

type PonPort

+ Technology common.PonTechnology

type Service

+ EnableMacLearning bool

+ NeedsPPPoE bool

Feb 3, 2022

Changes in this version

+ type AllocIDKey struct

+ AllocID uint16

+ OnuSn *openolt.SerialNumber

Jan 24, 2022

Changes in this version

+ const PotsStateDown

+ const PotsStateUp

type OltDevice

+ NumPots int

type Onu

+ PotsPorts []PotsPortIf

+ func (o *Onu) FindPotsByEntityId(meId uint16) (*PotsPort, error)

+ func (o *Onu) FindPotsById(uniID uint32) (*PotsPort, error)

+ func (o *Onu) InvalidateMibDataSync()

+ type PotsPort struct

+ ID uint32

+ MeId omcilib.EntityID

+ Onu *Onu

+ OperState *fsm.FSM

+ PortNo uint32

+ func NewPotsPort(ID uint32, onu *Onu) (*PotsPort, error)

+ func (u *PotsPort) Disable() error

+ func (u *PotsPort) Enable() error

+ func (u *PotsPort) StorePortNo(portNo uint32)

+ type PotsPortIf interface

+ Disable func() error

+ Enable func() error

Dec 14, 2021

Changes in this version

type Onu

+ InDownloadImageVersion string

Nov 11, 2021

Changes in this version

type Onu

+ ImageSectionData []byte

Jun 30, 2021

Changes in this version

+ const ServiceStateCreated

+ const ServiceStateDisabled

+ const ServiceStateInitialized

+ const ServiceTxDisable

+ const ServiceTxInitialize

+ const UniStateDown

+ const UniStateUp

type OltDevice

+ NumUni int

+ func (o *OltDevice) GetPonRxPower(ctx context.Context, in *openolt.Onu) (*openolt.PonRxPowerData, error)

type Onu

+ ActiveImageVersion string

+ AdminLockState uint8

+ CommittedImageVersion string

+ MibDb *omcilib.MibDb

+ StandbyImageVersion string

+ UniPorts []UniPortIf

+ func (o *Onu) FindUniByEntityId(meId uint16) (*UniPort, error)

+ func (o *Onu) FindUniById(uniID uint32) (*UniPort, error)

type Service

+ Id uint32

+ UniPort *UniPort

+ type UniPort struct

+ ID uint32

+ MeId omcilib.EntityID

+ Onu *Onu

+ OperState *fsm.FSM

+ PacketCh chan bbsimTypes.OnuPacketMessage

+ PortNo uint32

+ Services []ServiceIf

+ func NewUniPort(ID uint32, onu *Onu, nextCtag map[string]int, nextStag map[string]int) (*UniPort, error)

+ func (u *UniPort) Disable() error

+ func (u *UniPort) Enable() error

+ func (u *UniPort) HandleAuth()

+ func (u *UniPort) HandleDhcp(pbit uint8, cTag int)

+ func (u *UniPort) HandlePackets()

+ func (u *UniPort) StorePortNo(portNo uint32)

+ func (u *UniPort) UpdateStream(stream bbsimTypes.Stream)

+ type UniPortIf interface

+ Disable func() error

+ Enable func() error

+ HandleAuth func()

+ HandleDhcp func(pbit uint8, cTag int)

+ HandlePackets func()

+ StorePortNo func(portNo uint32)

+ UpdateStream func(stream bbsimTypes.Stream)

Apr 28, 2021

Changes in this version

type OltDevice

+ OmciResponseRate uint8

type Onu

+ OmciMsgCounter uint8

+ OmciResponseRate uint8

type Service

+ func (s *Service) UpdateStream(stream bbsimTypes.Stream)

type ServiceIf

+ UpdateStream func(stream bbsimTypes.Stream)

Mar 23, 2021

Changes in this version

+ const BbrOnuStateDhcpFlowSent

+ const BbrOnuStateEapolFlowSent

+ const BbrOnuTxSendDhcpFlow

+ const BbrOnuTxSendEapolFlow

+ const OnuStateCreated

+ const OnuStateDisabled

+ const OnuStateDiscovered

+ const OnuStateEnabled

+ const OnuStateImageActivated

+ const OnuStateImageCommitted

+ const OnuStateImageDownloadComplete

+ const OnuStateImageDownloadError

+ const OnuStateImageDownloadInProgress

+ const OnuStateImageDownloadStarted

+ const OnuStateInitialized

+ const OnuStatePonDisabled

+ const OnuTxActivateImage

+ const OnuTxCommitImage

+ const OnuTxCompleteImageDownload

+ const OnuTxDisable

+ const OnuTxDiscover

+ const OnuTxEnable

+ const OnuTxFailImageDownload

+ const OnuTxInitialize

+ const OnuTxPonDisable

+ const OnuTxProgressImageDownload

+ const OnuTxStartImageDownload

+ func NewSN(oltid int, intfid uint32, onuid uint32) *openolt.SerialNumber

type OltDevice

+ AllocIDs map[uint32]map[uint32]map[uint32]map[int32]map[uint64]bool

+ AllocIDsLock sync.RWMutex

+ GemPortIDs map[uint32]map[uint32]map[uint32]map[int32]map[uint64]bool

+ GemPortIDsLock sync.RWMutex

+ OltServer *grpc.Server

type Onu

+ ActiveImageEntityId uint16

+ CommittedImageEntityId uint16

+ ImageSoftwareExpectedSections int

+ ImageSoftwareReceivedSections int

+ func (o *Onu) IncrementAlarmSequenceNumber(key omcilib.OnuAlarmInfoMapKey) uint8

+ func (o *Onu) Reboot(timeout time.Duration) error

+ func (o *Onu) SendOMCIAlarmNotificationMsg(raiseOMCIAlarm bool, alarmType string)

type PonPort

+ AllocatedAllocIds map[uint16]*openolt.SerialNumber

+ AllocatedGemPorts map[uint16]*openolt.SerialNumber

+ AllocatedOnuIds map[uint32]*openolt.SerialNumber

Mar 16, 2021

Changes in this version

type OltDevice

+ PreviouslyConnected bool

+ func (o *OltDevice) GetGemPortStatistics(ctx context.Context, in *openolt.OnuPacket) (*openolt.GemPortStatistics, error)

+ func (o *OltDevice) GetOnuStatistics(ctx context.Context, in *openolt.Onu) (*openolt.OnuStatistics, error)

type Onu

+ MibDataSync uint8

Feb 4, 2021

Changes in this version

type OltDevice

+ func (o *OltDevice) HasNni(id uint32) bool

+ func (o *OltDevice) HasPon(id uint32) bool

+ func (o *OltDevice) SetAlarm(interfaceId uint32, interfaceType string, alarmStatus string) error

type Onu

+ func (o *Onu) HandlePowerOnONU() error

+ func (o *Onu) HandleShutdownONU() error

+ func (o *Onu) SetAlarm(alarmType string, status string) error

Dec 9, 2020

Changes in this version

type OltDevice

+ func (o *OltDevice) StartOltServer() (*grpc.Server, error)

Oct 30, 2020

Changes in this version

type NniPort

+ Olt *OltDevice

Sep 11, 2020

Changes in this version

type OltDevice

+ func (o *OltDevice) DeleteGroup(ctx context.Context, group *openolt.Group) (*openolt.Empty, error)

+ func (o *OltDevice) FindServiceByMacAddress(mac net.HardwareAddr) (ServiceIf, error)

+ func (o *OltDevice) GetExtValue(ctx context.Context, in *openolt.ValueParam) (*common_protos.ReturnValues, error)

+ func (o *OltDevice) GetLogicalOnuDistance(ctx context.Context, in *openolt.Onu) (*openolt.OnuLogicalDistance, error)

+ func (o *OltDevice) GetLogicalOnuDistanceZero(ctx context.Context, in *openolt.Onu) (*openolt.OnuLogicalDistance, error)

+ func (o *OltDevice) OnuItuPonAlarmSet(ctx context.Context, in *config.OnuItuPonAlarm) (*openolt.Empty, error)

+ func (o *OltDevice) PerformGroupOperation(ctx context.Context, group *openolt.Group) (*openolt.Empty, error)

type Onu

+ Services []ServiceIf

type OnuPacketMessage

+ GemPortId uint32

+ MacAddress net.HardwareAddr

+ type Service struct

+ CTag int

+ Channel chan Message

+ ConfigureMacAddress bool

+ DHCPState *fsm.FSM

+ DsPonCTagPriority uint8

+ DsPonSTagPriority uint8

+ EapolState *fsm.FSM

+ GemPort uint32

+ HwAddress net.HardwareAddr

+ IGMPState *fsm.FSM

+ InternalState *fsm.FSM

+ Name string

+ NeedsDhcp bool

+ NeedsEapol bool

+ NeedsIgmp bool

+ Onu *Onu

+ PacketCh chan OnuPacketMessage

+ STag int

+ Stream bbsimTypes.Stream

+ TechnologyProfileID int

+ UniTagMatch int

+ UsPonCTagPriority uint8

+ UsPonSTagPriority uint8

+ func NewService(name string, hwAddress net.HardwareAddr, onu *Onu, cTag int, sTag int, ...) (*Service, error)

+ func (s *Service) Disable()

+ func (s *Service) HandleAuth()

+ func (s *Service) HandleChannel()

+ func (s *Service) HandleDhcp(cTag int)

+ func (s *Service) HandlePackets()

+ func (s *Service) Initialize(stream bbsimTypes.Stream)

+ type ServiceIf interface

+ Disable func()

+ HandleAuth func()

+ HandleDhcp func(cTag int)

+ HandlePackets func()

+ Initialize func(stream bbsimTypes.Stream)

Aug 24, 2020

Changes in this version

type Onu

+ func (onu *Onu) ReDiscoverOnu()

Jun 25, 2020

Changes in this version

type MessageType

+ const FlowAdd

+ const FlowRemoved

type OltDevice

+ func (o *OltDevice) GetOnuByFlowId(flowId uint32) (*Onu, error)

type Onu

+ FlowIds []uint32

Jun 24, 2020

Changes in this version

type Onu

+ Backoff *backoff.Backoff

+ EapolFlowReceived bool

+ GemPortAdded bool

+ GemPortChannels []chan bool

+ func (o *Onu) GetGemPortChan() chan bool

Mar 20, 2020

Changes in this version

+ func InterfaceIDToPortNo(intfID uint32, intfType string) uint32

type NniPort

+ PacketCount uint64

type OltDevice

+ PortStatsInterval int

type PonPort

+ PacketCount uint64

+ func (p PonPort) GetNumOfActiveOnus() uint32

Mar 9, 2020

Changes in this version

+ type FlowKey struct

+ Direction string

+ ID uint32

type MessageType

+ const IGMPMembershipReportV3

type OltDevice

+ EventChannel chan common.Event

+ Flows map[FlowKey]openolt.Flow

+ PublishEvents bool

type Onu

+ Flows []FlowKey

+ TrafficSchedulers *tech_profile.TrafficSchedulers

+ func (onu *Onu) DeleteFlow(key FlowKey)

Feb 7, 2020

Changes in this version

+ const Both

+ const Default

+ const OnlyONU

+ const OnlyPON

+ var ControlledActivationModes = map[string]mode

type OltDevice

+ ControlledActivation mode

type Onu

+ DiscoveryDelay time.Duration

type PonPort

+ InternalState *fsm.FSM

Feb 4, 2020

Changes in this version

type MessageType

+ const IGMPLeaveGroup

+ const IGMPMembershipReportV2

Jan 29, 2020

Changes in this version

type OltDevice

+ OpenoltStream *openolt.Openolt_EnableIndicationServer

Jan 23, 2020

Changes in this version

type MessageType

+ const AlarmIndication

type OltDevice

+ func (o OltDevice) SendAlarmIndication(context context.Context, ind *openolt.AlarmIndication) error

Jan 17, 2020

Changes in this version

type PonPort

+ func CreatePonPort(olt OltDevice, id uint32) *PonPort

Dec 17, 2019

Changes in this version

type Onu

+ DiscoveryRetryDelay time.Duration

Dec 10, 2019

Changes in this version

type OltDevice

+ func (o *OltDevice) StopOltServer() error

Nov 26, 2019

Changes in this version

+ const OltRebootDelay

+ func StopOltServer() error

type NniPort

+ func (n *NniPort) NewVethChan() (chan *types.PacketMsg, error)

type OltDevice

+ Delay int

+ func (o *OltDevice) InitOlt() error

+ func (o *OltDevice) RestartOLT() error

type Onu

+ func (o *Onu) SetID(id uint32)

Nov 4, 2019

Changes in this version

+ type FlowAddSpy struct

+ CallCount int

+ Calls map[int]*openolt.Flow

type Onu

+ Auth bool

+ Dhcp bool

+ DhcpFlowReceived bool

Oct 23, 2019

Changes in this version

+ func StartOlt(olt *OltDevice, group *sync.WaitGroup)

+ type DefaultExecutor struct

+ func (d DefaultExecutor) Command(name string, arg ...string) Runnable

+ type Executor interface

+ Command func(name string, arg ...string) Runnable

type MessageType

+ const OmciIndication

+ const OnuPacketIn

+ const OnuPacketOut

+ const SendDhcpFlow

+ const SendEapolFlow

type OltDevice

+ func (o OltDevice) FindOnuById(intfId uint32, onuId uint32) (*Onu, error)

+ func (o OltDevice) FindOnuByMacAddress(mac net.HardwareAddr) (*Onu, error)

+ func (o OltDevice) FindOnuBySn(serialNumber string) (*Onu, error)

+ func (o OltDevice) GetPonById(id uint32) (*PonPort, error)

+ type OmciIndicationMessage struct

+ OmciInd *openolt.OmciIndication

+ OnuID uint32

+ OnuSN *openolt.SerialNumber

type Onu

+ DoneChannel chan bool

+ HasGemPort bool

+ PortNo uint32

+ func (o *Onu) StartOmci(client openolt.OpenoltClient)

+ func (o Onu) ProcessOnuMessages(stream openolt.Openolt_EnableIndicationServer, client openolt.OpenoltClient)

+ type OnuPacketMessage struct

+ IntfId uint32

+ OnuId uint32

+ Packet gopacket.Packet

+ Type packetHandlers.PacketType

type PonPort

+ func (p PonPort) GetOnuById(id uint32) (*Onu, error)

+ func (p PonPort) GetOnuBySn(sn *openolt.SerialNumber) (*Onu, error)

+ type Runnable interface

+ Run func() error

Oct 7, 2019

Changes in this version

+ func HexDecode(pkt []byte) []byte

+ type DyingGaspIndicationMessage struct

+ OnuID uint32

+ PonPortID uint32

+ Status string

+ type Message struct

+ Data interface{}

+ Type MessageType

+ type MessageType int

+ const DyingGaspIndication

+ const FlowUpdate

+ const NniIndication

+ const OMCI

+ const OltIndication

+ const OnuDiscIndication

+ const OnuIndication

+ const PonIndication

+ const StartDHCP

+ const StartEAPOL

+ func (m MessageType) String() string

+ type NniIndicationMessage struct

+ NniPortID uint32

+ OperState OperState

+ type NniPort struct

+ ID uint32

+ OperState *fsm.FSM

+ Type string

+ func CreateNNI(olt *OltDevice) (NniPort, error)

+ type OltDevice struct

+ ID int

+ InternalState *fsm.FSM

+ Nnis []NniPort

+ NumNni int

+ NumOnuPerPon int

+ NumPon int

+ OperState *fsm.FSM

+ Pons []PonPort

+ SerialNumber string

+ func CreateOLT(seq int, nni int, pon int, onuPerPon int, sTag int, cTagInit int, ...) OltDevice

+ func GetOLT() OltDevice

+ func (o OltDevice) ActivateOnu(context context.Context, onu *openolt.Onu) (*openolt.Empty, error)

+ func (o OltDevice) CollectStatistics(context.Context, *openolt.Empty) (*openolt.Empty, error)

+ func (o OltDevice) DeactivateOnu(context.Context, *openolt.Onu) (*openolt.Empty, error)

+ func (o OltDevice) DeleteOnu(context.Context, *openolt.Onu) (*openolt.Empty, error)

+ func (o OltDevice) DisableOlt(context.Context, *openolt.Empty) (*openolt.Empty, error)

+ func (o OltDevice) DisablePonIf(context.Context, *openolt.Interface) (*openolt.Empty, error)

+ func (o OltDevice) Enable(stream openolt.Openolt_EnableIndicationServer) error

+ func (o OltDevice) EnableIndication(_ *openolt.Empty, stream openolt.Openolt_EnableIndicationServer) error

+ func (o OltDevice) EnablePonIf(context.Context, *openolt.Interface) (*openolt.Empty, error)

+ func (o OltDevice) FindOnu(serialNumber string) (*Onu, error)

+ func (o OltDevice) FlowAdd(ctx context.Context, flow *openolt.Flow) (*openolt.Empty, error)

+ func (o OltDevice) FlowRemove(context.Context, *openolt.Flow) (*openolt.Empty, error)

+ func (o OltDevice) GetDeviceInfo(context.Context, *openolt.Empty) (*openolt.DeviceInfo, error)

+ func (o OltDevice) GetOnuInfo(context context.Context, packet *openolt.Onu) (*openolt.OnuIndication, error)

+ func (o OltDevice) GetPonIf(context context.Context, packet *openolt.Interface) (*openolt.IntfIndication, error)

+ func (o OltDevice) HeartbeatCheck(context.Context, *openolt.Empty) (*openolt.Heartbeat, error)

+ func (o OltDevice) OmciMsgOut(ctx context.Context, omci_msg *openolt.OmciMsg) (*openolt.Empty, error)

+ func (o OltDevice) OnuPacketOut(ctx context.Context, onuPkt *openolt.OnuPacket) (*openolt.Empty, error)

+ func (o OltDevice) Reboot(context.Context, *openolt.Empty) (*openolt.Empty, error)

+ func (o OltDevice) ReenableOlt(context.Context, *openolt.Empty) (*openolt.Empty, error)

+ func (o OltDevice) UplinkPacketOut(context context.Context, packet *openolt.UplinkPacket) (*openolt.Empty, error)

+ func (s OltDevice) CreateTrafficQueues(context.Context, *tech_profile.TrafficQueues) (*openolt.Empty, error)

+ func (s OltDevice) CreateTrafficSchedulers(context.Context, *tech_profile.TrafficSchedulers) (*openolt.Empty, error)

+ func (s OltDevice) RemoveTrafficQueues(context.Context, *tech_profile.TrafficQueues) (*openolt.Empty, error)

+ func (s OltDevice) RemoveTrafficSchedulers(context.Context, *tech_profile.TrafficSchedulers) (*openolt.Empty, error)

+ type OltIndicationMessage struct

+ OperState OperState

+ type OmciMessage struct

+ OnuID uint32

+ OnuSN *openolt.SerialNumber

+ type Onu struct

+ CTag int

+ Channel chan Message

+ HwAddress net.HardwareAddr

+ ID uint32

+ InternalState *fsm.FSM

+ OperState *fsm.FSM

+ PonPort PonPort

+ PonPortID uint32

+ STag int

+ SerialNumber *openolt.SerialNumber

+ func CreateONU(olt OltDevice, pon PonPort, id uint32, sTag int, cTag int) Onu

+ func (o Onu) NewSN(oltid int, intfid uint32, onuid uint32) *openolt.SerialNumber

+ func (o Onu) Sn() string

+ type OnuDiscIndicationMessage struct

+ Onu Onu

+ OperState OperState

+ type OnuFlowUpdateMessage struct

+ Flow *openolt.Flow

+ OnuID uint32

+ PonPortID uint32

+ type OnuIndicationMessage struct

+ OnuID uint32

+ OnuSN *openolt.SerialNumber

+ OperState OperState

+ PonPortID uint32

+ type OperState int

+ const DOWN

+ const UP

+ func (m OperState) String() string

+ type PacketMessage struct

+ OnuID uint32

+ PonPortID uint32

+ type PonIndicationMessage struct

+ OperState OperState

+ PonPortID uint32

+ type PonPort struct

+ ID uint32

+ NumOnu int

+ Olt OltDevice

+ Onus []Onu

+ OperState *fsm.FSM

+ Type string