wmradio/fifo.c

   1 /*
   2  * Copyright (C) 12 Jun 2003 Tomas Cermak
   3  *
   4  * This file is part of wmradio program.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License as published by
   8  * the Free Software Foundation; either version 2 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  19  */
  20 #include "fifo.h"
  21 #include "wmradio.h"
  22 #include<stdio.h>
  23 #include <sys/types.h>
  24 #include <sys/stat.h>
  25 #include <fcntl.h>
  26 #include <string.h>
  27 #include <unistd.h>
  28 #include <stdlib.h>
  29 #include <time.h>
  30
  31 #define FIFO_FILE_PREFIX "/tmp/wmradio_"
  32 FILE *fifo;
  33
  34 #define MAX_STRINGS 40
  35 char *read_line(FILE *file)
  36 {
  37     char *str=(char *)malloc(MAX_STRINGS);
  38     int fin=0;
  39     int size=MAX_STRINGS;
  40     int retries;
  41     struct timespec pause = { 0, 100000000 };
  42
  43     if (fgets(str,MAX_STRINGS,file)==NULL)
  44     {
  45         free(str);
  46         return NULL;
  47     }
  48     for(retries=3; retries; retries--) {
  49         if(!fin) {
  50             fin=1;
  51             if (strchr(str,'\n')==NULL) {
  52                 char *tmp=(char *)malloc(size+MAX_STRINGS-1);
  53                 nanosleep(&pause, &pause);
  54                 strcpy(tmp,str);
  55                 fgets(tmp+size-1,MAX_STRINGS,file);
  56                 free(str);
  57                 str=tmp;
  58                 size+=MAX_STRINGS-1;
  59                 fin=0;
  60             }
  61         }
  62     }
  63     if(!fin) {
  64         free(str);
  65         return NULL;
  66     }
  67     return str;
  68 }
  69
  70 char * fifo_filename() {
  71     static char *name = NULL;
  72     char buffer[100];
  73
  74     if (name == NULL) {
  75         snprintf(buffer,sizeof(buffer),"%i",getuid());
  76         name = malloc(sizeof(char)*strlen(buffer)+
  77                       sizeof(FIFO_FILE_PREFIX)+1);
  78         sprintf(name, "%s%s", FIFO_FILE_PREFIX, buffer);
  79     }
  80     return name;
  81 }
  82
  83 void fifo_init() {
  84     int fifo_fd;
  85     mkfifo(fifo_filename(), 0666);
  86     fifo_fd = open(fifo_filename(), O_NONBLOCK | O_RDONLY);
  87     fifo = fdopen(fifo_fd, "r");
  88 }
  89
  90 void fifo_close() {
  91     fclose(fifo);
  92     unlink(fifo_filename());
  93 }
  94
  95 void fifo_parse () {
  96     char *line = read_line(fifo);
  97     char *command;
  98     char *rest=NULL;
  99
 100     if (line) {
 101         command=(char *)malloc(strlen(line)+1);
 102         sscanf(line,"%s",command);
 103         rest=line+strlen(command);
 104
 105         if (!strcasecmp(command,"TUNE_PLUS")) {
 106             wmradio_command(TUNE_PLUS, 0);
 107         }
 108         else if (!strcasecmp(command,"TUNE_MINUS"))
 109         {
 110             wmradio_command(TUNE_MINUS, 0);
 111         }
 112         if (!strcasecmp(command,"FINE_TUNE_PLUS")) {
 113             wmradio_command(TUNE_PLUS, 1);
 114         }
 115         else if (!strcasecmp(command,"FINE_TUNE_MINUS"))
 116         {
 117             wmradio_command(TUNE_MINUS, 1);
 118         }
 119         else if (!strcasecmp(command,"POWER"))
 120         {
 121             wmradio_command(POWER_SWITCH, 0);
 122         }
 123         else if (!strcasecmp(command,"SET_PRESET"))
 124         {
 125             int i;
 126             if (sscanf(rest,"%i",&i)==1) {
 127                 if (i>=0 && i<6)
 128                     wmradio_command(SET_PRESET, i);
 129             }
 130         }
 131         else if (!strcasecmp(command,"SAVE_PRESET"))
 132         {
 133             int i;
 134             if ((sscanf(rest,"%i",&i))==1) {
 135                 if (i>=0 && i<6)
 136                     wmradio_command(SAVE_PRESET, i);
 137             }
 138         }
 139         else if (!strcasecmp(command,"SCAN"))
 140         {
 141             wmradio_command(SCAN, 0);
 142         }
 143         else if (!strcasecmp(command,"TUNE_NAME_PREV"))
 144         {
 145             wmradio_command(TUNE_NAME_PREV, 0);
 146         }
 147         else if (!strcasecmp(command,"TUNE_NAME_NEXT"))
 148         {
 149             wmradio_command(TUNE_NAME_NEXT, 0);
 150         }
 151         else if (!strcasecmp(command,"READ_CONFIG"))
 152         {
 153             wmradio_command(READ_CONFIG, 0);
 154         }
 155         free(command);
 156         free(line);
 157     }
 158 }