process.cc

/*===========================================================================*\
*                                                                            *
*                              OpenFlipper                                   *
 *           Copyright (c) 2001-2015, RWTH-Aachen University                 *
 *           Department of Computer Graphics and Multimedia                  *
 *                          All rights reserved.                             *
 *                            www.openflipper.org                            *
 *                                                                           *
 *---------------------------------------------------------------------------*
 * This file is part of OpenFlipper.                                         *
 *---------------------------------------------------------------------------*
 *                                                                           *
 * Redistribution and use in source and binary forms, with or without        *
 * modification, are permitted provided that the following conditions        *
 * are met:                                                                  *
 *                                                                           *
 * 1. Redistributions of source code must retain the above copyright notice, *
 *    this list of conditions and the following disclaimer.                  *
 *                                                                           *
 * 2. Redistributions in binary form must reproduce the above copyright      *
 *    notice, this list of conditions and the following disclaimer in the    *
 *    documentation and/or other materials provided with the distribution.   *
 *                                                                           *
 * 3. Neither the name of the copyright holder nor the names of its          *
 *    contributors may be used to endorse or promote products derived from   *
 *    this software without specific prior written permission.               *
 *                                                                           *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS       *
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED *
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A           *
 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER *
 * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,  *
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,       *
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR        *
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF    *
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING      *
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS        *
 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.              *
*                                                                            *
\*===========================================================================*/
 
 
 
 
 
 
//=============================================================================
//
//  CLASS Core - IMPLEMENTATION
//
//=============================================================================
 
 
//== INCLUDES =================================================================
 
#include "Core.hh"
 
#include <OpenFlipper/widgets/processManagerWidget/BlockingWidget.hh>
 
//== IMPLEMENTATION ==========================================================
 
 
// A job has been started by a plugin
void Core::slotStartJob( QString _jobId, QString _description , int _min , int _max, bool _blocking) {
  std::cerr << "StartJob: " << _jobId.toStdString() << " " << _description.toStdString() << " " << _min << " " << _max  << " " << _blocking <<std::endl;
 
  // Create job information
  JobInfo info;
  info.id             = _jobId;
  info.description    = _description;
  info.currentStep    =  0;
  info.minSteps       = _min;
  info.maxSteps       = _max;
  info.blocking       = _blocking;
  info.blockingWidget = 0;
 
 
 
  if (OpenFlipper::Options::gui()) {
    // Don't show process status in process manager
    // if blocking is enabled
    if(_blocking) {
      // Create blocking widget
      BlockingWidget* widget = new BlockingWidget(_jobId, _description,
              _min, _max);
 
      // Connect cancel button to local slot for further treatment
      connect(widget,     SIGNAL(cancelRequested(QString)),
              this,       SLOT(slotJobCancelRequested(QString)));
 
      info.blockingWidget = widget;
 
      int x = (coreWidget_->width()  / 2) - (widget->width()  / 2);
      int y = (coreWidget_->height() / 2) - (widget->height() / 2);
 
      widget->setGeometry( x, y, widget->width(), widget->height());
 
      // Show blocking widget
      widget->show();
 
    } else {
      // Create process manager window if it has not been created before
      if(!processManager_) {
          processManager_ = new ProcessManagerWidget();
 
          // Connect cancel buttons to local slot for further treatment
          connect(processManager_, SIGNAL(cancelJobRequested(QString)),
                  this,            SLOT(slotJobCancelRequested(QString)));
      }
 
      // Add new item
      processManager_->addJob(_jobId, _description, _min, _max);
 
      // Show window
      processManager_->show();
    }
  }
 
  // Add job to local job list
  currentJobs.push_back(info);
}
 
//-----------------------------------------------------------------------------
bool Core::getJob(QString _jobId, int& _index) {
  
  for ( int i = 0 ; i < currentJobs.size() ; ++i) {
      if ( currentJobs[i].id == _jobId ) {
        _index = i;
        return true;
      }
  }
  
  emit log(LOGERR,tr("Unable to find Job %1.").arg(_jobId));
  _index = -1;
  return false;
}
 
