StreamRepresentation Class Reference

Public Member Functions
	StreamRepresentation (const aggregator::StreamStatus &status)
void	updateData (const aggregator::StreamStatus &status, const base::Time &time)
QVariant	data (int col, int role)

Static Public Member Functions
static QVariant	headerData (int col, int role)

Public Attributes
QVariant	name
QVariant	bufferStatusSize
QVariant	bufferStatusFill
QVariant	droppedFull
QVariant	droppedLate
QVariant	droppedOrdering
QVariant	sampleRate
std::deque< std::pair< base::Time, aggregator::StreamStatus > >	statusHistory

Detailed Description

Definition at line 17 of file StreamAlignerWidget.cpp.

Constructor & Destructor Documentation

StreamRepresentation::StreamRepresentation ( const aggregator::StreamStatus &  status )

inline

Definition at line 19 of file StreamAlignerWidget.cpp.

    {   
    name = QString::fromStdString(status.name);
    };

Member Function Documentation

QVariant StreamRepresentation::data ( int  col, int  role  )

inline

Definition at line 65 of file StreamAlignerWidget.cpp.

    {
    if(role == Qt::DisplayRole || col == 1) 
    {
        switch(col)
        {
        case 0:
            return name;
            break;
        case 1:
            if(role == BufferSize)
            return bufferStatusSize;
            if(role == BufferFill)
            return bufferStatusFill;
            break;
        case 2:
            return droppedFull;
            break;
        case 3:
            return droppedLate;
            break;
        case 4:
            return droppedOrdering;
            break;
        case 5:
            return sampleRate;
            break;
        }
    }   
    return QVariant();
    }

static QVariant StreamRepresentation::headerData ( int  col, int  role  )

inlinestatic

Definition at line 97 of file StreamAlignerWidget.cpp.

    {
    if(role == Qt::DisplayRole) 
    {
        switch(col)
        {
        case 0:
            return QString("Name");
            break;
        case 1:
            return QString("BufferStatus");
            break;
        case 2:
            return QString("Dropped Full");
            break;
        case 3:
            return QString("Dropped Late");
            break;
        case 4:
            return QString("Dropped Ordering");
            break;
        case 5:
            return QString("Samples/s Avg.(1/5/30)");
            break;
        }
    }   
    return QVariant();
    }

void StreamRepresentation::updateData ( const aggregator::StreamStatus &  status, const base::Time &  time  )

inline

Definition at line 24 of file StreamAlignerWidget.cpp.

    {
    bufferStatusSize = QVariant::fromValue<int>(status.buffer_size);
    bufferStatusFill = QVariant::fromValue<int>(status.buffer_fill);
    droppedFull= QString("%0").arg(status.samples_dropped_buffer_full);
    droppedLate= QString("%0").arg(status.samples_dropped_late_arriving);
    droppedOrdering= QString("%0").arg(status.samples_backward_in_time);

    // make sure the history buffer is of the desired size
    const size_t avg_size = 30;
    statusHistory.push_front( std::make_pair( time, status ) );
    while( statusHistory.size() > (avg_size+1) )
        statusHistory.pop_back();

    const size_t intervals[3] = {1,5,30};
    float avg_rate[3];
    for( int i=0; i<3; i++ )
    {
        float rate = std::numeric_limits<float>::quiet_NaN();
        const size_t idx = intervals[i];
        if( statusHistory.size() > idx )
        {
        long sample_diff = 
            statusHistory[idx].second.samples_received - 
            statusHistory.front().second.samples_received;

        base::Time time_diff =
            statusHistory[idx].first - 
            statusHistory.front().first;

        rate = (float)sample_diff / time_diff.toSeconds();
        }
        avg_rate[i] = rate;
    }

    sampleRate = QString("%0/%1/%2")
        .arg( avg_rate[0], 0, 'f', 1 )
        .arg( avg_rate[1], 0, 'f', 1 )
        .arg( avg_rate[2], 0, 'f', 1 );
    }

Member Data Documentation

QVariant StreamRepresentation::bufferStatusFill

Definition at line 128 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::bufferStatusSize

Definition at line 127 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::droppedFull

Definition at line 129 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::droppedLate

Definition at line 130 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::droppedOrdering

Definition at line 131 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::name

Definition at line 126 of file StreamAlignerWidget.cpp.

QVariant StreamRepresentation::sampleRate

Definition at line 132 of file StreamAlignerWidget.cpp.

std::deque<std::pair<base::Time, aggregator::StreamStatus> > StreamRepresentation::statusHistory

Definition at line 134 of file StreamAlignerWidget.cpp.

---

The documentation for this class was generated from the following file:

• /build/rock-master-18.09-gui-rock-widget-collection-0.20180124/src/stream_aligner_widget/StreamAlignerWidget.cpp