+++ /dev/null
-/*
-# ============LICENSE_START===============================================
-# Copyright (C) 2020 Nordix Foundation. All rights reserved.
-# ========================================================================
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# 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.
-# ============LICENSE_END=================================================
-#
-*/
-
-// Sim mon server - query the agent and the simulators for counters and other data
-// Presents a web page on localhost:9999/mon
-
-var LOCALHOST="http://127.0.0.1:"
-var MRSTUB_PORT="3905"
-var AGENT_PORT="8081"
-var CR_PORT="8090"
-var http = require('http');
-
-var express = require('express');
-var app = express();
-var fieldSize=32;
-
-
-
-//I am alive
-app.get("/",function(req, res){
- res.send("ok");
-})
-
-//Get parameter valuue from other server
-function getSimCtr(url, index, cb) {
- var data = '';
- http.get(url, (resp) => {
- // A chunk of data has been recieved.
- resp.on('data', (chunk) => {
- data += chunk;
- });
-
- // The whole response has been received.
- resp.on('end', () => {
- var code=resp.statusCode
- if (code > 199 && code < 300) {
- cb(data, index);
- } else {
- cb("not found", index);
- }
- });
-
- }).on("error", (err) => {
- console.log("Error: " + err.message);
- cb("no response", index);
- });
-};
-
-
-//Format a comma separated list of data to a html-safe string with fixed fieldsizes
-function formatDataRow(commaList) {
- var str = "";
- var tmp=commaList.split(',');
- for(var i=0;i<tmp.length;i++) {
- var data=tmp[i];
- var len = fieldSize-data.length;
- while(len>0) {
- data = data+" ";
- len--;
- }
- str=str+data+" ";
- }
- return str;
-}
-
-//Format a comma separated list of ids to a html-safe string with fixed fieldsizes
-function formatIdRow(commaList) {
- var str = "";
- var tmp=commaList.split(',');
- for(var i=0;i<tmp.length;i++) {
- tmp[i] = tmp[i].trim();
- var data="<"+tmp[i]+">";
- var len = fieldSize+4-data.length;
- while(len>0) {
- data = data+" ";
- len--;
- }
- str=str+data+" ";
- }
- return str;
-}
-
-//Format a list of ids to a html-safe string in compact format
-function formatIdRowCompact(commaList) {
- if (commaList == undefined) {
- commaList= "";
- }
- var str = "";
- var tmp=commaList.split(',');
- for(var i=0;i<tmp.length;i++) {
- tmp[i] = tmp[i].trim();
- var data="<"+tmp[i]+">";
- str=str+data+" ";
- }
- return str;
-}
-
-//Pad a string upto a certain size using a pad string
-function padding(val, fieldSize, pad) {
- var s=""+val;
- for(var i=s.length;i<fieldSize;i++) {
- s=s+pad
- }
- return s;
-}
-
-//Status variables, for parameters values fetched from other simulators
-var mr1="", mr2="", mr3="", mr4="", mr5="", mr6="";
-
-//Status variables for agent
-var ag1=""
-var ag2=""
-var ag3=""
-var ag4=""
-
-//Status variables for callback receiver
-var cr1=""
-var cr2=""
-var cr3=""
-
-
-//Container names and ports of the ric simulator
-var simnames=[]
-var simports=[]
-
-//Status variables for each ric simulator
-var simvar1=[]
-var simvar2=[]
-var simvar3=[]
-var simvar4=[]
-
-//Counts the number of get request for the html page
-var getCtr=0
-
-var refreshInterval=2000
-
-function fetchAllMetrics() {
- setTimeout(() => {
-
- console.log("Fetching all metics data")
- if (refreshInterval < 20000) {
- refreshInterval+=100
- }
- if (getCtr%3 == 0) {
- //Extract the port numbers from the running simulators, for every 3 calls
- const { exec } = require('child_process');
- exec('docker ps --filter "name=ricsim" --format "{{.Names}} {{.Ports}}" | sed s/0.0.0.0:// | cut -d \'>\' -f1 | sed \'s/[[-]]*$//\'', (err, stdout, stderr) => {
-
- var simulators = ""
- simulators=`${stdout}`.replace(/(\r\n|\n|\r)/gm," ");
- simulators=simulators.trim();
- var sims=simulators.split(" ")
- simnames=[]
- simports=[]
- for(i=0;i<sims.length;i=i+2) {
- simnames[i/2]=sims[i]
- simports[i/2]=sims[i+1]
- }
- });
- }
- getCtr=getCtr+1
-
- //Get metric values from the simulators
- for(var index=0;index<simnames.length;index++) {
- getSimCtr(LOCALHOST+simports[index]+"/counter/num_instances", index, function(data, index) {
- simvar1[index] = data;
- });
- getSimCtr(LOCALHOST+simports[index]+"/counter/num_types", index, function(data,index) {
- simvar2[index] = data;
- });
- getSimCtr(LOCALHOST+simports[index]+"/policytypes", index, function(data,index) {
- data=data.replace(/\[/g,'');
- data=data.replace(/\]/g,'');
- data=data.replace(/ /g,'');
- data=data.replace(/\"/g,'');
- simvar3[index] = data;
- });
- getSimCtr(LOCALHOST+simports[index]+"/counter/interface", index, function(data,index) {
- simvar4[index] = data;
- });
- }
-
- //MR - get metrics values from the MR stub
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/requests_submitted", 0, function(data, index) {
- mr1 = data;
- });
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/requests_fetched", 0, function(data, index) {
- mr2 = data;
- });
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/current_requests", 0, function(data, index) {
- mr3 = data;
- });
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/responses_submitted", 0, function(data, index) {
- mr4 = data;
- });
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/responses_fetched", 0, function(data, index) {
- mr5 = data;
- });
- getSimCtr(LOCALHOST+MRSTUB_PORT+"/counter/current_responses", 0, function(data, index) {
- mr6 = data;
- });
-
- //CR - get metrics values from the callbackreceiver
- getSimCtr(LOCALHOST+CR_PORT+"/counter/received_callbacks", 0, function(data, index) {
- cr1 = data;
- });
- getSimCtr(LOCALHOST+CR_PORT+"/counter/fetched_callbacks", 0, function(data, index) {
- cr2 = data;
- });
- getSimCtr(LOCALHOST+CR_PORT+"/counter/current_messages", 0, function(data, index) {
- cr3 = data;
- });
-
- //Agent - get metrics from the agent
- getSimCtr(LOCALHOST+AGENT_PORT+"/status", 0, function(data, index) {
- ag1 = data;
- });
- getSimCtr(LOCALHOST+AGENT_PORT+"/services", 0, function(data, index) {
- ag2="";
- try {
- var jd=JSON.parse(data);
- for(var key in jd) {
- if (ag2.length > 1) {
- ag2=ag2+", "
- }
- ag2=ag2+(jd[key]["serviceName"]).trim()
- }
- }
- catch (err) {
- ag2=data
- }
- });
- getSimCtr(LOCALHOST+AGENT_PORT+"/policy_types", 0, function(data, index) {
- ag3="";
- try {
- var jd=JSON.parse(data);
- for(var key in jd) {
- if (ag3.length > 0) {
- ag3=ag3+", "
- }
- ag3=ag3+jd[key].trim()
- }
- }
- catch (err) {
- ag3=""
- }
- });
- getSimCtr(LOCALHOST+AGENT_PORT+"/policy_ids", 0, function(data, index) {
- ag4=""
- try {
- var jd=JSON.parse(data);
- ag4=""+jd.length
- }
- catch (err) {
- ag4=""
- }
- });
-
-
-
- fetchAllMetrics();
- }, refreshInterval)
-}
-
-fetchAllMetrics();
-
-setInterval(() => {
- console.log("Setting interval "+refreshInterval+"ms")
-}, refreshInterval)
-
-app.get("/mon",function(req, res){
-
-
- refreshInterval=2000
-
- //Build web page
- var htmlStr = "<!DOCTYPE html>" +
- "<html>" +
- "<head>" +
- "<meta http-equiv=\"refresh\" content=\"2\">"+ //2 sec auto refresh
- "<title>Policy Agent and simulator monitor</title>"+
- "</head>" +
- "<body>" +
- "<h3>Policy agent</h3>" +
- "<font face=\"monospace\">" +
- "Status:..............................." + formatDataRow(ag1) + "<br>" +
- "Services:............................." + formatIdRowCompact(ag2) + "<br>" +
- "Types:................................" + formatIdRowCompact(ag3) + "<br>" +
- "Number of instances:.................." + formatDataRow(ag4) + "<br>" +
- "</font>" +
- "<h3>MR Stub interface</h3>" +
- "<font face=\"monospace\">"+
- "Submitted requests:............................" + formatDataRow(mr1) + "<br>" +
- "Fetched requests:.............................." + formatDataRow(mr2) + "<br>" +
- "Current requests waiting:......................" + formatDataRow(mr3) + "<br>" +
- "Submitted responses:..........................." + formatDataRow(mr4) + "<br>" +
- "Fetched responses.............................." + formatDataRow(mr5) + "<br>" +
- "Current responses waiting......................" + formatDataRow(mr6) + "<br>" +
- "</font>"+
- "<h3>Callback receiver</h3>" +
- "<font face=\"monospace\">" +
- "Callbacks received:..................." + formatDataRow(cr1) + "<br>" +
- "Callbacks fetched:...................." + formatDataRow(cr2) + "<br>" +
- "Number of waiting callback messages:.." + formatDataRow(cr3) + "<br>" +
- "</font>" +
- "<h3>Near-RT RIC Simulators</h3>" +
- "<font face=\"monospace\">"
-
- htmlStr=htmlStr+padding("Near-RT RIC Simulator name", 35," ")
- htmlStr=htmlStr+padding("Types", 10," ")
- htmlStr=htmlStr+padding("Instances", 10," ")
- htmlStr=htmlStr+"<br>"+padding("",55,"=")+"<br>"
-
- for(var simIndex=0;simIndex<simnames.length;simIndex++) {
- htmlStr=htmlStr+padding(simnames[simIndex]+ " ("+simports[simIndex]+")",35," ");
- htmlStr=htmlStr+padding(simvar2[simIndex],10," ")
- htmlStr=htmlStr+padding(simvar1[simIndex],10," ")
- htmlStr=htmlStr+"<br>";
- }
-
- htmlStr=htmlStr+"<br>";
- htmlStr=htmlStr+padding("Near-RT RIC Simulator name", 35," ")
- htmlStr=htmlStr+padding("Version", 20," ")
- htmlStr=htmlStr+padding("Type-IDs", 10," ")+"<br>"
- htmlStr=htmlStr+padding("",65,"=")+"<br>"
- for(simIndex=0;simIndex<simnames.length;simIndex++) {
- htmlStr=htmlStr+padding(simnames[simIndex]+ " ("+simports[simIndex]+")",35," ");
- htmlStr=htmlStr+padding(simvar4[simIndex],20," ")
- htmlStr=htmlStr+padding(formatIdRowCompact(simvar3[simIndex]),10," ")
- htmlStr=htmlStr+"<br>";
- }
-
- htmlStr=htmlStr+
- "</body>" +
- "</html>";
- res.send(htmlStr);
-})
-
-var httpServer = http.createServer(app);
-var httpPort=9999;
-httpServer.listen(httpPort);
-console.log("Simulator monitor listening (http) at "+httpPort);
-console.log("Open the web page on localhost:9999/mon to view the statistics page.")
\ No newline at end of file
Code Review / nonrtric.git / blobdiff