[BACK]Return to sm1Socket.c CVS log [TXT][DIR] Up to [local] / OpenXM / src / kan96xx / plugin

Diff for /OpenXM/src/kan96xx/plugin/sm1Socket.c between version 1.4 and 1.8

version 1.4, 2001/08/12 03:13:36 version 1.8, 2002/10/21 01:11:44
Line 1 
Line 1 
 /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.3 2001/05/04 01:06:30 takayama Exp $ */  /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.7 2002/10/21 00:37:00 takayama Exp $ */
 /* msg0s.c */  /* msg0s.c */
 #include <stdio.h>  #include <stdio.h>
 #include <sys/types.h>  #include <sys/types.h>
Line 15 
Line 15 
   
 extern int Quiet;  extern int Quiet;
 static void errorMsg1s(char *s);  static void errorMsg1s(char *s);
   static int getContentLength(char *s);
   static int getReceivedContentLength(char *s);
   #define MAX_LISTEN_QUEUE 3
   
 /* [(sm1.socket) (open) [optional integer port, optional string name] ] extension ; */  /* [(sm1.socket) (open) [optional integer port, optional string name] ] extension ; */
 struct object KsocketOpen(struct object obj) {  struct object KsocketOpen(struct object obj) {
Line 78  struct object KsocketOpen(struct object obj) {
Line 81  struct object KsocketOpen(struct object obj) {
   }    }
   
   
   if (listen(s_waiting,1) < 0) {    if (listen(s_waiting,MAX_LISTEN_QUEUE) < 0) {
     errorMsg1s("Listen failed");      errorMsg1s("Listen failed");
   }    }
   /*    /*
Line 369  struct object KsocketRead(struct object obj) {
Line 372  struct object KsocketRead(struct object obj) {
     }      }
   }    }
   
   r = (char *)GC_malloc(sizeof(char)*(n+1));    r = (char *)GC_malloc(sizeof(char)*(totalsize+1));
   if (r == (char *)NULL) errorMsg1s("Out of Memory.");    if (r == (char *)NULL) errorMsg1s("Out of Memory.");
   bcopy(data,r,totalsize);    bcopy(data,r,totalsize);
   robj = KpoString(r);    r[totalsize] = 0;
     robj = KpoString(r);  /* BUG: it works only for reading string from TCP/IP
                                                       stream. */
   
   return(robj);    return(robj);
   
Line 526  struct object KsocketWriteByte(struct object obj) {
Line 531  struct object KsocketWriteByte(struct object obj) {
   return(KpoInteger(r));    return(KpoInteger(r));
 }  }
   
   struct object KsocketReadHTTP(struct object socketObj) {
     /* Read until two empty line appears. */
     struct object ob;
     char *s;
     char *sss;
     char *tmp;
     int i;
     int flag;
     int flagmax = 1;
     int datasize;
     int last;
     int contentLength=-1;
     ob = KsocketRead(socketObj);
     s = KopString(ob);
     if (strncmp(s,"POST",4) == 0) flagmax=2; /* for IE */
     else flagmax=1;
     flag = 0;
     for (i=strlen(s)-1; i>=0; i--) {
           if ((s[i] == '\n') && (i==0)) {
             ++flag;
           }else if ((s[i] == '\n') && (s[i-1] == '\n')) {
             ++flag;
           }else if ((s[i] == 0xd) && (s[i+1] == 0xa) && (i == 0)) {
             ++flag;
           }else if ((s[i] == 0xa) && (s[i-1] == 0xd) && (s[i+1] == 0xd) && (s[i+2] == 0xa)) {
             ++flag;
           }
     }
     if (flag >= flagmax) return ob;
     datasize = strlen(s);
     sss = s;
     if ((s[strlen(s)-1] == '\n') ||
         (s[strlen(s)-2] == 0xd) && (s[strlen(s)-1] == 0xa)) {
           last = 1;
     }else last = 0;
   
     while (flag < flagmax) {
           contentLength = getContentLength(sss);
           if (contentLength != -1) {
             if (contentLength <= getReceivedContentLength(sss)) {
                   break;
             }
           }
           fprintf(stderr,"Waiting in socketReadBlock (spin lock to wait an empty line). flagmax(0d,0a)=%d, contentLength\n",flagmax,contentLength);
           if (strlen(s) == 0) {fprintf(stderr,"but I'm not receiving data. Expecting a bug.\n");
           }else{
             /* for debugging. */
             for (i=0; i<strlen(sss); i++) {
                   if ((sss[i] >= ' ') && (sss[i] < 0x7f)) {
                     fprintf(stderr,"%c",sss[i]);
                   }else{
             fprintf(stderr,"%3x",sss[i]);
                     if (sss[i] == 0xa) fprintf(stderr,"\n");
                   }
   
             }
             fprintf(stderr,"\n");
           }
           sleep(2);
           ob = KsocketRead(socketObj);
           s = KopString(ob);
           for (i=strlen(s)-1; i>=0; i--) {
             if ((s[i] == '\n') && (i==0) && last) {
                   ++flag;
             }else if ((s[i] == '\n') && (s[i-1] == '\n')) {
                   ++flag;
             }else if ((s[i] == 0xd) && (s[i+1] == 0xa) && (i==0) && last) {
                   ++flag;
             }else if ((s[i] == 0xa) && (s[i-1] == 0xd) && (s[i+1] == 0xd) && (s[i+2] == 0xa)) {
                   ++flag;
             }
           }
           if (datasize-1 <= strlen(sss)+strlen(s)) {
         tmp = (char *)GC_malloc(sizeof(char)*2*(datasize+strlen(s))+1);
         if (tmp == (char *)NULL) errorMsg1s("Out of Memory.");
             strcpy(tmp,sss);
             strcat(tmp,s);
         datasize = 2*(datasize+strlen(s));
             sss = tmp;
           }else{
             strcat(sss,s);
           }
   
           if ((s[strlen(s)-1] == '\n') ||
                   (s[strlen(s)-2] == 0xd) && (s[strlen(s)-1] == 0xa)) {
             last = 1;
           }else last = 0;
   
     }
   
     return KpoString(sss);
   
   }
   
 struct object Kplugin_sm1Socket(char *key,struct object obj) {  struct object Kplugin_sm1Socket(char *key,struct object obj) {
   struct object robj = NullObject;    struct object robj = NullObject;
   if (strcmp(key,"open") == 0) {    if (strcmp(key,"open") == 0) {
Line 540  struct object Kplugin_sm1Socket(char *key,struct objec
Line 639  struct object Kplugin_sm1Socket(char *key,struct objec
     robj = KsocketSelectMulti(obj);      robj = KsocketSelectMulti(obj);
   }else if (strcmp(key,"read") == 0) {    }else if (strcmp(key,"read") == 0) {
     robj = KsocketRead(obj);      robj = KsocketRead(obj);
     }else if (strcmp(key,"readHTTP") == 0) {
       robj = KsocketReadHTTP(obj);
   }else if (strcmp(key,"write") == 0) {    }else if (strcmp(key,"write") == 0) {
     robj = KsocketWrite(obj);      robj = KsocketWrite(obj);
   }else if (strcmp(key,"read") == 0) {    }else if (strcmp(key,"read") == 0) {
Line 557  struct object Kplugin_sm1Socket(char *key,struct objec
Line 658  struct object Kplugin_sm1Socket(char *key,struct objec
 }  }
   
   
   static int getContentLength(char *s) {
     int n;
     int i;
     int len = -1;
     char *s1 = "Content-length:";
     char *s2 = "CONTENT-LENGTH:";
     n = strlen(s);
     for (i=0; i<n; i++) {
           if ((strncmp(&(s[i]),s1,strlen(s1)) == 0) ||
                   (strncmp(&(s[i]),s2,strlen(s2)) == 0)) {
             sscanf(&(s[i+strlen(s1)]),"%d",&len);
             break;
           }
     }
     return len;
   }
   static int getReceivedContentLength(char *s) {
     int n;
     int i;
     int start;
     start = -1;
     n = strlen(s);
     for (i=0; i<n; i++) {
           if ((s[i] == '\n') && (s[i+1] == '\n')) {
             start = i+2; break;
           }else if ((s[i] == 0xd) && (s[i+1] == 0xa) && (s[i+2] == 0xd) && (s[i+3] == 0xa)) {
             start = i+4;
           }
     }
     if (start == -1) return 0;
     return (n-start);
   }
   
   
   
Legend:
Removed from v.1.4  
changed lines
  Added in v.1.8
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>