X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fo1%2FO1App.cpp;fp=src%2Fo1%2FO1App.cpp;h=0d2ba2e1bde713f3beb7a46fff2fb4de3c27a938;hb=0a4589de6e89782d734930a2a7648d5921b176d8;hp=d63498f38c35e2c4fbf30f78db5b97dbbae74b6b;hpb=c9ee9d5360e8cad2cb2f807f5ebfabe9304d88c4;p=o-du%2Fl2.git diff --git a/src/o1/O1App.cpp b/src/o1/O1App.cpp index d63498f38..0d2ba2e1b 100644 --- a/src/o1/O1App.cpp +++ b/src/o1/O1App.cpp @@ -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");