RealTime2.cxx

Go to the documentation of this file.

#include "RealTime2.h"

ClassImp(RealTime2)

// cannot make a namespace ?? unamed to try
// unamed bad idea, make global better like this, not sure
bool RealTime2::status_rt = false;
RealTime2* RealTime2::frealtime = NULL;

RealTime2* RealTime2::getInstance()
{
#ifdef DEBUG_CONT_FRAME
    std::cout << "RealTime2::getInstance() " << std::endl;
#endif
 if ( status_rt )
    return frealtime;
 else {
    frealtime = new RealTime2();
    status_rt = true;
    return frealtime;
 }
}

void RealTime2::killInstance()
{
  if ( !status_rt ) {
      std::cout << "RealTime::killInstance, but has not been run, nothing to do " << std::endl;
      return;
  }
  else {
      delete frealtime;
      frealtime = 0;
      status_rt = false;      
  }
}

void RealTime2::SetMessage( std::vector<std::string> & message ) {
#ifdef DEBUG_CONT_FRAME
        std::cout << "RealTime2::ListMessages push back a new message " << std::endl;
#endif
        // insert new element at the end
        //need to protect here ?
        //boost::lock_guard automatically calls lock() and unlock() inside its constructor and destructor, respectively.
        // destructed automatically on exit of the function
        boost::lock_guard<boost::mutex> lock(mutex);
        ListMessages.push_back( message );
#ifdef DEBUG_CONT_FRAME
        std::cout << "Size of the list " << ListMessages.size() << std::endl;
#endif
}

std::vector<std::string> RealTime2::GetMessage() {
/*
#ifdef DEBUG_CONT_FRAME
        std::cout << "RealTime2::GetMessage " << std::endl;
#endif
*/
        std::vector<std::string> message;
        // if the list is empty return
        if (! ListMessages.size() ) {
/*
#ifdef DEBUG_CONT_FRAME
                std::cout << "The list is empty return" << std::endl;
#endif
*/
                return message;
        }

        boost::lock_guard<boost::mutex> lock(mutex);
        // access first element
        message = ListMessages.front();
        // remove the first element from the list
        // need lock here as well
        ListMessages.erase ( ListMessages.begin() );
#ifdef DEBUG_CONT_FRAME
        std::cout << "return a non-empty message" << std::endl;
#endif
        return message;
}

//not needed should in controller or main/indicator frame
/*
void RealTime2::ConnectToGUI()
{
#ifdef DEBUG_CONT_FRAME
    std::cout << "\n\t RealTime2::ConnectToGUI RealTime2 not used !!!! " << std::endl;
#endif
 //Connect("Timeout()", "RealTime", 0, "UpdateStock()");
 //Start(10000);
 Start(100);
}
*/

// works, but still bound to thread
/*
void RealTime2::GetUpdate()
{
#ifdef DEBUG_CONT_FRAME
    std::cout << "\n\t RealTime2::GetUpdate Emit TimeOut()" << std::endl;
#endif

    Timeout();
    //Emit("TimeOut()");
}
*/