BoxStatsSample.h

Go to the documentation of this file.

#ifndef BOXSTATSSAMPLE_H
#define BOXSTATSSAMPLE_H

#include<vector>
#include<sstream>

using namespace std;

struct BoxStatsSample {
        BoxStatsSample(unsigned long tv_sec, 
                                   size_t tuplesConsumed,
                                   const vector<size_t> tuplesProduced) :
                _tv_sec(tv_sec),
                _tuplesConsumed(tuplesConsumed),
                _tuplesProduced(tuplesProduced)
        {
        }

        // This is intended to correspond to the timeval._tv_sec field that gets 
        // filled in by a call to gettimeofday(...).
        long _tv_sec;

        // The total number of tuples consumed, from all streams entering the
        // box, during this sample.
        size_t _tuplesConsumed;

        // For each output port, this gives the total number of tuples emitted
        // by this box during this sample.  Elements in this vector correspond
        // to elements in the QBox::_inq vector, on a per-index basis.
        vector<size_t> _tuplesProduced;

        string to_string() const {
                ostringstream os;
                os << "_tv_sec = " << _tv_sec << endl
                   << "_tuplesConsumed = " << _tuplesConsumed << endl;

                for (vector<size_t>::size_type i = 0; i < _tuplesProduced.size(); ++i) {
                        os << "_tuplesProduced[" << i << "] = " << _tuplesProduced[i] << endl;
                }

                return os.str();
        }
};

#endif

---