| 1 | #include <sys/types.h> | 
|---|
| 2 | #include <sys/stat.h> | 
|---|
| 3 | #include <sys/time.h> | 
|---|
| 4 | #include <fcntl.h> | 
|---|
| 5 | #include <termios.h> | 
|---|
| 6 | #include <stdio.h> | 
|---|
| 7 | #include <time.h> | 
|---|
| 8 | #include <stdlib.h> | 
|---|
| 9 | #include <string.h> | 
|---|
| 10 | #include <unistd.h> | 
|---|
| 11 | #include <sys/select.h> | 
|---|
| 12 |  | 
|---|
| 13 | #define bzero(b,len) (memset((b), '\0' ,(len)), (void) 0) | 
|---|
| 14 |  | 
|---|
| 15 | /* baudrate settings are defined in <asm/termbits.h>, which is | 
|---|
| 16 | included by <termios.h> */ | 
|---|
| 17 | //      #define BAUDRATE B9600  // Baudrate of ATmega on Arduino board | 
|---|
| 18 | #define BAUDRATE B38400 //Baudrate of ATmega on Pt100-Logger | 
|---|
| 19 |  | 
|---|
| 20 | /* change this definition for the correct port */ | 
|---|
| 21 | //        #define MODEMDEVICE "/dev/myArduino" //Addess of Arduino device | 
|---|
| 22 | #define MODEMDEVICE "/dev/FTE33RWR"  //Address of Pt100 Logger | 
|---|
| 23 |  | 
|---|
| 24 | #define _POSIX_SOURCE 1 /* POSIX compliant source */ | 
|---|
| 25 |  | 
|---|
| 26 | #define FALSE 0 | 
|---|
| 27 | #define TRUE 1 | 
|---|
| 28 |  | 
|---|
| 29 | #define myPath "/ct3data/SlowData/" //   will be used later on | 
|---|
| 30 | //#define myPath "" // for testing purposes | 
|---|
| 31 |  | 
|---|
| 32 |  | 
|---|
| 33 | FILE * openOutfile(char *path); | 
|---|
| 34 | static int poll_stdin_time(int microsekunden) ; | 
|---|
| 35 |  | 
|---|
| 36 | volatile int STOP=FALSE; | 
|---|
| 37 |  | 
|---|
| 38 | int main(int argc, char *argv[]) | 
|---|
| 39 | { | 
|---|
| 40 | int fd, res; | 
|---|
| 41 | struct termios oldtio,newtio; | 
|---|
| 42 | char buf[255]; | 
|---|
| 43 | char dummy[255]; | 
|---|
| 44 |  | 
|---|
| 45 | /* | 
|---|
| 46 | Open modem device for reading and writing and not as controlling tty | 
|---|
| 47 | because we don't want to get killed if linenoise sends CTRL-C. | 
|---|
| 48 | */ | 
|---|
| 49 | fd = open(MODEMDEVICE, O_RDWR | O_NOCTTY ); | 
|---|
| 50 | if (fd <0) {perror(MODEMDEVICE); exit(-1); } | 
|---|
| 51 |  | 
|---|
| 52 | tcgetattr(fd,&oldtio); /* save current serial port settings */ | 
|---|
| 53 | bzero(&newtio, sizeof(newtio)); /* clear struct for new port settings */ | 
|---|
| 54 |  | 
|---|
| 55 | /* | 
|---|
| 56 | BAUDRATE: Set bps rate. You could also use cfsetispeed and cfsetospeed. | 
|---|
| 57 | CRTSCTS : output hardware flow control (only used if the cable has | 
|---|
| 58 | all necessary lines. See sect. 7 of Serial-HOWTO) | 
|---|
| 59 | CS8     : 8n1 (8bit,no parity,1 stopbit) | 
|---|
| 60 | CLOCAL  : local connection, no modem contol | 
|---|
| 61 | CREAD   : enable receiving characters | 
|---|
| 62 | */ | 
|---|
| 63 | newtio.c_cflag = BAUDRATE |  CS8 | CLOCAL | CREAD; | 
|---|
| 64 |  | 
|---|
| 65 | //  CRTSCTS |  maybe not needed //DN 090907 | 
|---|
| 66 |  | 
|---|
| 67 | /* | 
|---|
| 68 | IGNPAR  : ignore bytes with parity errors | 
|---|
| 69 | ICRNL   : map CR to NL (otherwise a CR input on the other computer | 
|---|
| 70 | will not terminate input) | 
|---|
| 71 | otherwise make device raw (no other input processing) | 
|---|
| 72 | */ | 
|---|
| 73 | newtio.c_iflag = IGNPAR ; | 
|---|
| 74 |  | 
|---|
| 75 | // | ICRNL // i guess this is not needed here. DN 090907 | 
|---|
| 76 |  | 
|---|
| 77 | /* | 
|---|
| 78 | Raw output. | 
|---|
| 79 | */ | 
|---|
| 80 | newtio.c_oflag = 0; | 
|---|
| 81 |  | 
|---|
| 82 | /* | 
|---|
| 83 | ICANON  : enable canonical input | 
|---|
| 84 | disable all echo functionality, and don't send signals to calling program | 
|---|
| 85 | */ | 
|---|
| 86 | newtio.c_lflag = ICANON; | 
|---|
| 87 |  | 
|---|
| 88 | /* | 
|---|
| 89 | initialize all control characters | 
|---|
| 90 | default values can be found in /usr/include/termios.h, and are given | 
|---|
| 91 | in the comments, but we don't need them here | 
|---|
| 92 | */ | 
|---|
| 93 | newtio.c_cc[VINTR]    = 0;     /* Ctrl-c */ | 
|---|
| 94 | newtio.c_cc[VQUIT]    = 0;     /* Ctrl-\ */ | 
|---|
| 95 | newtio.c_cc[VERASE]   = 0;     /* del */ | 
|---|
| 96 | newtio.c_cc[VKILL]    = 0;     /* @ */ | 
|---|
| 97 | newtio.c_cc[VEOF]     = 4;     /* Ctrl-d */ | 
|---|
| 98 | newtio.c_cc[VTIME]    = 0;     /* inter-character timer unused */ | 
|---|
| 99 | newtio.c_cc[VMIN]     = 1;     /* blocking read until 1 character arrives */ | 
|---|
| 100 | newtio.c_cc[VSWTC]    = 0;     /* '\0' */ | 
|---|
| 101 | newtio.c_cc[VSTART]   = 0;     /* Ctrl-q */ | 
|---|
| 102 | newtio.c_cc[VSTOP]    = 0;     /* Ctrl-s */ | 
|---|
| 103 | newtio.c_cc[VSUSP]    = 0;     /* Ctrl-z */ | 
|---|
| 104 | newtio.c_cc[VEOL]     = 0;     /* '\0' */ | 
|---|
| 105 | newtio.c_cc[VREPRINT] = 0;     /* Ctrl-r */ | 
|---|
| 106 | newtio.c_cc[VDISCARD] = 0;     /* Ctrl-u */ | 
|---|
| 107 | newtio.c_cc[VWERASE]  = 0;     /* Ctrl-w */ | 
|---|
| 108 | newtio.c_cc[VLNEXT]   = 0;     /* Ctrl-v */ | 
|---|
| 109 | newtio.c_cc[VEOL2]    = 0;     /* '\0' */ | 
|---|
| 110 |  | 
|---|
| 111 | /* | 
|---|
| 112 | now clean the modem line and activate the settings for the port | 
|---|
| 113 | */ | 
|---|
| 114 | tcflush(fd, TCIFLUSH); | 
|---|
| 115 | tcsetattr(fd,TCSANOW,&newtio); | 
|---|
| 116 |  | 
|---|
| 117 | /* | 
|---|
| 118 | terminal settings done, now handle input | 
|---|
| 119 | In this example, inputting a 'z' at the beginning of a line will | 
|---|
| 120 | exit the program. | 
|---|
| 121 | */ | 
|---|
| 122 |  | 
|---|
| 123 | FILE *outfile; | 
|---|
| 124 | outfile = openOutfile(myPath); | 
|---|
| 125 |  | 
|---|
| 126 | if (outfile == NULL) {return -1;} | 
|---|
| 127 |  | 
|---|
| 128 | char outstring[400]; | 
|---|
| 129 | //char c; | 
|---|
| 130 |  | 
|---|
| 131 | while (STOP==FALSE) {     /* loop until we have a terminating condition */ | 
|---|
| 132 | /* read blocks program execution until a line terminating character is | 
|---|
| 133 | input, even if more than 255 chars are input. If the number | 
|---|
| 134 | of characters read is smaller than the number of chars available, | 
|---|
| 135 | subsequent reads will return the remaining chars. res will be set | 
|---|
| 136 | to the actual number of characters actually read */ | 
|---|
| 137 | res = read(fd,buf,255); | 
|---|
| 138 | buf[res]=0;             /* set end of string, so we can printf */ | 
|---|
| 139 |  | 
|---|
| 140 | if (strncmp (buf,"T:",2) != 0) continue; | 
|---|
| 141 | if (strlen(buf)>2) strcpy(dummy, buf+2); | 
|---|
| 142 | else continue; | 
|---|
| 143 | strcpy(buf,dummy); | 
|---|
| 144 | //         printf("%s\n",dummy); | 
|---|
| 145 |  | 
|---|
| 146 | time_t rawtime; | 
|---|
| 147 | struct tm * timeinfo; | 
|---|
| 148 |  | 
|---|
| 149 | time ( &rawtime ); | 
|---|
| 150 | timeinfo = localtime ( &rawtime ); | 
|---|
| 151 |  | 
|---|
| 152 | struct timeval timeofday; | 
|---|
| 153 | gettimeofday(&timeofday, NULL); | 
|---|
| 154 |  | 
|---|
| 155 |  | 
|---|
| 156 | sprintf(outstring, "PT100 Sensorvalues %04d %02d %02d %02d %02d %02d %03d %d %s", | 
|---|
| 157 | (*timeinfo).tm_year+1900, | 
|---|
| 158 | (*timeinfo).tm_mon+1, | 
|---|
| 159 | (*timeinfo).tm_mday, | 
|---|
| 160 | (*timeinfo).tm_hour, | 
|---|
| 161 | (*timeinfo).tm_min, | 
|---|
| 162 | (*timeinfo).tm_sec, | 
|---|
| 163 | timeofday.tv_usec/1000, | 
|---|
| 164 | (long)rawtime, | 
|---|
| 165 | buf); | 
|---|
| 166 |  | 
|---|
| 167 | printf("%s", outstring); | 
|---|
| 168 |  | 
|---|
| 169 | fprintf(outfile, "%s", outstring); | 
|---|
| 170 | fflush(outfile); | 
|---|
| 171 |  | 
|---|
| 172 | if (poll_stdin_time(1500000)==1) { | 
|---|
| 173 | STOP=TRUE; | 
|---|
| 174 | } | 
|---|
| 175 |  | 
|---|
| 176 |  | 
|---|
| 177 | } //end while(STOP==FALSE) | 
|---|
| 178 |  | 
|---|
| 179 |  | 
|---|
| 180 |  | 
|---|
| 181 | /* restore the old port settings */ | 
|---|
| 182 | tcsetattr(fd,TCSANOW,&oldtio); | 
|---|
| 183 | fclose(outfile); | 
|---|
| 184 |  | 
|---|
| 185 | return 0; | 
|---|
| 186 | } //end main(); | 
|---|
| 187 |  | 
|---|
| 188 | // OPens or Creates an Outfile named | 
|---|
| 189 | // "PT100_YYYYMMDD.slow" | 
|---|
| 190 | // this file should contain all enviromentals from noon to noon. | 
|---|
| 191 | // The File is created if it doesn't exist. | 
|---|
| 192 | // all data is appended, nothing will be deleted or overwritten. | 
|---|
| 193 |  | 
|---|
| 194 | FILE * openOutfile(char *path) | 
|---|
| 195 | { | 
|---|
| 196 | FILE *outfile; | 
|---|
| 197 |  | 
|---|
| 198 | time_t rawtime; | 
|---|
| 199 | struct tm * timeinfo; | 
|---|
| 200 |  | 
|---|
| 201 | time ( &rawtime ); | 
|---|
| 202 | timeinfo = gmtime ( &rawtime ); | 
|---|
| 203 |  | 
|---|
| 204 | // check what day it is today :-) | 
|---|
| 205 | if ((*timeinfo).tm_hour >13){ //then it is already tommorow | 
|---|
| 206 | rawtime += 86400; | 
|---|
| 207 | timeinfo = gmtime ( &rawtime ); | 
|---|
| 208 | } | 
|---|
| 209 | //generate filename | 
|---|
| 210 | char *outfilename; | 
|---|
| 211 | outfilename =(char*) calloc( strlen(path)+25 , sizeof(char)); | 
|---|
| 212 | if (outfilename ==NULL) | 
|---|
| 213 | { | 
|---|
| 214 | perror("could not allocate space for outputfilename"); | 
|---|
| 215 | return NULL; | 
|---|
| 216 | } | 
|---|
| 217 | sprintf(outfilename,"%sPT100_%04d%02d%02d.slow", | 
|---|
| 218 | path, // from user | 
|---|
| 219 | (*timeinfo).tm_year+1900, | 
|---|
| 220 | (*timeinfo).tm_mon+1, | 
|---|
| 221 | (*timeinfo).tm_mday ); | 
|---|
| 222 |  | 
|---|
| 223 | // there is no need to check if file is already existing. | 
|---|
| 224 | // if not fopen(name,"a") will create it. | 
|---|
| 225 | // if it exists | 
|---|
| 226 | // it will only be opened for appnendign | 
|---|
| 227 | outfile = fopen(outfilename,"a"); | 
|---|
| 228 |  | 
|---|
| 229 | if (outfile==NULL){ | 
|---|
| 230 | perror("could not open outputfile"); | 
|---|
| 231 | return NULL;} | 
|---|
| 232 |  | 
|---|
| 233 | return outfile; | 
|---|
| 234 | } | 
|---|
| 235 |  | 
|---|
| 236 | static int poll_stdin_time(int microsekunden) { | 
|---|
| 237 | struct timeval timeout; | 
|---|
| 238 | fd_set read_fds; | 
|---|
| 239 | int c; | 
|---|
| 240 | int stdin_status; | 
|---|
| 241 |  | 
|---|
| 242 | FD_ZERO(&read_fds); | 
|---|
| 243 | FD_SET(STDIN_FILENO, &read_fds); | 
|---|
| 244 | timeout.tv_sec = 0; | 
|---|
| 245 | timeout.tv_usec =microsekunden; | 
|---|
| 246 | stdin_status = select(STDIN_FILENO+1, &read_fds, NULL, NULL, &timeout); | 
|---|
| 247 | if (stdin_status == 1 ) { | 
|---|
| 248 | c=getchar(); | 
|---|
| 249 | fflush(stdin); | 
|---|
| 250 | if (c=='q') { | 
|---|
| 251 | return 1; | 
|---|
| 252 | } | 
|---|
| 253 | } else if (stdin_status ==0) { | 
|---|
| 254 | return 0; | 
|---|
| 255 | } else { | 
|---|
| 256 | perror("select()"); | 
|---|
| 257 | } | 
|---|
| 258 |  | 
|---|
| 259 |  | 
|---|
| 260 |  | 
|---|
| 261 | return -1; | 
|---|
| 262 |  | 
|---|
| 263 |  | 
|---|
| 264 | } | 
|---|