OpenXM/src/asir-port/cgi/webasir2.c - diff

Return to webasir2.c CVS log

Up to [local] / OpenXM / src / asir-port / cgi

Diff for /OpenXM/src/asir-port/cgi/webasir2.c between version 1.1 and 1.3

-version 1.1, 2014/08/30 12:25:56
+version 1.3, 2014/08/31 07:53:57
 Line 1
 Line 1
 Line 1
- /* $OpenXM$
+ /* $OpenXM: OpenXM/src/asir-port/cgi/webasir2.c,v 1.2 2014/08/30 22:47:20 takayama Exp $
   */
  /*
    (httpd-asir2.sm1) run   webasir2
+    >log 2>&1
+    Todo, timer(limit, command, message) implement in sm1.
   */
  #include <stdio.h>
+ #include <stdlib.h>
  #include <sys/types.h>
+ #include <unistd.h>
  #include <sys/socket.h>
  #include <sys/time.h>
  #include <netinet/in.h>
-Line 12
+Line 16
 Line 12
 Line 16
  #include <string.h>
  #define SIZE 0x10000
+ char *byteArrayToUrlEncoding(char *s,int size);
  int Debug=1;
+ int SetTimer=0;
  int main(int argc,char *argv[]) {
    int dataPort;
    struct hostent *servhost;
-Line 21  int main(int argc,char *argv[]) {
+Line 27  int main(int argc,char *argv[]) {
 Line 21  int main(int argc,char *argv[]) {
 Line 27  int main(int argc,char *argv[]) {
    FILE *fp;
    char s[1];
    char fname[SIZE];
-   int i;
+   int i,j,c;
    char key[SIZE];
    char comm[SIZE];
+   char *asircomm;
    int quit;
+   char workf[SIZE];
    quit = 0;
+   asircomm="3-2;";
    for (i=1; i<argc; i++) {
      if (strcmp(argv[i],"--quit")==0) quit=1;
+     else if (strcmp(argv[i],"--asir")==0) {
+       i++;
+       if (i <argc) asircomm = argv[i];
+       else { usage(); return(-1); }
+     }else if (strcmp(argv[i],"--debug")==0) {
+       i++;
+       if (i <argc) sscanf(argv[i],"%d",&Debug);
+       else { usage(); return(-1); }
+     }else if (strcmp(argv[i],"--settimer")==0) {
+       i++;
+       if (i <argc) sscanf(argv[i],"%d",&SetTimer);
+       else { usage(); return(-1); }
+     } else if (strcmp(argv[i],"--stdin")==0) {
+       asircomm = (char *) malloc(SIZE);
+       asircomm[0] = 0; j=0;
+       while ((c=getchar()) != EOF) {
+         asircomm[j] = c; j++; asircomm[j] = 0;
+         if (j > SIZE-3) {
+           fprintf(stderr,"error, too big input.\n"); return(-1);
+         }
+       }
+     } else {
+       usage(); return(0);
+     }
    }
-   system("ls /tmp/webasir*.txt >tmp-webasir.txt");
+   sprintf(workf,"/tmp/tmp-webasir-%d.txt",(int) getpid());
-   fp = fopen("tmp-webasir.txt","r");
+   sprintf(comm,"ls /tmp/webasir*.txt >%s",workf);
+   system(comm);
+   fp = fopen(workf,"r");
    if (fp == NULL) {
      fprintf(stderr,"No webasir2 is running.\n"); return(-1);
    }
-Line 55  int main(int argc,char *argv[]) {
+Line 90  int main(int argc,char *argv[]) {
 Line 55  int main(int argc,char *argv[]) {
 Line 90  int main(int argc,char *argv[]) {
    }
    if (Debug) printf("key=%s\n",key);
    fclose(fp);
+   sprintf(comm,"rm -f %s",workf);
+   system(comm);
    if ((servhost = gethostbyname("localhost")) == NULL) {
      fprintf(stderr,"bad server name.\n"); return(-1);
-Line 72  int main(int argc,char *argv[]) {
+Line 109  int main(int argc,char *argv[]) {
 Line 72  int main(int argc,char *argv[]) {
 Line 109  int main(int argc,char *argv[]) {
    if (Debug) fprintf(stderr,"Trying to connect port %d  ",ntohs(dServer.sin_port));
    if (connect(dataPort,(struct sockaddr *)&dServer,sizeof(dServer)) == -1) {
-     fprintf(stderr,"cannot connect\n");
+     fprintf(stderr,"error: cannot connect\n");
-   }else{  fprintf(stderr,"Connected\n"); }
+   }else{  if (Debug) fprintf(stderr,"Connected\n"); }
+   if (SetTimer) {
+     strcpy(comm,asircomm);
+     for (i=strlen(comm)-1; i>=0; i--) {
+       if ((comm[i] == ';') || (comm[i] <= ' ')) comm[i] = 0;
+       else break;
+     }
+     sprintf(asircomm,"timer(%d,%s,\"error(timeout %d sec)\");",
+             SetTimer,comm,SetTimer);
+   }
    if (quit) {
      sprintf(comm,"GET /?msg=httpdAsirMeta+quit HTTP/1.1\n\n");
      write(dataPort,comm,strlen(comm));
      fflush(NULL);
    }else{
-     sprintf(comm,"GET /?%s=10-21;\n\n",key);
+     sprintf(comm,"GET /?%s=%s;\n\n",key,byteArrayToUrlEncoding(asircomm,strlen(asircomm)));
      write(dataPort,comm,strlen(comm));
      fflush(NULL);
    }
-Line 91  int main(int argc,char *argv[]) {
+Line 137  int main(int argc,char *argv[]) {
 Line 91  int main(int argc,char *argv[]) {
 Line 137  int main(int argc,char *argv[]) {
    printf("%s\n",comm);
  }
+ /* from kan96xx/plugin/oxcgi.c */
+ /* . - _  A-Z a-z 0-9
+    space --> +
+ */
+ static int isUrlEncoding3(char s) {
+   if ((s == '.') || (s == '-') || (s == '_')) return(0);
+   if ((s >= 'A') && (s <= 'Z')) return(0);
+   if ((s >= 'a') && (s <= 'z')) return(0);
+   if ((s >= '0') && (s <= '9')) return(0);
+   if (s == ' ') return(0);
+   return(1);
+ }
+ char *byteArrayToUrlEncoding(char *s,int size) {
+   int n,i,j;
+   char *r;
+   n = 0;
+   /* get Size */
+   for (i=0; i<size; i++) {
+     if (isUrlEncoding3((char)s[i])) n += 3;
+     n++;
+   }
+   r = malloc(n+1);
+   if (r == NULL) {fprintf(stderr,"%s\n","No more memory."); return(NULL); }
+   r[0] = 0; r[n] = 0;
+   i = 0; j = 0;
+   while ((j < n) && (i<size)) {
+     if (isUrlEncoding3((char)s[i])) {
+       sprintf(&(r[j]),"%%%02X",s[i]); j += 3;
+     }else{
+       if ((char)s[i] == ' ') r[j]='+';
+       else r[j] = s[i];
+       j++; r[j] = 0;
+     }
+     i++;
+   }
+   return(r);
+ }
+ usage() {
+   fprintf(stderr,"webasir2 [--quit] [--asir command_string]\n");
+   fprintf(stderr,"         [--debug level]\n");
+   fprintf(stderr,"         [--settimer seconds]\n");
+   fprintf(stderr,"webasir2 --stdin  ; command is obtained from the stdin.\n");
+ }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>