Cell down alarm notification [Issue-Id: ODUHIGH-430]

[o-du/l2.git] / src / o1 / O1App.cpp

diff --git a/src/o1/O1App.cpp b/src/o1/O1App.cpp
index d63498f..0d2ba2e 100644 (file)
--- 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");