src/globalsearch/queueinterfaces/loadleveler.h

/*****************************************************************************
  LoadLevelerInterface - Base class for running jobs remotely on a cluster
  managed by LoadLeveler

  Copyright (C) 2012 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 LOADLEVELERINTERFACE_H
#define LOADLEVELERINTERFACE_H

#ifdef ENABLE_SSH

// Tell doxygen to skip this file

#include <globalsearch/queueinterfaces/loadlevelerdialog.h>
#include <globalsearch/queueinterfaces/remote.h>

#include <QtCore/QDateTime>
#include <QtCore/QReadWriteLock>
#include <QtCore/QString>
#include <QtCore/QStringList>

namespace GlobalSearch {

  class LoadLevelerQueueInterface : public RemoteQueueInterface
  {
    Q_OBJECT;

  public:
    explicit LoadLevelerQueueInterface(OptBase *parent,
                                       const QString &settingsFile = "");

    virtual ~LoadLevelerQueueInterface();

    virtual bool isReadyToSearch(QString *str);

    QDialog* dialog();

    friend class LoadLevelerConfigDialog;
    friend class LoadLevelerTest;

  public slots:
    void readSettings(const QString &filename = "");
    void writeSettings(const QString &filename = "");
    bool startJob(Structure *s);
    bool stopJob(Structure *s);
    QueueInterface::QueueStatus getStatus(Structure *s) const;
    void setInterval(const int sec);

  protected:
    // Unit test these:
    QString parseStatus(const QStringList &statusList,
                        unsigned int jobId) const;
    unsigned int parseJobId(const QString &submissionOutput, bool *ok) const;
    // Fetches the queue from the server
    QStringList getQueueList() const;
    // Cached queue data
    QStringList m_queueData;
    // Limits queue checks to once per second
    QDateTime m_queueTimeStamp;
    // Locks for m_queueData;
    QReadWriteLock m_queueMutex;
    // Paths:
    QString m_llq;
    QString m_llsubmit;
    QString m_llcancel;
    // Refresh interval for queue data
    int m_interval;
    // Clean remote directories when a job is stopped?
    bool m_cleanRemoteOnStop;
  };
}

#endif // ENABLE_SSH
#endif // LOADLEVELERINTERFACE_H

// End doxygen skip:

---