init

Dockerfile

+from xapp_frame
+
+WORKDIR /xapp
+
+COPY ./main.cpp /xapp/main.cpp
+COPY ./Makefile /xapp/Makefile
+COPY ./run_xapp.sh /xapp/run_xapp.sh
+RUN make
+
+ENTRYPOINT ["/xapp/run_xapp.sh"]
+
+
+

Makefile

+%.o:: %.cpp %.hpp
+	g++ -g ${prereq%% *} -c
+
+% :: %.cpp
+	#C_INCLUDE_PATH=/tmp/usr/include:/usr/local/include g++ $< -g -o $@  -lricxfcpp -lrmr_si -lpthread -lm
+	g++ $< -w -Wextra -Werror -g -o $@  -lricxfcpp -lrmr_si -lpthread -lm -L/usr/local/lib/x86_64-linux-gnu -lpistache -lcpprest -lnlohmann_json_schema_validator -I/usr/loca/include
+	#g++ $< -g -o $@  /usr/local/lib/libricxfcpp.a -lrmr_si -lpthread -lm
+
+all:: main

main.cpp

+#include <memory>
+#include <ricxfcpp/xapp.hpp>
+long m1000_count = 0;    // message counters, one for each type
+long m1001_count = 0;
+
+// callback function that will increase the appropriate counter
+void cbf( xapp::Message& mbuf, int mtype, int subid, int len,
+            xapp::Msg_component payload,  void* data ) {
+    long* counter;
+
+    if( (counter = (long *) data) != NULL ) {
+        (*counter)++;
+    }
+    std::cout << *counter << std::endl;
+}
+
+int main( ) {
+    std::unique_ptr<Xapp> xapp;
+    char* listen_port = (char *) "4560";
+    bool  wait4table = false;
+
+    xapp = std::unique_ptr<Xapp>(
+          new Xapp( listen_port, wait4table ) );
+
+    // register the same callback function for both msg types
+    xapp->Add_msg_cb( 1000, cbf, (void *) &m1000_count );
+    xapp->Add_msg_cb( 1001, cbf, (void *) &m1001_count );
+
+    xapp->Run( 1 );        // start the callback driver
+}
+

run_xapp.sh

+#!/bin/bash
+LD_PRELOAD=/usr/local/lib/libnlohmann_json_schema_validator.so.2 ./main

xapp-descriptor/config.json

+{
+   "comment":  "test xapp",
+   "xapp_name": "xapp_test",
+   "version": "1.0.0",
+   "containers": [
+        {
+            "name": "xapp_test",
+            "image": {
+                "registry": "docker.io",
+                "name": "prlab/xapp_test",
+                "tag": "1.0.0"
+            },
+            "command": [ "/bin/bash", "-c", "--" ],
+        "args": [ "/xapp/run_xapp.sh" ]
+        }
+    ],
+    "messaging": {
+        "ports": [
+            {
+                "name": "rmr-data-in",
+                "container": "xapp_test",
+                "port": 4560,
+                "rxMessages": [
+                    "RIC_UE_CONTEXT_RELEASE",
+                    "TEST_ANOMALY_UPDATE"
+                ],
+                "txMessages": ["TEST_UE_LIST","TEST_ANOMALY_ACK"],
+                "policies": [],
+                "description": "rmr receive data port for xapp_test"
+            },
+            {
+                "name": "rmr-route",
+                "container": "xapp_test",
+                "port": 4561,
+                "description": "rmr route port for test xapp"
+            }
+        ]
+    },
+
+
+    "rmr": {        
+        "protPort": "tcp:4560",
+        "maxSize": 2072,
+        "numWorkers": 1,
+        "txMessages": [
+            "TEST_UE_LIST",
+            "TEST_ANOMALY_ACK"
+        ],
+        "rxMessages":[
+            "RIC_UE_CONTEXT_RELEASE",
+            "TEST_ANOMALY_UPDATE"
+        ],
+        "policies": [20008]
+    }
+    "controls":{
+        "test_control_api" : "rest",
+        "test_control_ep": "http://127.0.0.1:5000/api/echo"
+    }
+}