// Read analog inputs from shared memory and output formatted HTML #include #include #include #include #include "../io/io2.h" #include "../usr/include/mysql/mysql.h" #define NUM_CHANNELS 8 char *split(char *source, char **p, char **v) { char *amp, *eq; /* if there's an = sign, make it an end-of-line */ if(eq=strchr(source,'=')){ eq[0] = '\0'; *p = source; *v = eq+1; eq++; if(amp=strchr(eq,'&')){ amp[0] = '\0'; return(amp+1); }else{ return(0); } } return(0); } main(){ float reading; int c,i,j; char bgcolor[10]; char entry[100]; char chname[20]; char *next, *p[10], *v[10]; int intval; int shmid, ddata, ddir, dio1, dio2, mybit; key_t key; char *shmat(); //short *shm, *s; shmstruct *shm; MYSQL server; MYSQL_RES *result; MYSQL_ROW row; char *query[128]; // Start HTML printf ("Content-type: text/html\n\n

System status

\n"); mysql_init(&server); if (!(mysql_real_connect(&server,"copper.cld.home","wkuhns",NULL,"sensor",0,NULL,0))){ printf("

Error Connecting

\n"); abort(); } // Key for out shared memory is 9700 key = 9700; // Create our shared memory if ((shmid = shmget(key, sizeof(shmstruct), 0666)) < 0) { perror("shmget"); exit(1); } //printf("Shm1 OK\n"); // Link to our shared memory if ((shm=shmat(shmid, NULL, 0)) == (char *) -1) { perror("shmat"); exit(1); } //printf("Shm2 OK\n"); // Get form data entry[0] = 0; fscanf(stdin,"%s",&entry); //printf("fd0 OK: %s\n",entry); j = 0; next = &entry[0]; //printf("fd1 OK\n"); while(next=(split(next,&p[j],&v[j]))){ j++; } //printf("fd2 OK: params=%d\n",j); // Set default channel number c = 0; if (j>0){ for(i=0;i\n",c); } //printf("OK.\n p2... "); if(!strcmp(p[i],"dir")){ sscanf(v[i],"%x",&intval); shm->diodir[c] = (byte) intval; //printf("Dir=%x
\n",shm->dio[c].dir); } //printf("OK.\n p3... "); if(!strcmp(p[i],"data")){ sscanf(v[i],"%x",&intval); shm->diovalue[c] = (byte) intval; //printf("Data=%x
\n",shm->dio[c].value); } //printf("xx\n"); } } //printf("

\n"); printf ("\n"); printf ("\n"); sprintf(query,"SELECT hwch, name from channel where apid = 6 and ctype='analog' order by board,hwch"); // Query mysql server if (mysql_query(&server, query)){ printf("

Error querying database

%s\n",query); abort(); } result = mysql_store_result(&server); // Cycle through channels for (j=0; jadstatus[j]){ reading = shm->advalue[j]; printf ("\n",j); printf ("\n",shm->adraw[j]); printf ("\n",row[1]); printf ("\n",reading); printf ("\n",reading*1.8+32); if (j==8 || j==9){ printf ("\n",(int)(reading*.36-36)); }else{ printf ("\n",(int)(reading*3.6-36)); } }else{ printf ("\n",j); printf ("\n",shm->adraw[j]); printf ("\n",row[1]); printf ("\n"); printf ("\n"); } } printf("

Channel	raw a/d	Name	deg. C	deg. F
%d	%d	%s	%1.1f	%1.1f

%d	%d	%s	Out Of Range

\n"); // Digital IO printf ("

Digital I/O

\n"); // Container table printf("\n"); sprintf(query,"SELECT hwch, name, board from channel where apid = 6 and ctype='digital' order by board,hwch"); // Query mysql server if (mysql_query(&server, query)){ printf("

Error querying database

%s\n",query); abort(); } result = mysql_store_result(&server); // Cycle through channels j=-1; i = 0; while(row=mysql_fetch_row(result)){ if (j != atoi(row[2])){ if (j > -1){ printf ("

\n"); } j = atoi(row[2]); i = 0; ddata = shm->diovalue[j]; ddir = shm->diodir[j]; printf ("\n"); printf ("\n",j); } printf ("",i,row[1]); if(ddir & 1 << i){ printf (""); }else{ printf (""); } if(ddata & 1 << i){ strcpy(&bgcolor,"red"); }else{ strcpy(&bgcolor,"grey"); } printf ("\n",bgcolor); i++; } printf ("

Block %d	dir
%d: %s	Out	In

\n"); printf ("\n"); // Refresh button //printf("j = %d, data = %d",j,ddata); printf("
\n"); printf("\n"); }