PerfSensorBase.h

/*
 * PerfSensorBase.h
 *
 *  Created on: 09.08.2018
 *      Author: Micha Mueller
 */

#ifndef PERFEVENT_PERFSENSORBASE_H_
#define PERFEVENT_PERFSENSORBASE_H_

#include "../../includes/SensorBase.h"
#include <limits.h>

class PerfSensorBase : public SensorBase {
public:
	static constexpr int64_t MAXCOUNTERVALUE = LLONG_MAX; //ToDo check if it is not LLONG_MAX, or make it configurable!

	PerfSensorBase(const std::string& name) :
		SensorBase(name),
		_type(0),
		_config(0),
		_lastRawPerf(0) {
	  //default delta to true, as perfevent has only monotonic sensors usually
	  _delta = true;
	}

	virtual ~PerfSensorBase() {}

	unsigned getType() 		const { return _type; }
	unsigned getConfig()	const { return _config; }

	void setType(unsigned type)		{ _type = type; }
	void setConfig(unsigned config)	{ _config = config;	}
	void setLastRaw(uint64_t raw)   { _lastRawPerf = raw; }

	void storeReading(uint64_t value, uint64_t timestamp, double factor=1.0, unsigned long long maxValue=ULLONG_MAX) {
        _latestValue.timestamp = timestamp;
        if( _delta ) {
            if (value < _lastRawPerf)
                _latestValue.value = (value + (maxValue - _lastRawPerf)) * factor;
            else
                _latestValue.value = (value - _lastRawPerf) * factor;
            _lastRawPerf = value;
        }
        else
            _latestValue.value = value * factor;

		if (!(_skipConstVal && (_latestValue.value == _lastSentValue.value)) && _subsamplingIndex++ % _subsamplingFactor == 0) {
			_readingQueue->push(_latestValue);
			_lastSentValue = _latestValue;
		}
		if (_sinkFile) {
			_sinkFile->seekp(0, std::ios::beg);
			*_sinkFile << _latestValue.value;
		}

        _readingQueue->push(_latestValue);
        _cache[_cacheIndex] = _latestValue;
        _cacheIndex = (_cacheIndex + 1) % _cacheSize;
    }

protected:
	unsigned int _type;
	unsigned int _config;
	uint64_t     _lastRawPerf;
};

using PerfSBPtr = std::shared_ptr<PerfSensorBase>;

#endif /* PERFEVENT_PERFSENSORBASE_H_ */