blob: eb923ba7d3c813a17d5fcc0fa312fcd649217569 [file] [log] [blame]
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -07001/*
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 */
16package core
17
18import (
19 "errors"
20 "fmt"
21 "sync"
22 log "github.com/sirupsen/logrus"
23)
24
25type OnuOmciState struct {
26 gemPortId uint16
27 mibUploadCtr uint16
28 extraMibUploadCtr uint16 // this is only for debug purposes, will be removed in the future
29 uniGInstance uint8
30 tcontInstance uint8
31 pptpInstance uint8
32 priorQInstance uint8 // To assign incrementing value to PQ instance-Id
33 priorQPriority uint8 // Priority of the PriorityQueueG (0-7)
34 tcontPointer uint8 // Tcont Pointer for PriorQ
35 state istate
36}
37
38type istate int
39
40// TODO - Needs to reflect real ONU/OMCI state
41const (
42 INCOMPLETE istate = iota
43 DONE
44)
45
46var OnuOmciStateMap = map[OnuKey]*OnuOmciState{}
47var OnuOmciStateMapLock = sync.RWMutex{}
48
49func NewOnuOmciState() *OnuOmciState {
50 return &OnuOmciState{gemPortId: 0, mibUploadCtr: 0, uniGInstance: 1, tcontInstance: 0, pptpInstance: 1}
51}
52func (s *OnuOmciState) ResetOnuOmciState() {
53 // Resetting the counters
54 s.mibUploadCtr = 0
55 s.extraMibUploadCtr = 0
56 s.gemPortId = 0
57 s.uniGInstance = 1
58 s.tcontInstance = 0
59 s.pptpInstance = 1
60 s.tcontPointer = 0
61 s.priorQPriority = 0
62}
63func GetOnuOmciState(intfId uint32, onuId uint32) istate {
64 key := OnuKey{intfId, onuId}
65 OnuOmciStateMapLock.RLock()
66 defer OnuOmciStateMapLock.RUnlock()
67 if onu, ok := OnuOmciStateMap[key]; ok {
68 return onu.state
69 } else {
70 return INCOMPLETE
71 }
72}
73
74func GetGemPortId(intfId uint32, onuId uint32) (uint16, error) {
75 key := OnuKey{intfId, onuId}
76 OnuOmciStateMapLock.RLock()
77 defer OnuOmciStateMapLock.RUnlock()
78 if OnuOmciState, ok := OnuOmciStateMap[key]; ok {
79 if OnuOmciState.state != DONE {
80 errmsg := fmt.Sprintf("ONU {intfid:%d, onuid:%d} - Not DONE (GemportID is not set)", intfId, onuId)
81 return 0, errors.New(errmsg)
82 }
83 return OnuOmciState.gemPortId, nil
84 }
85 errmsg := fmt.Sprintf("ONU {intfid:%d, onuid:%d} - Failed to find a key in OnuOmciStateMap", intfId, onuId)
86 return 0, errors.New(errmsg)
87}
88
89func CheckIsTeo() string {
90 log.Warn("It's TEO!")
91 return "It's TEO!"
92}