---

VisQueueProcessor.cc

Go to the documentation of this file.

//<<<<<< INCLUDES                                                       >>>>>>

#include "VisFramework/VisFrameworkBase/interface/VisQueueProcessor.h"
#include "VisFramework/VisFrameworkBase/interface/VisQueue.h"
#include "VisFramework/VisFrameworkBase/interface/debug.h"
#include "Utilities/Threads/interface/Thread.h"
#include <classlib/utils/Signal.h>
#include <classlib/utils/Callback.h>
#include <qapplication.h> // FIXME: move out

//<<<<<< PRIVATE DEFINES                                                >>>>>>
//<<<<<< PRIVATE CONSTANTS                                              >>>>>>
//<<<<<< PRIVATE TYPES                                                  >>>>>>
//<<<<<< PRIVATE VARIABLE DEFINITIONS                                   >>>>>>
//<<<<<< PUBLIC VARIABLE DEFINITIONS                                    >>>>>>
//<<<<<< CLASS STRUCTURE INITIALIZATION                                 >>>>>>

IG_DEFINE_STATE_ELEMENT (VisQueueProcessor,
                         "Services/Framework/Elements/QueueProcessor");

//<<<<<< PRIVATE FUNCTION DEFINITIONS                                   >>>>>>
//<<<<<< PUBLIC FUNCTION DEFINITIONS                                    >>>>>>
//<<<<<< MEMBER FUNCTION DEFINITIONS                                    >>>>>>

VisQueueProcessor::VisQueueProcessor (IgState *state)
    : m_state (state),
      m_done (false),
      m_dispatcher (new VisEventDispatcher ())
{
    LOG (0, trace, LFfwvis, "VisQueueProcessor::VisQueueProcessor\n");
    ASSERT (m_state); m_state->put (s_key, this); 
}

VisQueueProcessor::~VisQueueProcessor (void)
{ ASSERT (m_state); m_state->detach (s_key); }

VisQueueProcessor::VisEventDispatcher
VisQueueProcessor::eventDispatcher (void)
{
    return *m_dispatcher;
}


void
VisQueueProcessor::process (void)
{
    LOG (0, trace, LFfwvis, "VisQueueProcessor::process()\n");

    // Force our signal handler until we can get decent tracebacks
    // from COBRA in case of error.  This kills the Objy handlers so
    // it isn't a nice approach...
    lat::Signal::handleFatal("iguana");

    // FIXME: Move out -- another lazy observer that observes event?
    qApp->lock ();
    QApplication::restoreOverrideCursor ();
    qApp->unlock (false);

    // Pull items off the queue and execute them until we are told to
    // stop.  Abort throws an exception so we don't need to care.
    VisQueue *q = VisQueue::get (m_state);
    ASSERT (q);

    for (m_done = false; ! m_done; )
    {
        lat::Callback action (q->pop ());
        LOG (0, trace, LFfwvis, "VisQueueProcessor: got action\n");
        action ();
    }

    LOG (0, trace, LFfwvis, "VisQueueProcessor: loop done\n"); 

    // FIXME: Move out -- another observer that observes end-of-event?
    // FIXME: Block GUI.  FIXME: Needs unsetting for end-of-run.
    qApp->lock ();
    QApplication::setOverrideCursor (Qt::waitCursor);
    qApp->unlock (false);

    LOG (0, trace, LFfwvis, "VisQueueProcessor::process() done\n");
}


void
VisQueueProcessor::scheduleAbort (void)
{
    ASSERT (VisQueue::get (m_state));
    VisQueue::get (m_state)
        ->push (lat::CreateCallback (this, &VisQueueProcessor::doAbort));
}

void
VisQueueProcessor::scheduleNextEvent (void)
{
    LOG (0, trace, LFfwvis, "VisQueueProcessor::scheduleNextEvent()\n");

    ASSERT (VisQueue::get (m_state));
    VisQueue::get (m_state)
        ->push (lat::CreateCallback (this, &VisQueueProcessor::doNextEvent));

    LOG (0, trace, LFfwvis, "VisQueueProcessor::scheduleNextEvent() done\n");
}


void
VisQueueProcessor::doAbort (void)
{ 
    //throw FIXME::SomeExceptionTypeHere (); 
}

void
VisQueueProcessor::doNextEvent (void)
{
    LOG (0, trace, LFfwvis, "VisQueueProcessor::doNextEvent()\n");

    VisEventMessage event;
    
    eventDispatcher ().broadcast (event);
    m_done = true;

    LOG (0, trace, LFfwvis, "VisQueueProcessor::doNextEvent() done\n");
}

---