Finished the conversion to C.
[breezed.git] / breezed.c
1
2 /*
3
4    breezed is a fan speed control daemon for Linux computers.
5
6    Copyright (c) 2008, 2009 Francois Fleuret
7    Written by Francois Fleuret <francois@fleuret.org>
8
9    This file is part of breezed.
10
11    breezed is free software: you can redistribute it and/or modify it
12    under the terms of the GNU General Public License version 3 as
13    published by the Free Software Foundation.
14
15    breezed is distributed in the hope that it will be useful, but
16    WITHOUT ANY WARRANTY; without even the implied warranty of
17    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
18    General Public License for more details.
19
20    You should have received a copy of the GNU General Public License
21    along with breezed.  If not, see <http://www.gnu.org/licenses/>.
22
23 */
24
25 #include <stdio.h>
26 #include <stdlib.h>
27 #include <fcntl.h>
28 #include <errno.h>
29 #include <unistd.h>
30 #include <string.h>
31
32 const int major_version_number = 1;
33 const int minor_version_number = 2;
34
35 const int buffer_size = 1024;
36
37 const char *default_configuration_file = "/etc/breezed.conf";
38
39 /* The time period to check the temperature. */
40 const int polling_delay = 5;
41
42 /* Minimum time between last change and a change down. */
43 const int minimum_delay_to_go_down = 30;
44
45 /* Gap between a threshold to go up and a threshold to go down to
46    reduce the oscillations. */
47 const int down_temperature_delta = 2;
48
49 char *file_fan = 0;
50
51 int debug = 0;
52 int nb_rounds_since_last_change = 0;
53 int last_level = -1;
54
55 int file_fan_fd;
56
57 int nb_temperature_thresholds;
58 int *temperature_thresholds = 0;
59
60 int nb_file_thermal = 0;
61 char **file_thermal = 0;
62 int *file_thermal_fd = 0;
63
64 char *configuration_file;
65
66 /******************************************************************/
67
68 char *next_word(char *buffer, char *r, int buffer_size) {
69   char *s;
70   s = buffer;
71
72   if(r != 0) {
73     while((*r == ' ') || (*r == '\t') || (*r == ',')) r++;
74     if(*r == '"') {
75       r++;
76       while((*r != '"') && (*r != '\0') &&
77             (s<buffer+buffer_size-1))
78         *s++ = *r++;
79       if(*r == '"') r++;
80     } else {
81       while((*r != '\r') && (*r != '\n') && (*r != '\0') &&
82             (*r != '\t') && (*r != ' ') && (*r != ',')) {
83         if(s == buffer + buffer_size) {
84           fprintf(stderr, "Buffer overflow in next_word.\n");
85           exit(1);
86         }
87         *s++ = *r++;
88       }
89     }
90
91     while((*r == ' ') || (*r == '\t') || (*r == ',')) r++;
92     if((*r == '\0') || (*r=='\r') || (*r=='\n')) r = 0;
93   }
94   *s = '\0';
95
96   return r;
97 }
98
99 void set_fan_level(int fan_fd, int f, int max_fan_level) {
100   char buffer[buffer_size];
101   if(f < 0 || f > max_fan_level) f = max_fan_level;
102   sprintf(buffer, "level %d\n", f);
103   if(write(fan_fd, buffer, strlen(buffer)) < 0) {
104     fprintf(stderr, "Error in setting the fan level (%s).\n",
105             strerror(errno));
106     exit(1);
107   }
108 }
109
110 void define_thermal_files(char *definition) {
111   char token[buffer_size];
112
113   if(file_thermal) {
114     fprintf(stderr, "Thermal files already defined.\n");
115     exit(1);
116   }
117
118   char *s;
119   s = definition;
120   while(s) {
121     s = next_word(token, s, buffer_size);
122     nb_file_thermal++;
123   }
124
125   file_thermal = (char **) malloc(nb_file_thermal * sizeof(char *));
126   file_thermal_fd = (int *) malloc(nb_file_thermal * sizeof(int));
127   s = definition;
128   int k = 0;
129   while(s) {
130     s = next_word(token, s, buffer_size);
131     file_thermal[k] = strdup(token);
132     k++;
133   }
134 }
135
136 void define_temperature_thresholds(char *definition) {
137   char token[buffer_size];
138
139   if(temperature_thresholds) {
140     fprintf(stderr, "Temperature thresholds already defined.\n");
141     exit(1);
142   }
143
144   nb_temperature_thresholds = 1;
145
146   char *s;
147   s = definition;
148   while(s) {
149     s = next_word(token, s, buffer_size);
150     nb_temperature_thresholds++;
151   }
152
153   temperature_thresholds =
154     (int *) malloc(nb_temperature_thresholds * sizeof(int));
155
156   temperature_thresholds[0] = -1;
157
158   s = definition;
159   int k = 1;
160   while(s) {
161     s = next_word(token, s, buffer_size);
162     temperature_thresholds[k] = atoi(token);
163     if(k > 0 &&
164        temperature_thresholds[k] < temperature_thresholds[k-1]) {
165       fprintf(stderr, "The temperature thresholds have to be increasing.\n");
166       exit(0);
167     }
168     k++;
169   }
170 }
171
172 void evaluate_one_configuration_line(char *line, int line_number) {
173   char token[buffer_size];
174   char *s;
175
176   s = next_word(token, line, buffer_size);
177
178   if(strcmp(token, "thermal_files") == 0) {
179     if(s == 0) {
180       fprintf(stderr, "Missing parameter in %s:%d\n",
181               configuration_file, line_number);
182       exit(1);
183     }
184     define_thermal_files(s);
185   }
186
187   else if(strcmp(token, "debug") == 0) {
188     debug = 1;
189   }
190
191   else if(strcmp(token, "fan_file") == 0) {
192     if(file_fan) {
193       fprintf(stderr, "Fan file already defined.\n");
194       exit(1);
195     }
196     if(s == 0) {
197       fprintf(stderr, "Missing parameter in %s:%d\n",
198               configuration_file, line_number);
199       exit(1);
200     }
201     file_fan = strdup(s);
202   }
203
204   else if(strcmp(token, "temperature_thresholds") == 0) {
205     if(s == 0) {
206       fprintf(stderr, "Missing parameter in %s:%d\n",
207               configuration_file, line_number);
208       exit(1);
209     }
210     define_temperature_thresholds(s);
211   }
212
213   else if(token[0] && token[0] != '#') {
214     fprintf(stderr, "Unknown keyword '%s' in %s:%d.\n",
215             token, configuration_file, line_number);
216     exit(1);
217   }
218 }
219
220 /******************************************************************/
221
222 int main(int argc, char **argv) {
223   char buffer[buffer_size];
224   int i, t;
225
226   configuration_file = strdup(default_configuration_file);
227
228   i = 1;
229   while(i < argc) {
230
231     if(strcmp(argv[i], "--debug") == 0 || strcmp(argv[i], "-d") == 0) {
232       debug = 1;
233       i++;
234     }
235
236     else if(strcmp(argv[i], "--version") == 0 || strcmp(argv[i], "-v") == 0) {
237       printf("Breezed v%d.%d. Written by Francois Fleuret (francois@fleuret.org).\n",
238              major_version_number, minor_version_number);
239       exit(0);
240     }
241
242     else if(strcmp(argv[i], "--no-configuration-file") == 0 ||
243             strcmp(argv[i], "-ncf") == 0) {
244       free(configuration_file);
245       configuration_file = 0;
246       i++;
247     }
248
249     else if(strcmp(argv[i], "--configuration-file") == 0 ||
250             strcmp(argv[i], "-cf") == 0) {
251       i++;
252       if(i == argc) {
253         fprintf(stderr, "Missing parameter for %s.\n", argv[i - 1]);
254         exit(1);
255       }
256
257       free(configuration_file);
258       configuration_file = strdup(argv[i]);
259
260       i++;
261     }
262
263     else if(strcmp(argv[i], "--thermal-files") == 0 ||
264             strcmp(argv[i], "-tf") == 0) {
265       i++;
266       if(i == argc) {
267         fprintf(stderr, "Missing parameter for %s.\n", argv[i - 1]);
268         exit(1);
269       }
270       define_thermal_files(argv[i]);
271       i++;
272     }
273
274     else if(strcmp(argv[i], "--fan-file") == 0 ||
275             strcmp(argv[i], "-ff") == 0) {
276       i++;
277       if(i == argc) {
278         fprintf(stderr, "Missing parameter for %s.\n", argv[i - 1]);
279         exit(1);
280       }
281
282       if(file_fan) {
283         fprintf(stderr, "Fan file already defined.\n");
284         exit(1);
285       }
286       file_fan = strdup(argv[i]);
287
288       i++;
289     }
290
291     else if(strcmp(argv[i], "--temperature-thresholds") == 0 ||
292             strcmp(argv[i], "-tt") == 0) {
293       i++;
294
295       if(i == argc) {
296         fprintf(stderr, "Missing parameter for %s.\n", argv[i - 1]);
297         exit(1);
298       }
299
300       define_temperature_thresholds(argv[i]);
301       i++;
302     }
303
304     else if(strcmp(argv[i], "--help") == 0 || strcmp(argv[i], "-h") == 0) {
305
306       printf("%s [--version|-v] [--help|-h] [--debug|-d]\\\n\
307   [--configuration-file|-cf <file>]\\\n\
308   [--no-configuration-file|-ncf]\\\n\
309   [--thermal-files|-tf <thermalfile1,thermalfile2,...>] \\\n\
310   [--fanfile|-ff <fan file>] \\\n\
311   [--temperature-thresholds|-tt <t1,t2,t3,t4,...>]\n\
312 \n\
313   --help|-h :                    shows this help\n\
314   --version|-v :                 shows the version number\n\
315   --debug|-d :                   prints out additional information\n\
316   --configuration-file|-cf       sets the configuration file\n\
317   --no-configuration-file|-ncf   do not load a configuration file\n\
318   --thermal-files|-tf :          sets where to look for temperatures\n\
319   --fanfile|-ff :                sets where to control the fan level\n\
320   --temperature-thresholds|-tt : sets the temperature thresholds\n\
321 \n\
322 This daemon polls the temperatures every 5s, takes the max and sets\n\
323 the fan level accordingly. It uses as temperatures all the numbers it\n\
324 finds in the provided \"thermal files\". Hence you can use as well\n\
325 /proc/acpi/thermal_zone/THM*/temperature or /proc/acpi/ibm/thermal.\n\
326 \n\
327 The fan speed is set by echoing into the provided fan file.\n\
328 \n\
329 To reduce oscillations, it will not reduce the fan speed less than 30s\n\
330 after the last previous change and the thresholds actually used to\n\
331 reduce the fan speed are two degrees lower than the provided\n\
332 thresholds, which are used to increase the fan speed.\n\
333 \n\
334 This daemon should be started through the adequate shell script in\n\
335 /etc/init.d.\n\
336 \n\
337 Options can be set either in the configuration file, or on the \n\
338 command line. Options can not be set twice.\n\
339 \n\
340 Version %d.%d, November 2009.\n\
341 \n\
342 Written by Francois Fleuret (francois@fleuret.org).\n",
343              argv[0],
344              major_version_number, minor_version_number);
345
346       exit(0);
347     }
348
349     else {
350       fprintf(stderr, "Unknown argument %s.\n", argv[i]);
351       exit(1);
352     }
353   }
354
355
356   /******************************************************************/
357
358   if(configuration_file) {
359     char raw_line[buffer_size];
360     int start, end, eol, k;
361     FILE *file;
362
363     file = fopen(configuration_file, "r");
364
365     if(!file) {
366       fprintf(stderr, "Can not open `%s' for reading.\n", configuration_file);
367       exit(1);
368     }
369
370     start = 0;
371     end = 0;
372
373     char *s;
374
375     int line_number = 0;
376
377     while(end > start || !feof(file)) {
378       eol = start;
379
380       /* Look for the end of a line in what is already in the buffer */
381       while(eol < end && raw_line[eol] != '\n') eol++;
382
383       /* if we did not find the of a line, move what has not been
384          processed and is in the buffer to the beginning of the buffer,
385          fill the buffer with new data from the file, and look for the
386          end of a line */
387       if(eol == end) {
388         for(k = 0; k < end - start; k++) {
389           raw_line[k] = raw_line[k + start];
390         }
391         end -= start;
392         eol -= start;
393         start = 0;
394         end += fread(raw_line + end, sizeof(char), buffer_size - end, file);
395         while(eol < end && raw_line[eol] != '\n') eol++;
396       }
397
398       /* The end of the line is the buffer size, which means the line is
399          too long */
400
401       if(eol == buffer_size) {
402         raw_line[buffer_size - 1] = '\0';
403         fprintf(stderr, "Selector: Line too long (max is %d characters):\n",
404                 buffer_size);
405         fprintf(stderr, raw_line);
406         fprintf(stderr, "\n");
407         exit(1);
408       }
409
410       /* If we got a line, we replace the carriage return by a \0 to
411          finish the string */
412
413       raw_line[eol] = '\0';
414
415       /* here we process the line */
416
417       line_number++;
418
419       if(debug) {
420         printf("%s:%d \"%s\"\n",
421                configuration_file, line_number, raw_line + start);
422       }
423
424       evaluate_one_configuration_line(raw_line + start, line_number);
425
426       start = eol + 1;
427     }
428
429   }
430
431   /******************************************************************/
432
433   if(nb_temperature_thresholds == 0) {
434     fprintf(stderr, "No temperature threshold was provided.\n");
435     exit(1);
436   }
437
438   if(nb_file_thermal == 0) {
439     fprintf(stderr, "No thermal file was provided.\n");
440     exit(1);
441   }
442
443   if(file_fan == 0){
444     fprintf(stderr, "No fan file was provided.\n");
445     exit(1);
446   }
447
448   for(i = 0; i < nb_file_thermal; i++) {
449     file_thermal_fd[i] = open(file_thermal[i], O_RDONLY);
450     if(file_thermal_fd[i] < 0) {
451       fprintf(stderr, "Can not open %s for reading (%s).\n",
452               file_thermal[i], strerror(errno));
453       exit(1);
454     }
455   }
456
457   file_fan_fd = open(file_fan, O_WRONLY);
458
459   if(file_fan_fd < 0) {
460     fprintf(stderr, "Can not open %s for writing (%s).\n",
461             file_fan, strerror(errno));
462     exit(1);
463   }
464
465   /******************************************************************/
466
467   if(debug) {
468     for(t = 0; t < nb_file_thermal; t++) {
469       printf("file_thermal[%d] %s\n", t, file_thermal[t]);
470     }
471
472     printf("file_fan %s\n", file_fan);
473
474     for(t = 0; t < nb_temperature_thresholds; t++) {
475       printf("temperature_thresholds[%d] %d",
476              t, temperature_thresholds[t]);
477     }
478   }
479
480   /******************************************************************/
481
482   while(1) {
483
484     int temperature = -1;
485
486     if(debug) {
487       printf("Temperature:");
488     }
489
490     for(i = 0; i < nb_file_thermal; i++) {
491       lseek(file_thermal_fd[i], 0, SEEK_SET);
492       int size = read(file_thermal_fd[i], buffer, buffer_size);
493
494       if(size > 0 && size < buffer_size) {
495         buffer[size] = '\0';
496
497         char *s = buffer;
498
499         while(*s) {
500           while(*s && *s != '-' && (*s < '0') || (*s > '9')) s++;
501
502           if(*s) {
503             int t = 0, sign = 1;
504             if(*s == '-') {
505               sign = -1;
506               s++;
507             }
508
509             while(*s >= '0' && *s <= '9') {
510               t = t * 10 + (*s - '0');
511               s++;
512             }
513
514             t *= sign;
515             if(debug) {
516               printf(" %d", t);
517             }
518
519             /* So that we can deal with the new files where the
520                temperature are in 1/1000th of C */
521             if(t > 1000) t /= 1000;
522
523             if(t > temperature) temperature = t;
524           }
525         }
526
527         if(debug) {
528           if(i < nb_file_thermal - 1)
529             printf(" /");
530           else
531             printf("\n");
532         }
533       } else {
534         if(size == 0) {
535           fprintf(stderr, "Nothing to read in %d.\n", file_thermal[i]);
536         } else if(size < 0) {
537           fprintf(stderr, "Error while reading %s (%s).\n",
538                   file_thermal[i], strerror(errno));
539         } else {
540           fprintf(stderr, "Error while reading %s (too large).\n",
541                   file_thermal[i]);
542         }
543         exit(1);
544       }
545     }
546
547     if(temperature < 0) {
548       fprintf(stderr, "Could not read a meaningful temperature.\n");
549       exit(1);
550     }
551
552     nb_rounds_since_last_change++;
553
554     int new_level = last_level;
555
556     int new_level_up = nb_temperature_thresholds - 1;
557     while(new_level_up > 0 &&
558           temperature < temperature_thresholds[new_level_up]) {
559       new_level_up--;
560     }
561
562     if(new_level_up > last_level) {
563       new_level = new_level_up;
564     } else {
565       int new_level_down = nb_temperature_thresholds - 1;
566       while(new_level_down > 0 &&
567             temperature <
568             temperature_thresholds[new_level_down] - down_temperature_delta)
569         new_level_down--;
570       if(new_level_down < last_level &&
571          nb_rounds_since_last_change * polling_delay >=
572          minimum_delay_to_go_down) {
573         new_level = new_level_down;
574       }
575     }
576
577     /* We set it every time, even when there is no change, to handle
578        when the level has been modified somewhere else (for instance
579        when combing back from suspend). */
580
581     set_fan_level(file_fan_fd, new_level, nb_temperature_thresholds - 1);
582
583     if(new_level != last_level) {
584       nb_rounds_since_last_change = 0;
585       last_level = new_level;
586       if(debug) {
587         printf("Temperature is %dC setting the fan level to %d.",
588                temperature, new_level);
589       }
590     }
591
592     sleep(polling_delay);
593   }
594 }