summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
2f0d02a)
Issue-ID: RICAPP-115
Signed-off-by: sjana <sj492a@att.com>
Change-Id: I07a72a2598f790d1be20dbfd839fb795762f2feb
# this is used by CI jobs to apply a tag when it builds the image
---
# this is used by CI jobs to apply a tag when it builds the image
---
| **Date** | **Ver.** | **Author** | **Comment** |
| | | | |
+--------------------+--------------------+--------------------+--------------------+
| **Date** | **Ver.** | **Author** | **Comment** |
| | | | |
+--------------------+--------------------+--------------------+--------------------+
-| 2020-21-05 | 1.0.3 | Shraboni Jana | Third draft |
+| 2020-06-06 | 1.0.4 | Shraboni Jana | Fourth draft |
| | | | |
+--------------------+--------------------+--------------------+--------------------+
| | | | |
+--------------------+--------------------+--------------------+--------------------+
"image": {
"registry": "nexus3.o-ran-sc.org:10002",
"name": "o-ran-sc/ric-app-hw",
"image": {
"registry": "nexus3.o-ran-sc.org:10002",
"name": "o-ran-sc/ric-app-hw",
//start listener threads and register message handlers.
int num_threads = std::stoi(config[XappSettings::SettingName::THREADS]);
//start listener threads and register message handlers.
int num_threads = std::stoi(config[XappSettings::SettingName::THREADS]);
- bool sub_required = true;
- for(int j=0; j < num_threads; j++) {
- std::unique_ptr<XappMsgHandler> mp_handler;
- if(sub_required)
- mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID], std::ref(*sub_handler));
- else
- mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID]);
-
- hw_xapp->register_handler(std::ref(*mp_handler));
- }
-
mdclog_write(MDCLOG_INFO, "Starting Listener Threads. Number of Workers = %d", num_threads);
mdclog_write(MDCLOG_INFO, "Starting Listener Threads. Number of Workers = %d", num_threads);
+ std::unique_ptr<XappMsgHandler> mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID]);
+ hw_xapp->start_xapp_receiver(std::ref(*mp_handler));
+
+ sleep(1);
- //Delete all subscriptions if any based on Xapp Mode.
//xapp->shutdown();
while(1){
//xapp->shutdown();
while(1){
break;
case A1_POLICY_REQ:
break;
case A1_POLICY_REQ:
+
+ mdclog_write(MDCLOG_INFO, "In Message Handler: Received A1_POLICY_REQ.");
helper.handler_id = xapp_id;
helper.handler_id = xapp_id;
res = a1_policy_handler((char*)message->payload, &message->len, helper);
if(res){
message->mtype = A1_POLICY_RESP; // if we're here we are running and all is ok
res = a1_policy_handler((char*)message->payload, &message->len, helper);
if(res){
message->mtype = A1_POLICY_RESP; // if we're here we are running and all is ok
#include <cstdlib>
#include <mdclog/mdclog.h>
#include <cstdlib>
#include <mdclog/mdclog.h>
-#define DEFAULT_XAPP_NAME "HW-Xapp"
+#define DEFAULT_XAPP_NAME "hwxapp"
#define DEFAULT_PORT "4560"
#define DEFAULT_MSG_MAX_BUFFER "2072"
#define DEFAULT_THREADS "1"
#define DEFAULT_PORT "4560"
#define DEFAULT_MSG_MAX_BUFFER "2072"
#define DEFAULT_THREADS "1"