thermferm/units.c

Sun, 13 Jul 2014 17:31:45 +0200

author
Michiel Broek <mbroek@mbse.eu>
date
Sun, 13 Jul 2014 17:31:45 +0200
changeset 106
1bd9a16f5061
parent 101
1302abe92eb1
child 164
f16def8472ba
permissions
-rw-r--r--

Added .h files

93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
1 /*****************************************************************************
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
2 * Copyright (C) 2014
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
3 *
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
4 * Michiel Broek <mbroek at mbse dot eu>
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
5 *
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
6 * This file is part of the mbsePi-apps
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
7 *
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
8 * This is free software; you can redistribute it and/or modify it
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
9 * under the terms of the GNU General Public License as published by the
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
10 * Free Software Foundation; either version 2, or (at your option) any
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
11 * later version.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
12 *
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
13 * mbsePi-apps is distributed in the hope that it will be useful, but
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
14 * WITHOUT ANY WARRANTY; without even the implied warranty of
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
16 * General Public License for more details.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
17 *
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
18 * You should have received a copy of the GNU General Public License
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
19 * along with EC-65K; see the file COPYING. If not, write to the Free
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
20 * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
21 *****************************************************************************/
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
22
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
23 #include "thermferm.h"
106
1bd9a16f5061 Added .h files
Michiel Broek <mbroek@mbse.eu>
parents: 101
diff changeset
24 #include "units.h"
1bd9a16f5061 Added .h files
Michiel Broek <mbroek@mbse.eu>
parents: 101
diff changeset
25 #include "xutil.h"
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
26
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
27
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
28 extern int debug;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
29 extern sys_config Config;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
30 extern int my_shutdown;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
31
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
32 extern const char UNITMODE[5][8];
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
33
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
34
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
35
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
36 int read_w1_28(char *address, int *val)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
37 {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
38 char *device, line[60], *p = NULL;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
39 FILE *fp;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
40 int rc = 0;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
41
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
42 device = xstrcpy((char *)"/sys/bus/w1/devices/");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
43 device = xstrcat(device, address);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
44 device = xstrcat(device, (char *)"/w1_slave");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
45
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
46 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
47 * Read sensor data
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
48 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
49 if ((fp = fopen(device, "r"))) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
50 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
51 * The output looks like:
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
52 * 72 01 4b 46 7f ff 0e 10 57 : crc=57 YES
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
53 * 72 01 4b 46 7f ff 0e 10 57 t=23125
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
54 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
55 fgets(line, 50, fp);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
56 line[strlen(line)-1] = '\0';
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
57 if ((line[36] == 'Y') && (line[37] == 'E')) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
58 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
59 * CRC is Ok, continue
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
60 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
61 fgets(line, 50, fp);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
62 line[strlen(line)-1] = '\0';
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
63 strtok(line, (char *)"=");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
64 p = strtok(NULL, (char *)"=");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
65 rc = sscanf(p, "%d", val);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
66 if (rc != 1) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
67 syslog(LOG_NOTICE, "sensor %s data parse error", address);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
68 rc = 3;
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
69 } else {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
70 rc = 0;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
71 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
72 } else {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
73 syslog(LOG_NOTICE, "sensor %s CRC error", address);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
74 rc = 1;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
75 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
76 fclose(fp);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
77 } else {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
78 syslog(LOG_NOTICE, "sensor %s is missing", address);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
79 rc = 2;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
80 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
81
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
82 free(device);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
83 device = NULL;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
84
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
85 return rc;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
86 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
87
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
88
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
89
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
90 #ifdef HAVE_WIRINGPI_H
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
91 PI_THREAD (my_units_loop)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
92 #else
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
93 void *my_units_loop(void *threadid)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
94 #endif
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
95 {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
96 units_list *unit;
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
97 int rc, temp, deviation;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
98
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
99 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
100 * Initialize units for processing
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
101 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
102 for (unit = Config.units; unit; unit = unit->next) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
103 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
104 * Safety, turn everything off
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
105 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
106 unit->heater_state = unit->cooler_state = unit->fan_state = unit->door_state = 0;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
107 if (unit->profile && (int)unit->prof_started && (unit->mode == UNITMODE_PROFILE)) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
108 syslog(LOG_NOTICE, "Starting unit %s profile %s", unit->name, unit->profile);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
109 } else if (unit->mode == UNITMODE_BEER) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
110 syslog(LOG_NOTICE, "Starting unit %s beer cooler at %.1f degrees", unit->name, unit->beer_set);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
111 } else if (unit->mode == UNITMODE_FRIDGE) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
112 syslog(LOG_NOTICE, "Starting unit %s as refridgerator at %.1f degrees", unit->name, unit->fridge_set);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
113 } else if (unit->mode == UNITMODE_NONE) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
114 syslog(LOG_NOTICE, "Starting unit %s in inactive state", unit->name);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
115 } else {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
116 syslog(LOG_NOTICE, "Starting unit %s in off state", unit->name);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
117 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
118 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
119
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
120 syslog(LOG_NOTICE, "Thread my_units_loop started");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
121 if (debug)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
122 fprintf(stdout, "Thread my_units_loop started\n");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
123
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
124 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
125 * Loop forever until the external shutdown variable is set.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
126 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
127 for (;;) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
128
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
129 if (my_shutdown)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
130 break;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
131
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
132 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
133 * Update the state of all fermenter units
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
134 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
135 for (unit = Config.units; unit; unit = unit->next) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
136
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
137 if (my_shutdown)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
138 break;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
139
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
140 if (unit->air_address) {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
141 rc = read_w1_28(unit->air_address, &temp);
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
142 if (rc == 0) {
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
143 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
144 * It is possible to have read errors or extreme values.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
145 * This can happen with bad connections so we compare the
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
146 * value with the previous one. If the difference is too
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
147 * much, we don't send that value. That also means that if
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
148 * the next value is ok again, it will be marked invalid too.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
149 * Maximum error is 20 degrees for now.
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
150 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
151 deviation = 20000;
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
152 if ((unit->air_temperature == 0) ||
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
153 (unit->air_temperature && (temp > (int)unit->air_temperature - deviation) && (temp < ((int)unit->air_temperature + deviation)))) {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
154 unit->air_temperature = temp;
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
155 unit->air_state = 0;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
156 } else {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
157 syslog(LOG_NOTICE, "deviation error deviation=%d, old=%d new=%d", deviation, unit->air_temperature, temp);
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
158 if (debug) {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
159 fprintf(stdout, "deviation error deviation=%d, old=%d new=%d\n", deviation, unit->air_temperature, temp);
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
160 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
161 }
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
162 } else if (rc == 2) {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
163 unit->air_state = 1;
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
164 } else {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
165 unit->air_state = 2;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
166 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
167 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
168 if (my_shutdown)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
169 break;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
170
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
171 if (unit->beer_address) {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
172 rc = read_w1_28(unit->beer_address, &temp);
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
173 if (rc == 0) {
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
174 deviation = 20000;
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
175 if ((unit->beer_temperature == 0) ||
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
176 (unit->beer_temperature && (temp > (int)unit->beer_temperature - deviation) && (temp < ((int)unit->beer_temperature + deviation)))) {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
177 unit->beer_temperature = temp;
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
178 unit->beer_state = 0;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
179 } else {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
180 syslog(LOG_NOTICE, "deviation error deviation=%d, old=%d new=%d", deviation, unit->beer_temperature, temp);
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
181 if (debug) {
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
182 fprintf(stdout, "deviation error deviation=%d, old=%d new=%d\n", deviation, unit->beer_temperature, temp);
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
183 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
184 }
101
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
185 } else if (rc == 2) {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
186 unit->beer_state = 1;
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
187 } else {
1302abe92eb1 Made temperature sensors working in the units
Michiel Broek <mbroek@mbse.eu>
parents: 93
diff changeset
188 unit->beer_state = 2;
93
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
189 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
190 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
191 if (my_shutdown)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
192 break;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
193
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
194
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
195 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
196 usleep(10000);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
197 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
198
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
199 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
200 * Stop units processing in a neat way
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
201 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
202 for (unit = Config.units; unit; unit = unit->next) {
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
203 /*
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
204 * Turn everything off
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
205 */
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
206 unit->heater_state = unit->cooler_state = unit->fan_state = unit->door_state = 0;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
207 syslog(LOG_NOTICE, "Stopped unit %s mode %s", unit->name, UNITMODE[unit->mode]);
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
208 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
209
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
210 syslog(LOG_NOTICE, "Thread my_units_loop stopped");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
211 if (debug)
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
212 fprintf(stdout, "Thread my_units_loop stopped\n");
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
213 return 0;
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
214 }
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
215
b759f814469d Added units processing thread
Michiel Broek <mbroek@mbse.eu>
parents:
diff changeset
216

mercurial