src/globalsearch/queueinterfaces/internal.h

/*****************************************************************************
  InternalQueueInterface - Interface for running jobs locally on an internal
    queue

  Copyright (C) 2011 by David C. Lonie

  This program is free software; you can redistribute it and/or modify
  it under the terms of the GNU General Public License as published by
  the Free Software Foundation version 2 of the License.

  This program is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License for more details.
 ****************************************************************************/

#ifndef INTERNALQUEUEINTERFACE_H
#define INTERNALQUEUEINTERFACE_H

#include <globalsearch/queueinterfaces/local.h>

#include <QtCore/QProcess>

// Doxygen skip:
namespace GlobalSearch {
class InternalQueueInterfaceConfigDialog;

// Since QProcess doesn't support polling at all (e.g. the only way
// to track its progress is to monitor signals), this class provides
// a basic polling wrapper.
class InternalQueueProcess : public QProcess
{ Q_OBJECT;
public:
  enum Status {NotStarted = 0, Running, Finished, Error};
InternalQueueProcess(QObject *parent) :
  QProcess(parent), m_status(NotStarted)
  {
    connect(this, SIGNAL(started()), this, SLOT(setRunning()));
    connect(this, SIGNAL(finished(int, QProcess::ExitStatus)),
            this, SLOT(setFinished()));
    connect(this, SIGNAL(error(QProcess::ProcessError)),
            this, SLOT(setFinished()));}
public slots:
  void setRunning() {m_status = Running;};
  void setFinished() {m_status = Finished;};
  Status status() {return m_status;};
private:
  Status m_status;
};

class InternalQueueInterface : public LocalQueueInterface
{
    Q_OBJECT
public:
  friend class InternalQueueInterfaceConfigDialog;
  explicit InternalQueueInterface(OptBase *parent,
                                  const QString &settingsFile = "");
  virtual ~InternalQueueInterface();

  virtual bool isReadyToSearch(QString *err);

public slots:

  virtual bool startJob(Structure *s);

  virtual bool stopJob(Structure *s);

  virtual QueueInterface::QueueStatus getStatus(Structure *s) const;

  virtual bool prepareForStructureUpdate(Structure *s) const;

  virtual QDialog* dialog();

protected:
  QHash<unsigned long, InternalQueueProcess*> m_processes;

};

}
// End doxygen skip:

#endif // INTERNALQUEUEINTERFACE_H

---