2 ==================================================================================
3 Copyright (c) 2019 AT&T Intellectual Property.
4 Copyright (c) 2019 Nokia
6 Licensed under the Apache License, Version 2.0 (the "License");
7 you may not use this file except in compliance with the License.
8 You may obtain a copy of the License at
10 http://www.apache.org/licenses/LICENSE-2.0
12 Unless required by applicable law or agreed to in writing, software
13 distributed under the License is distributed on an "AS IS" BASIS,
14 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 See the License for the specific language governing permissions and
16 limitations under the License.
17 ==================================================================================
21 Abstract: Routing Manager Main file. Implemets the following functions:
22 - parseArgs: reading command line arguments
23 - init:Rtmgr initializing the service modules
24 - serve: running the loop
33 "routing-manager/pkg/nbi"
34 "routing-manager/pkg/rpe"
35 "routing-manager/pkg/rtmgr"
36 "routing-manager/pkg/sbi"
37 "routing-manager/pkg/sdl"
42 const SERVICENAME = "rtmgr"
43 const INTERVAL time.Duration = 2
46 args map[string]*string
50 // TODO: arguments should be validated (filename; xm-url; sbi-if; rest-url; rest-port)
51 args = make(map[string]*string)
52 args["configfile"] = flag.String("configfile", "/etc/rtmgrcfg.json", "Routing manager's configuration file path")
53 args["nbi"] = flag.String("nbi", "httpGetter", "Northbound interface module to be used. Valid values are: 'httpGetter | httpRESTful'")
54 args["sbi"] = flag.String("sbi", "nngpush", "Southbound interface module to be used. Valid values are: 'nngpush | nngpub'")
55 args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush | rmrpub'")
56 args["sdl"] = flag.String("sdl", "file", "Datastore enginge to be used. Valid values are: 'file'")
57 args["xm-url"] = flag.String("xm-url", "http://localhost:3000/xapps", "HTTP URL where xApp Manager exposes the entire xApp List")
58 args["nbi-if"] = flag.String("nbi-if", "http://localhost:8888", "Base HTTP URL where routing manager will be listening on")
59 args["sbi-if"] = flag.String("sbi-if", "0.0.0.0", "IPv4 address of interface where Southbound socket to be opened")
60 args["filename"] = flag.String("filename", "/db/rt.json", "Absolute path of file where the route information to be stored")
61 args["loglevel"] = flag.String("loglevel", "INFO", "INFO | WARN | ERROR | DEBUG")
65 func initRtmgr() (nbi.NbiEngine, sbi.SbiEngine, sdl.SdlEngine, rpe.RpeEngine, error) {
67 var nbii nbi.NbiEngine
68 var sbii sbi.SbiEngine
69 var sdli sdl.SdlEngine
70 var rpei rpe.RpeEngine
71 if nbii, err = nbi.GetNbi(*args["nbi"]); err == nil && nbii != nil {
72 if sbii, err = sbi.GetSbi(*args["sbi"]); err == nil && sbii != nil {
73 if sdli, err = sdl.GetSdl(*args["sdl"]); err == nil && sdli != nil {
74 if rpei, err = rpe.GetRpe(*args["rpe"]); err == nil && rpei != nil {
75 return nbii, sbii, sdli, rpei, nil
80 return nil, nil, nil, nil, err
83 func serveSBI(triggerSBI <-chan bool, sbiEngine sbi.SbiEngine, sdlEngine sdl.SdlEngine, rpeEngine rpe.RpeEngine) {
86 data, err := sdlEngine.ReadAll(*args["filename"])
87 if err != nil || data == nil {
88 rtmgr.Logger.Error("cannot get data from sdl interface due to: " + err.Error())
91 sbiEngine.UpdateEndpoints(data)
92 policies := rpeEngine.GeneratePolicies(rtmgr.Eps)
93 err = sbiEngine.DistributeAll(policies)
95 rtmgr.Logger.Error("routing rable cannot be published due to: " + err.Error())
101 func serve(nbiEngine nbi.NbiEngine, sbiEngine sbi.SbiEngine, sdlEngine sdl.SdlEngine, rpeEngine rpe.RpeEngine) {
103 triggerSBI := make(chan bool)
105 nbiErr := nbiEngine.Initialize(*args["xm-url"], *args["nbi-if"], *args["filename"], *args["configfile"],
106 sdlEngine, rpeEngine, triggerSBI)
108 rtmgr.Logger.Error("fail to initialize nbi due to: " + nbiErr.Error())
112 err := sbiEngine.Initialize(*args["sbi-if"])
114 rtmgr.Logger.Info("fail to open pub socket due to: " + err.Error())
117 defer nbiEngine.Terminate()
118 defer sbiEngine.Terminate()
120 // This SBI Go routine is trtiggered by periodic main loop and when data is recieved on REST interface.
121 go serveSBI(triggerSBI, sbiEngine, sdlEngine, rpeEngine)
124 time.Sleep(INTERVAL * time.Second)
125 if *args["nbi"] == "httpGetter" {
126 data, err := nbiEngine.(*nbi.HttpGetter).FetchAllXapps(*args["xm-url"])
128 rtmgr.Logger.Error("cannot fetch xapp data dute to: " + err.Error())
129 } else if data != nil {
130 sdlEngine.WriteXapps(*args["filename"], data)
138 func SetupCloseHandler() {
139 c := make(chan os.Signal, 2)
140 signal.Notify(c, os.Interrupt, syscall.SIGTERM)
143 rtmgr.Logger.Info("\r- Ctrl+C pressed in Terminal")
150 rtmgr.SetLogLevel(*args["loglevel"])
151 nbiEngine, sbiEngine, sdlEngine, rpeEngine, err := initRtmgr()
153 rtmgr.Logger.Error(err.Error())
157 rtmgr.Logger.Info("Start " + SERVICENAME + " service")
158 rtmgr.Eps = make(rtmgr.Endpoints)
159 serve(nbiEngine, sbiEngine, sdlEngine, rpeEngine)