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.
+
+
+ This source code is part of the near-RT RIC (RAN Intelligent Controller)
+ platform project (RICP).
+
==================================================================================
*/
/*
import (
"encoding/json"
+ "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"net/http"
"routing-manager/pkg/rpe"
"routing-manager/pkg/rtmgr"
"routing-manager/pkg/sdl"
+ "sync"
"time"
)
return instance
}
-var myClient = &http.Client{Timeout: 5 * time.Second}
+var myClient = &http.Client{Timeout: 15 * time.Second}
func fetchAllXApps(xmurl string) (*[]rtmgr.XApp, error) {
- rtmgr.Logger.Info("Invoked httpGetter.fetchXappList: " + xmurl)
+ xapp.Logger.Info("Invoked httpGetter.fetchXappList: " + xmurl)
r, err := myClient.Get(xmurl)
if err != nil {
return nil, err
defer r.Body.Close()
if r.StatusCode == 200 {
- rtmgr.Logger.Debug("http client raw response: %v", r)
+ xapp.Logger.Debug("http client raw response: %v", r)
var xApps []rtmgr.XApp
err = json.NewDecoder(r.Body).Decode(&xApps)
if err != nil {
- rtmgr.Logger.Warn("Json decode failed: " + err.Error())
+ xapp.Logger.Warn("Json decode failed: " + err.Error())
}
- rtmgr.Logger.Info("HTTP GET: OK")
- rtmgr.Logger.Debug("httpGetter.fetchXappList returns: %v", xApps)
+ xapp.Logger.Info("HTTP GET: OK")
+ xapp.Logger.Debug("httpGetter.fetchXappList returns: %v", xApps)
return &xApps, err
}
- rtmgr.Logger.Warn("httpGetter got an unexpected http status code: %v", r.StatusCode)
+ xapp.Logger.Warn("httpGetter got an unexpected http status code: %v", r.StatusCode)
return nil, nil
}
-func (g *HttpGetter) Initialize(xmurl string, nbiif string, fileName string, configfile string,
- sdlEngine sdl.Engine, rpeEngine rpe.Engine, triggerSBI chan<- bool) error {
+func (g *HttpGetter) Initialize(xmurl string, nbiif string, fileName string, configfile string, e2murl string,
+ sdlEngine sdl.Engine, rpeEngine rpe.Engine, m *sync.Mutex) error {
return nil
}