Subversion Repositories heating

/*

 * Copyright (C) 2015 by Andreas Theofilu. All rights reserved!

 *

 * All rights reserved. No warranty, explicit or implicit, provided.

 *

 * NOTICE:  All information contained herein is, and remains

 * the property of Andreas Theofilu and his suppliers, if any.

 * The intellectual and technical concepts contained

 * herein are proprietary to Andreas Theofilu and its suppliers and

 * may be covered by European and Foreign Patents, patents in process,

 * and are protected by trade secret or copyright law.

 * Dissemination of this information or reproduction of this material

 * is strictly forbidden unless prior written permission is obtained

 * from Andreas Theofilu.

 * 

 * Author: Andreas Theofilu <andreas@theosys.at>

 */

#include <iostream>

#include <fstream>

#include <string>

#include <iomanip>

#include <cstring>

#include <cctype>

#include <cstddef>

#include <cstdio>

#include <cstdlib>

#include <ctime>

#include <fstream>

#include <cerrno>

#include <unistd.h>

#include <syslog.h>

#include <termios.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <fcntl.h>

#include "config.h"

#include "temperature.h"

using namespace std;

temperature::temperature()

{

struct termios options;

	initialized = false;

	fd_serial = -1;

	outPos = 0;

	outside = 0.0;

	stop = false;

	for (int i = 0; i < MAX_TEMPS; i++)

		allTemps[i] = 100.0;

	// Test if serial port is available.

	if (access(Configure.serial, R_OK | W_OK))

	{

		syslog(LOG_DAEMON, "Serial device <%s> is not accessible!", Configure.serial);

		return;

	}

	// open the serial port for reading and writing

	if ((fd_serial = open(Configure.serial, O_RDWR | O_NOCTTY | O_NDELAY)) == -1)

	{

		syslog(LOG_DAEMON, "Error opening serial device <%s>: %s", Configure.serial, strerror(errno));

		return;

	}

	tcgetattr(fd_serial, &options);

	cfsetispeed(&options, B9600);

	cfsetospeed(&options, B9600);

	tcsetattr(fd_serial, TCSANOW, &options);

	fcntl(fd_serial, F_SETFL, 0);

	initialized = true;

}

temperature::~temperature()

{

	if (fd_serial != -1)

		close(fd_serial);

	stop = true;

	sleep(1);

	fd_serial = -1;

	initialized = false;

}

void temperature::trun()

{

char buf[512], ch;

int r, pos;

	debug ("temperature::trun() reached!");

	if (!initialized)

		return;

	pos = 0;

	debug ("temperature::trun() is working!");

	while (!stop)

	{

		if ((r = read(fd_serial, &ch, 1)) <= 0)

		{

			if (r < 0)

				syslog(LOG_DAEMON, "Error reading serial device <%s>: %s", Configure.serial, strerror(errno));

			sleep(1);

			continue;

		}

		if (pos < (int)(sizeof(buf) - 1))

		{

			buf[pos] = ch;

			buf[pos+1] = 0;

			pos++;

			if (ch == 0x0d)

			{

				debug("Templogger: " + ToString(buf));

				if (strstr(buf, "Templog 2.5") != NULL)

				{

					ch = '1';

					write (fd_serial, &ch, 1);

				}

				else if (isdigit(buf[0]))

				{

					string temps = buf;

					vector<string> s = split(temps, ' ');

					if (outPos != 0 && outPos <= (int)s.size())

						outside = strtod(s.at(outPos - 1).c_str(), NULL);

					// save all temperatures

					for (int i = 0; i < (int)s.size(); i++)

						allTemps[i] = strtod(s.at(i).c_str(), NULL);

				}

				pos = 0;

			}

		}

	}

	stop = false;

}

double temperature::getTemp (int pos)

{

	if (pos && pos <= MAX_TEMPS)

		return allTemps[pos-1];

	return 100.0;

}