PDUSensor.cpp

/*
 * PDUSensor.cpp
 *
 *  Created on: 24.02.2018
 *      Author: Micha Mueller
 */

#include "PDUSensor.h"
#include "timestamp.h"
#include <string>

PDUSensor::PDUSensor(const std::string& name) :
	Sensor(name) {
	_pdu = NULL;
}

PDUSensor::~PDUSensor() {
	// TODO Auto-generated destructor stub
}

void PDUSensor::read() {
	reading_t reading;
	reading.timestamp = getTimestamp();

	try {
		reading.value = _pdu->readValue(_xmlPath);
		_readingQueue->push(reading);
		_latestValue.value		= reading.value;
		_latestValue.timestamp	= reading.timestamp;
#ifdef DEBUG
		LOG(debug) << _pdu->getHost() << "::" << _name << ": \"" << reading.value << "\"";
#endif
	} catch (const std::exception& e) {
		LOG(error) << _pdu->getHost() << "::" << _name << " could not read value: " << e.what();
	}
}

void PDUSensor::readAsync() {
	uint64_t now = getTimestamp();
	read();
	if (_timer != NULL && _keepRunning) {
		uint64_t next = now + MS_TO_NS(_interval);
		_timer->expires_at(timestamp2ptime(next));
		_timer->async_wait(_pdu->getStrand()->wrap(std::bind(&PDUSensor::readAsync, this)));
	}
}

void PDUSensor::init(boost::asio::io_service& io) {
	if(_pdu) {
		_pdu->initializeStrand(io);
	} else {
		LOG(error) << "No PDUUnit set for sensor " << _name << "! Cannot initialize sensor.";
	}
	Sensor::init(io);
}

void PDUSensor::startPolling() {
	if (_pdu) {
		_keepRunning = 1;
		_timer->async_wait(_pdu->getStrand()->wrap(std::bind(&PDUSensor::readAsync, this)));
		LOG(info) << "Sensor " << _name << " started.";
	} else {
		LOG(error) << "No PDUUnit set for sensor " << _name << "! Cannot start polling.";
	}
}

void PDUSensor::stopPolling() {
	_keepRunning = 0;
	//cancel any outstanding readAsync()
	_timer->cancel();
	LOG(info) << "Sensor " << _name << " stopped.";
}