X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fo1%2FO1App.cpp;h=0d2ba2e1bde713f3beb7a46fff2fb4de3c27a938;hb=6dc8a4c17da24847b3a3aee91b37151f77a8a5bc;hp=5b1382160ef16e5e1fadde045775d1a0216ef423;hpb=6fe137e5c6f9470f4f48448f5651573c42bd8aed;p=o-du%2Fl2.git diff --git a/src/o1/O1App.cpp b/src/o1/O1App.cpp index 5b1382160..0d2ba2e1b 100644 --- a/src/o1/O1App.cpp +++ b/src/o1/O1App.cpp @@ -24,7 +24,7 @@ #include "O1App.hpp" #include "GlobalDefs.hpp" #include "SessionHandler.hpp" -#include "ConfigInterface.h" +#include "CmInterface.h" #include #include "VesUtils.hpp" @@ -73,7 +73,7 @@ O1App::~O1App() /******************************************************************* * - * @brief Runs the O1 modules as a thread + * @brief Runs the O1 modules as a thread * * @details * @@ -103,28 +103,29 @@ bool O1App::run() { if( !sessHdlr.init() ) { - O1_LOG("\nO1 O1App : SessionHandler initialization failed "); + O1_LOG("\nO1 O1App : SessionHandler initialization failed "); return false; } } - catch( const std::exception& e ) + catch( const std::exception& e ) { O1_LOG("\nO1 O1App : Exception : %s", e.what()); return false; } - + /* Start the Unix Socket Server to listen for alarm messages */ + AlarmManager::instance().subscribe(&mUxSocketServer); if( mUxSocketServer.start() ) - { - + { + if(mUxSocketServer.setAffinity(O1::CPU_CORE)) { O1_LOG("\nO1 O1App : CPU affinity set for UnixSocketServer thread to " ); mUxSocketServer.printAffinity(); } - + sleep(SLEEP_INTERVAL); - if( mUxSocketServer.isRunning() ) + if( mUxSocketServer.isRunning() ) { mStartupStatus = true; O1_LOG("\nO1 O1App : Unix Socket server started");