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

version 1.1, 1999/10/08 02:12:05 version 1.9, 2002/10/21 01:59:16
Line 1 
Line 1 
   /* $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 14 
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 57  struct object KsocketOpen(struct object obj) {
Line 61  struct object KsocketOpen(struct object obj) {
   me.sin_family = AF_INET;    me.sin_family = AF_INET;
   me.sin_port = htons(portNumber);    me.sin_port = htons(portNumber);
   bcopy(myhost->h_addr,    bcopy(myhost->h_addr,
         &me.sin_addr,myhost->h_length);          &me.sin_addr,myhost->h_length);
   
   if ((s_waiting = socket(AF_INET,SOCK_STREAM,0)) < 0) {    if ((s_waiting = socket(AF_INET,SOCK_STREAM,0)) < 0) {
     errorMsg1s("Socket allocation is failed.");      errorMsg1s("Socket allocation is failed.");
Line 77  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");
   }    }
   /*    /*
    fprintf(stderr,"Done the initialization. port =%d\n",ntohs(me.sin_port));        fprintf(stderr,"Done the initialization. port =%d\n",ntohs(me.sin_port));
      fprintf(stderr,"socket id = %d",accept(s_waiting,NULL,NULL)); */        fprintf(stderr,"socket id = %d",accept(s_waiting,NULL,NULL)); */
   rob = newObjectArray(2);    rob = newObjectArray(2);
   putoa(rob,0,KpoInteger(s_waiting));    putoa(rob,0,KpoInteger(s_waiting));
   putoa(rob,1,KpoInteger(ntohs(me.sin_port)));    putoa(rob,1,KpoInteger(ntohs(me.sin_port)));
Line 131  struct object KsocketConnect(struct object obj) {
Line 135  struct object KsocketConnect(struct object obj) {
   server.sin_family = AF_INET;    server.sin_family = AF_INET;
   server.sin_port = htons(portNumber);    server.sin_port = htons(portNumber);
   bcopy(servhost->h_addr,    bcopy(servhost->h_addr,
         (char *)&server.sin_addr,servhost->h_length);          (char *)&server.sin_addr,servhost->h_length);
   
   if ((socketid = socket(AF_INET,SOCK_STREAM,0)) <0) {    if ((socketid = socket(AF_INET,SOCK_STREAM,0)) <0) {
     errorMsg1s("socket allocation is failed.\n");      errorMsg1s("socket allocation is failed.\n");
Line 236  struct object KsocketSelect(struct object obj) {
Line 240  struct object KsocketSelect(struct object obj) {
 }  }
   
 struct object KsocketSelectMulti(struct object obj)  struct object KsocketSelectMulti(struct object obj)
 /* [ [integer socketid1, integer socketid2, ...]       /* [ [integer socketid1, integer socketid2, ...]
      optional integer timeout default 0]       optional integer timeout default 0]
    [ result1, result2, ....]     [ result1, result2, ....]
 */  */
Line 349  struct object KsocketRead(struct object obj) {
Line 353  struct object KsocketRead(struct object obj) {
     if (datasize - totalsize > 0) {      if (datasize - totalsize > 0) {
       n = read(socketid,data+totalsize,datasize-totalsize);        n = read(socketid,data+totalsize,datasize-totalsize);
       if (n < 0) {        if (n < 0) {
         errorMsg1s("Read error.");          errorMsg1s("Read error.");
       }        }
       if (n < datasize-totalsize) {        if (n < datasize-totalsize) {
         totalsize += n;          totalsize += n;
         break;          break;
       }else{ totalsize += n; }        }else{ totalsize += n; }
       if (totalsize == 0) {        if (totalsize == 0) {
         errorMsg1s("Select returns 1, but there is no data to read.");          errorMsg1s("Select returns 1, but there is no data to read.");
       }        }
     }else { /* increase the datasize */      }else { /* increase the datasize */
       tmp = (char *)GC_malloc(sizeof(char)*2*datasize);        tmp = (char *)GC_malloc(sizeof(char)*2*datasize);
Line 368  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 475  struct object KsocketWriteByte(struct object obj) {
Line 481  struct object KsocketWriteByte(struct object obj) {
   struct object ob1;    struct object ob1;
   struct object ob2;    struct object ob2;
   int socketid;    int socketid;
   int r;    int r,i,n,kk,r0;
   char data[2];  #define DATA_SIZE 1024
     char data[DATA_SIZE];
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
     errorMsg1s("KsocketWriteByte([integer socketid, int])");      errorMsg1s("KsocketWriteByte([integer socketid, int | array of int])");
   }    }
   if (getoaSize(obj) < 2) {    if (getoaSize(obj) < 2) {
     errorMsg1s("KsocketWriteByte([integer socketid, int])");      errorMsg1s("KsocketWriteByte([integer socketid, int | array of int])");
   }    }
   ob1 = getoa(obj,0);    ob1 = getoa(obj,0);
   ob2 = getoa(obj,1);    ob2 = getoa(obj,1);
   if (ob1.tag != Sinteger) {    if (ob1.tag != Sinteger) {
     errorMsg1s("KsocketWriteByte([integer socketid, int]) : the first argument must be an integer.");      errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : the first argument must be an integer.");
   }    }
   socketid = KopInteger(ob1);    socketid = KopInteger(ob1);
   if (ob2.tag != Sinteger) {    if (ob2.tag != Sinteger && ob2.tag != Sarray) {
     errorMsg1s("KsocketWriteByte([integer socketid, int]) : the second argument must be a string.");      errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : the second argument must be an integer or an array of integers.");
   }    }
   data[0] = KopInteger(ob2);    if (ob2.tag == Sinteger) {
   r = write(socketid,data, 1);      data[0] = KopInteger(ob2);
       r = write(socketid,data, 1);
     }else{
       n = getoaSize(ob2); kk = 0; r = 0;
       for (i=0; i<n; i++) {
         if (getoa(ob2,i).tag != Sinteger)
               errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : elements of the second argument must be integers.");
         data[kk] = KopInteger(getoa(ob2,i));
         kk++;
         if (kk >= DATA_SIZE) {
           r0 = write(socketid,data,kk);
           if (r0 != kk) {
             fprintf(stderr,"Warning: Could not write to the socket.\n");
             return(KpoInteger(r+r0));
           }
           r += r0;
           kk = 0;
         }
       }
       if (kk > 0) {
         r0 = write(socketid,data,kk);
         if (r0 != kk) {
           fprintf(stderr,"Warning: Could not write to the socket.\n");
           return(KpoInteger(r+r0));
         }
         r += r0;
       }
     }
   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=%d\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 511  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 528  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.1  
changed lines
  Added in v.1.9
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>