ostinato/client/portwidget.cpp

/*
Copyright (C) 2010 Srivats P.

This file is part of "Ostinato"

This 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, either version 3 of the License, or
(at your option) any later version.

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.

You should have received a copy of the GNU General Public License
along with this program.  If not, see <http://www.gnu.org/licenses/>
*/

#include "portwidget.h"

#include "portgrouplist.h"
#include "xqlocale.h"

#include <cfloat>

PortWidget::PortWidget(QWidget *parent)
    : QWidget(parent)
{
    setupUi(this);
}

void PortWidget::setPortGroupList(PortGroupList *portGroups)
{
    plm = portGroups;

    connect(plm->getStreamModel(), SIGNAL(rowsInserted(QModelIndex, int, int)), 
        SLOT(updatePortActions()));
    connect(plm->getStreamModel(), SIGNAL(rowsRemoved(QModelIndex, int, int)), 
        SLOT(updatePortActions()));
    connect(plm->getStreamModel(), SIGNAL(modelReset()), 
        SLOT(updatePortActions()));

    updatePortActions();
}

PortWidget::~PortWidget()
{
}

void PortWidget::setCurrentPortIndex(const QModelIndex &currentIndex,
                                     const QModelIndex &previousIndex)
{
    if (!plm)
        return;

    qDebug("In %s", __PRETTY_FUNCTION__);

    // XXX: We assume indices corresponds to sourceModel, not proxyModel
    // - caller/sender should ensure this

    // Disconnect previous port
    if (plm->isPort(previousIndex))
        disconnect(&(plm->port(previousIndex)),
                SIGNAL(portRateChanged(int, int)),
                this, SLOT(updatePortRates()));

    if (!plm->isPort(currentIndex)) {
        currentPortIndex_ = QModelIndex(); // set to invalid
        return;
    }

    currentPortIndex_ = currentIndex;

    // Connect current port
    connect(&(plm->port(currentPortIndex_)),
            SIGNAL(portRateChanged(int, int)),
            this, SLOT(updatePortRates()));

    double speed = plm->port(currentPortIndex_).speed();
    portSpeed->setText(QString("Max %L1 Mbps").arg(speed));

    rbLoad->setVisible(speed > 0);
    averageLoadPercent->setVisible(speed > 0);
    speedSep->setVisible(speed > 0);
    portSpeed->setVisible(speed > 0);

    updatePortRates();
    updatePortActions();
}

void PortWidget::on_startTx_clicked()
{
    Q_ASSERT(plm->isPort(currentPortIndex_));

    QModelIndex curPortGroup = plm->getPortModel()->parent(currentPortIndex_);
    Q_ASSERT(curPortGroup.isValid());
    Q_ASSERT(plm->isPortGroup(curPortGroup));

    QList<uint> portList({plm->port(currentPortIndex_).id()});
    plm->portGroup(curPortGroup).startTx(&portList);
}

void PortWidget::on_stopTx_clicked()
{
    Q_ASSERT(plm->isPort(currentPortIndex_));

    QModelIndex curPortGroup = plm->getPortModel()->parent(currentPortIndex_);
    Q_ASSERT(curPortGroup.isValid());
    Q_ASSERT(plm->isPortGroup(curPortGroup));

    QList<uint> portList({plm->port(currentPortIndex_).id()});
    plm->portGroup(curPortGroup).stopTx(&portList);
}

void PortWidget::on_averageLoadPercent_editingFinished()
{
    Q_ASSERT(plm->isPort(currentPortIndex_));

    plm->port(currentPortIndex_).setAverageLoadRate(
            averageLoadPercent->value()/100);
}

void PortWidget::on_averagePacketsPerSec_editingFinished()
{
    Q_ASSERT(plm->isPort(currentPortIndex_));

    bool isOk;
    double pps = XLocale().toPacketsPerSecond(averagePacketsPerSec->text(),
                                              &isOk);

    if (isOk)
        plm->port(currentPortIndex_).setAveragePacketRate(pps);
    else
        updatePortRates();
}

void PortWidget::on_averageBitsPerSec_editingFinished()
{
    Q_ASSERT(plm->isPort(currentPortIndex_));

    bool isOk;
    double bps = XLocale().toBitsPerSecond(averageBitsPerSec->text(), &isOk);

    if (isOk)
        plm->port(currentPortIndex_).setAverageBitRate(bps);
    else
        updatePortRates();
}

void PortWidget::updatePortRates()
{
    if (!currentPortIndex_.isValid())
        return;

    if (!plm->isPort(currentPortIndex_))
        return;

    // XXX: pps/bps input widget is a LineEdit and not a SpinBox
    // because we want users to be able to enter values in various
    // units e.g. "1.5 Mbps", "1000K", "50" (bps) etc.

    // XXX: It's a considered decision NOT to show frame rate in
    // higher units of Kpps and Mpps as most users may not be
    // familiar with those and also we want frame rate to have a
    // high resolution for input e.g. if user enters 1,488,095.2381
    // it should NOT be shown as 1.4881 Mpps

    averagePacketsPerSec->setText(QString("%L1 pps")
            .arg(plm->port(currentPortIndex_).averagePacketRate(), 0, 'f', 4));

    averageBitsPerSec->setText(XLocale().toBitRateString(
                plm->port(currentPortIndex_).averageBitRate()));

    averageLoadPercent->setValue(
            plm->port(currentPortIndex_).averageLoadRate()*100);
}

void PortWidget::updatePortActions()
{
    if (!plm->isPort(currentPortIndex_))
        return;

    startTx->setEnabled(plm->port(currentPortIndex_).numStreams() > 0);
    stopTx->setEnabled(plm->port(currentPortIndex_).numStreams() > 0);
}