src/stats/stats.cpp

Go to the documentation of this file.

#include "stats.h"
#include "../mainwindowimpl.h"
#include "../thread/sshexecutethread.h"
#include <QDebug>
#include <QStandardItemModel>
#include <QMovie>

Stats::Stats(QWidget *parent)
    : QWidget(parent)
{
    setupUi(this);
    connect(actionRefresh, SIGNAL(triggered()), this, SLOT(refresh()));

    // Set the model of the treeView and configure it
    model =  new QStandardItemModel(0, 6, parent);

    model->setHeaderData(0, Qt::Horizontal, QObject::tr("JOBNAME"));
    model->setHeaderData(1, Qt::Horizontal, QObject::tr("USERNAME"));
    model->setHeaderData(2, Qt::Horizontal, QObject::tr("STATE"));
    model->setHeaderData(3, Qt::Horizontal, QObject::tr("PROC"));
    model->setHeaderData(4, Qt::Horizontal, QObject::tr("REMAINING"));
    model->setHeaderData(5, Qt::Horizontal, QObject::tr("STARTTIME"));

    treeView->setModel(model);
    treeView->setRootIsDecorated(false);
    treeView->setAlternatingRowColors(true);
    treeView->setSortingEnabled(true);
    treeView->setUniformRowHeights(true);

    // Set the delegate of the treeView and configure it
    delegate = new StatsDelegate(this->treeView);
    treeView->setItemDelegate(delegate);

    treeView->setContextMenuPolicy(Qt::CustomContextMenu);
    QObject::connect(treeView, SIGNAL(customContextMenuRequested( const QPoint &)),
                     delegate, SLOT(onCustomContextMenuRequested( const QPoint &)));

}


void Stats::addJobEntry(const QString &jobname,
              const QString &username, const QString &state,
              const QString &proc, const QString &remaining, const QString &starttime)
{
    model->insertRow(0);
    model->setData(model->index(0, 0), jobname);
    model->setData(model->index(0, 1), username);
    model->setData(model->index(0, 2), state);
    model->setData(model->index(0, 3), proc);
    model->setData(model->index(0, 4), remaining);
    model->setData(model->index(0, 5), starttime);
}



void Stats::clearJobListing ()
{
    model->removeRows(0, model->rowCount());
}

void Stats::refresh()
{
    Myssh & ssh = dynamic_cast<MainWindowImpl*>(window())->_ssh;


    if (ssh.isConnected())
    {
        QMovie * movie = new QMovie(":/imgs/anim.gif");
        lAnim->setMovie(movie);
        movie->start();

        SSHExecuteThread * thread = new SSHExecuteThread(&ssh, QString("showq"));
        QObject::connect (thread, SIGNAL(cmdSent(QStringList)), this, SLOT(onJobsReceived(QStringList)));
        thread->start();
    }
}

void Stats::onJobsReceived(QStringList outerr)
{
    QString showq;
    QStringList l, l2;
    QStringList::const_iterator constIterator;

    showq = outerr[0];

    this->clearJobListing();

    l = showq.split('\n');
    for (constIterator = l.constBegin(); constIterator != l.constEnd(); ++constIterator)
    {
        QString id,
                username,
                state,
                nbproc,
                remaining,
                starttime;

        l2 = (*constIterator).split(QRegExp("\\s+"));
        if (l2.count() == 9
            && l2[1] != "Active" && l2[1] != "of" && l2[1] != "Idle")
        {
            id = l2[0];
            username = l2[1];
            state = l2[2];
            nbproc = l2[3];
            remaining = l2[4];
            starttime = l2[5]+" "+l2[6]+" "+l2[7]+" "+l2[8];
            addJobEntry(id, username, state, nbproc, remaining, starttime);
        }
    }

    lAnim->clear();
}

---