[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.7 and 1.9

version 1.7, 2002/10/21 00:37:00 version 1.9, 2002/10/21 01:59:16
Line 1 
Line 1 
 /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.6 2002/10/20 07:58:18 takayama Exp $ */  /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.8 2002/10/21 01:11:44 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  #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 ; */
Line 540  struct object KsocketReadHTTP(struct object socketObj)
Line 542  struct object KsocketReadHTTP(struct object socketObj)
   int flagmax = 1;    int flagmax = 1;
   int datasize;    int datasize;
   int last;    int last;
     int contentLength=-1;
   ob = KsocketRead(socketObj);    ob = KsocketRead(socketObj);
   s = KopString(ob);    s = KopString(ob);
   if (strncmp(s,"POST",4) == 0) flagmax=2;    if (strncmp(s,"POST",4) == 0) flagmax=2; /* for IE */
   else flagmax=1;    else flagmax=1;
   flag = 0;    flag = 0;
   for (i=strlen(s)-1; i>=0; i--) {    for (i=strlen(s)-1; i>=0; i--) {
Line 565  struct object KsocketReadHTTP(struct object socketObj)
Line 568  struct object KsocketReadHTTP(struct object socketObj)
   }else last = 0;    }else last = 0;
   
   while (flag < flagmax) {    while (flag < flagmax) {
         fprintf(stderr,"Waiting in socketReadBlock (spin lock to wait an empty line). flagmax(0d,0a)=%d\n",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=%d\n",flagmax,contentLength);
         if (strlen(s) == 0) {fprintf(stderr,"but I'm not receiving data. Expecting a bug.\n");          if (strlen(s) == 0) {fprintf(stderr,"but I'm not receiving data. Expecting a bug.\n");
         }else{          }else{
           /* for debugging. */            /* for debugging. */
           for (i=0; i<strlen(sss); i++) {            for (i=0; i<strlen(sss); i++) {
                 fprintf(stderr,"%3x",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");            fprintf(stderr,"\n");
         }          }
Line 643  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.7  
changed lines
  Added in v.1.9
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>