//-----------------------------------------------------------------------------
 
// A job state has been updated by a plugin
void Core::slotSetJobState(QString _jobId, int _value ) {
  int id;
  
  if (  getJob(_jobId, id) ) {
    currentJobs[id].currentStep = _value;
 
    if (!OpenFlipper::Options::gui())
        return;
    // Update gui
    if(!currentJobs[id].blocking)
        processManager_->updateStatus(_jobId, _value);
    else {
        BlockingWidget* w = 0;
        w = dynamic_cast<BlockingWidget*>(currentJobs[id].blockingWidget);
        if(w != 0) {
                w->updateStatus(_value);
        }
    }
  }
}
 
//-----------------------------------------------------------------------------
 
// A job's caption has been updated by a plugin
void Core::slotSetJobName(QString _jobId, QString _name ) {
    int id;
    
    if (  getJob(_jobId, id) ) {
        currentJobs[id].id = _name;
 
        if (!OpenFlipper::Options::gui())
            return;
        // Update gui
        if(!currentJobs[id].blocking)
                processManager_->setJobName(_jobId, _name);
        else {
                BlockingWidget* w = 0;
                w = dynamic_cast<BlockingWidget*>(currentJobs[id].blockingWidget);
                if(w != 0) {
                        w->setJobId(_name);
                }
        }
    }
}
//-----------------------------------------------------------------------------
 
// A job's widget's status text has been updated by a plugin
void Core::slotSetJobDescription(QString _jobId, QString _text ) {
    int id;
    
    if (  getJob(_jobId, id) ) {
        currentJobs[id].description = _text;
 
        if (!OpenFlipper::Options::gui())
            return;
        // Update gui
        if(!currentJobs[id].blocking)
                processManager_->setJobDescription(_jobId, _text);
        else {
                BlockingWidget* w = 0;
                w = dynamic_cast<BlockingWidget*>(currentJobs[id].blockingWidget);
            if(w != 0) {
                w->setJobDescription(_text);
            }
        }
    }
}
 
//-----------------------------------------------------------------------------
 
// A job state has been canceled by a plugin
void Core::slotCancelJob(QString _jobId ) {
  int id;
  
  if (  getJob(_jobId, id) ) {
 
    if (OpenFlipper::Options::gui()) {
        // Update gui
        if(!currentJobs[id].blocking)
            processManager_->removeJob(_jobId);
        else {
            BlockingWidget* w = 0;
            w = dynamic_cast<BlockingWidget*>(currentJobs[id].blockingWidget);
            if(w != 0) {
                w->hide();
                delete w;
            }
        }
    }
 
        currentJobs.removeAt(id);
  }
}
 
//-----------------------------------------------------------------------------
 
// A job state has been finished by a plugin
void Core::slotFinishJob(QString _jobId ) {
  int id;
  
  if (  getJob(_jobId, id) ) {
 
    if (OpenFlipper::Options::gui()) {
        // Update gui
        if(!currentJobs[id].blocking) {
            processManager_->removeJob(_jobId);
 
            // Hide widget if there's no job left
            if(processManager_->getNumJobs() == 0) processManager_->hide();
 
        } else {
            BlockingWidget* w = 0;
            w = dynamic_cast<BlockingWidget*>(currentJobs[id].blockingWidget);
            if(w != 0) {
                w->hide();
                delete w;
            }
        }
    }
 
    currentJobs.removeAt(id);
  }
}
 
//-----------------------------------------------------------------------------
 
// A job will be canceled by user request
void Core::slotJobCancelRequested(const QString &_jobId ) {
    
  std::cerr << "Cancel requested!" << std::endl;
  
  emit jobCanceled(_jobId);
    // Cancel job still to be implemented...
        
}
 
//=============================================================================