PDUSensor.cpp

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

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

extern volatile int keepRunning;

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::startPolling(boost::asio::io_service& io) {
	if(!_readingQueue) {
		_readingQueue = new boost::lockfree::spsc_queue<reading_t>(1024);
	}
	if (_pdu) {
		_pdu->initializeStrand(io);
		_timer = new boost::asio::deadline_timer(io, boost::posix_time::seconds(0));
		_timer->async_wait(_pdu->getStrand()->wrap(std::bind(&PDUSensor::readAsync, this)));
	} else {
		LOG(error) << "No PDUUnit set for sensor " << _name << "! Cannot start polling.";
	}
}