ossimJob.cpp

Go to the documentation of this file.

#include <ossim/parallel/ossimJob.h>


void ossimJob::start()
{
   setState(ossimJob_RUNNING);
   run();
   if(!(state() & ossimJob_CANCEL))
   {
      setState(ossimJob_FINISHED);
   }
}

void ossimJob::setState(int value, bool on)
{
   std::shared_ptr<ossimJob> thisShared = getSharedFromThis();

   // we will need to make sure that the state flags are set properly
   // so if you turn on running then you can't have finished or ready turned onturned on
   // but can stil have cancel turned on
   //
   int newState = m_state;
   if(on)
   {
      newState = ((newState | value)&ossimJob_ALL);
   }
   else 
   {
      newState = ((newState & ~value)&ossimJob_ALL);
   }

   int oldState     = 0;
   int currentState = 0;
   std::shared_ptr<ossimJobCallback> callback;

   bool stateChangedFlag = false;
   {
      std::lock_guard<std::mutex> lock(m_jobMutex);
      
      stateChangedFlag = newState != m_state;
      oldState = m_state;
      m_state = static_cast<State>(newState);
      currentState = m_state;
      callback = m_callback;
   }
   
   if(stateChangedFlag&&callback)
   {
      if(!(oldState&ossimJob_READY)&&
         (currentState&ossimJob_READY))
      {
         callback->ready(thisShared);
      }
      else if(!(oldState&ossimJob_RUNNING)&&
              (currentState&ossimJob_RUNNING))
      {
         callback->started(thisShared);
      }
      else if(!(oldState&ossimJob_CANCEL)&&
              (currentState&ossimJob_CANCEL))
      {
         callback->canceled(thisShared);
      }
      else if(!(oldState&ossimJob_FINISHED)&&
              (currentState&ossimJob_FINISHED))
      {
         callback->finished(thisShared);
      }
   }
}