src/o1/O1App.cpp

   1 /*******************************************************************************
   2 ################################################################################
   3 #   Copyright (c) [2020-2021] [HCL Technologies Ltd.]                          #
   4 #                                                                              #
   5 #   Licensed under the Apache License, Version 2.0 (the "License");            #
   6 #   you may not use this file except in compliance with the License.           #
   7 #   You may obtain a copy of the License at                                    #
   8 #                                                                              #
   9 #       http://www.apache.org/licenses/LICENSE-2.0                             #
  10 #                                                                              #
  11 #   Unless required by applicable law or agreed to in writing, software        #
  12 #   distributed under the License is distributed on an "AS IS" BASIS,          #
  13 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
  14 #   See the License for the specific language governing permissions and        #
  15 #   limitations under the License.                                             #
  16 ################################################################################
  17 *******************************************************************************/
  18
  19 /* This file contains the O1App class which is responsible for running/starting
  20    all the O1 modules in a thread. It inherits the Thread class and Singleton
  21    class.
  22 */
  23
  24 #include "O1App.hpp"
  25 #include "GlobalDefs.hpp"
  26 #include "SessionHandler.hpp"
  27 #include "CmInterface.h"
  28 #include <unistd.h>
  29
  30 #include "VesUtils.hpp"
  31 #include "VesEventHandler.hpp"
  32
  33
  34 /*******************************************************************
  35  *
  36  * @brief Constructor
  37  *
  38  * @details
  39  *
  40  *    Function : O1App
  41  *
  42  *    Functionality:
  43  *      - Constructor intialization
  44  *
  45  * @params[in] None
  46  * @return None
  47  ******************************************************************/
  48
  49 O1App::O1App() : mUxSocketServer(O1::ALARM_SOCK_PATH)
  50 {
  51
  52 }
  53
  54 /*******************************************************************
  55  *
  56  * @brief Destructor
  57  *
  58  * @details
  59  *
  60  *    Function : ~O1App
  61  *
  62  *    Functionality:
  63  *      - Destructor
  64  *
  65  * @params[in] None
  66  * @return None
  67  ******************************************************************/
  68
  69 O1App::~O1App()
  70 {
  71
  72 }
  73
  74 /*******************************************************************
  75  *
  76  * @brief Runs the O1 modules as a thread
  77  *
  78  * @details
  79  *
  80  *    Function : run
  81  *
  82  *    Functionality:
  83  *      - Implements the "run" function of Thread class.
  84  *        Starts all the O1 modules.
  85  *
  86  *
  87  * @params[in] void
  88  * @return true  : success
  89  *         false : failure
  90  ******************************************************************/
  91
  92 bool O1App::run()
  93 {
  94    const int SLEEP_INTERVAL = 2;
  95    const int DEFAUL_CELL_ID = 1;
  96    SessionHandler sessHdlr;
  97
  98    /*setting default cell state disabled*/
  99    setCellOpState(DEFAUL_CELL_ID, DISABLED, INACTIVE);
 100
 101    /* Start Netconf session and subscribe to yang modules */
 102    try
 103    {
 104       if( !sessHdlr.init() )
 105       {
 106          O1_LOG("\nO1 O1App : SessionHandler initialization failed ");
 107          return false;
 108       }
 109    }
 110    catch( const std::exception& e )
 111    {
 112       O1_LOG("\nO1 O1App : Exception : %s", e.what());
 113       return false;
 114    }
 115
 116    /* Start the Unix Socket Server to listen for alarm messages */
 117    AlarmManager::instance().subscribe(&mUxSocketServer);
 118    if( mUxSocketServer.start() )
 119    {
 120
 121       if(mUxSocketServer.setAffinity(O1::CPU_CORE))
 122       {
 123          O1_LOG("\nO1 O1App : CPU affinity set for UnixSocketServer thread to " );
 124          mUxSocketServer.printAffinity();
 125       }
 126
 127       sleep(SLEEP_INTERVAL);
 128       if( mUxSocketServer.isRunning() )
 129       {
 130          mStartupStatus = true;
 131          O1_LOG("\nO1 O1App : Unix Socket server started");
 132       }
 133       else
 134       {
 135          O1_LOG("\nO1 O1App : Unix Socket server failed to start");
 136          return false;
 137       }
 138       /* Wait for the Unix Socket Server thread to end*/
 139       mUxSocketServer.join();
 140    }
 141    else
 142    {
 143       O1_LOG("\nO1 O1App : Unix Socket server failed to start");
 144       return false;
 145    }
 146    return true;
 147 }
 148
 149 /*******************************************************************
 150  *
 151  * @brief Check if the O1 Module is fully up and running
 152  *
 153  * @details
 154  *
 155  *    Function : getStartupStatus
 156  *
 157  *    Functionality:
 158  *      - Returns the status of O1App whether it is fully up
 159  *
 160  *
 161  * @params[in] void
 162  * @return true  : started
 163  *         false : not started
 164  ******************************************************************/
 165
 166 bool O1App::getStartupStatus() const
 167 {
 168    return mStartupStatus;
 169 }
 170
 171 /*******************************************************************
 172  *
 173  * @brief Cleanup O1App
 174  *
 175  * @details
 176  *
 177  *    Function : cleanUp
 178  *
 179  *    Functionality:
 180  *      - Implements the "cleanUp" function of Thread class to
 181  *        take care of any clean up required for O1 components
 182  *        before stopping the thread.
 183  *
 184  * @params[in] void
 185  * @return void
 186  ******************************************************************/
 187
 188 void O1App::cleanUp(void)
 189 {
 190    /* Stop the socket server thread */
 191    mUxSocketServer.stop();
 192 }