[1890] - E2M: Get all nodes fail after a couple of tries 46/746/1
authorns019t <ns019t@intl.att.com>
Mon, 19 Aug 2019 09:45:35 +0000 (12:45 +0300)
committerns019t <ns019t@intl.att.com>
Mon, 19 Aug 2019 09:45:41 +0000 (12:45 +0300)
Change-Id: I262c43af3af43f04a9affb8761ca7bf74dfea62d
Signed-off-by: ns019t <ns019t@intl.att.com>
E2Manager/controllers/nodeb_controller.go
E2Manager/services/rnib_reader_service.go

index d0448aa..a3286f8 100644 (file)
@@ -141,7 +141,7 @@ func (rc NodebController) HandleRequest(writer http.ResponseWriter, request *htt
 
 func (rc NodebController) GetNodebIdList (writer http.ResponseWriter, request *http.Request, params httprouter.Params) {
        startTime := time.Now()
-       rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider())
+       rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider)
        nodebIdList, rnibError := rnibReaderService.GetNodebIdList()
 
        if rnibError != nil {
@@ -169,7 +169,7 @@ func (rc NodebController) GetNodeb(writer http.ResponseWriter, request *http.Req
        startTime := time.Now()
        ranName := params.ByName("ranName")
        // WAS: respondingNode, rnibError := reader.GetRNibReader().GetNodeb(ranName)
-       rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider());
+       rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider);
        respondingNode, rnibError := rnibReaderService.GetNodeb(ranName)
        if rnibError != nil {
                rc.Logger.Errorf("%v", rnibError)
index 1c310a1..a598243 100644 (file)
@@ -24,27 +24,25 @@ import (
 )
 
 type RnibReaderService struct {
-       rnibReaderInstance reader.RNibReader
+       rnibReaderProvider func() reader.RNibReader
 }
 
-func NewRnibReaderService(rnibReaderInstance reader.RNibReader) *RnibReaderService{
-       return &RnibReaderService{rnibReaderInstance}
+func NewRnibReaderService(rnibReaderProvider func() reader.RNibReader) *RnibReaderService{
+       return &RnibReaderService{rnibReaderProvider}
 }
 
-
-
 func (s RnibReaderService) GetNodeb(ranName string) (*entities.NodebInfo, common.IRNibError) {
-       return s.rnibReaderInstance.GetNodeb(ranName)
+       return s.rnibReaderProvider().GetNodeb(ranName)
 }
 
 func (s  RnibReaderService) GetNodebIdList()(*[]*entities.NbIdentity, common.IRNibError) {
-       enbIdList, err := s.rnibReaderInstance.GetListEnbIds()
+       enbIdList, err := s.rnibReaderProvider().GetListEnbIds()
 
        if (err != nil) {
                return nil, err
        }
 
-       gnbIdList, err := s.rnibReaderInstance.GetListGnbIds()
+       gnbIdList, err := s.rnibReaderProvider().GetListGnbIds()
 
        if (err != nil) {
                return nil, err