[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.6

version 1.1, 1999/10/08 02:12:05 version 1.6, 2002/10/20 07:58:18
Line 1 
Line 1 
   /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.5 2002/10/17 13:40:29 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);
   #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 59  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 79  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 133  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 238  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 351  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 370  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 479  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 KsocketReadBlock(struct object socketObj) {
     /* Read until the empty line appears. */
     struct object ob;
     char *s;
     char *sss;
     char *tmp;
     int i;
     int flag;
     int datasize;
     ob = KsocketRead(socketObj);
     s = KopString(ob);
     flag = 0;
     for (i=strlen(s)-1; i>=0; i--) {
           if ((s[i] == '\n') && (i==0)) {
             flag = 1;
           }else if ((s[i] == '\n') && (s[i-1] == '\n')) {
             flag = 1;
           }else if ((s[i] == 0xd) && (s[i+1] == 0xa) && (i == 0)) {
             flag = 1;
           }else if ((s[i] == 0xa) && (s[i-1] == 0xd) && (s[i+1] == 0xd) && (s[i+2] == 0xa)) {
             flag = 1;
           }
     }
     if (flag == 1) return ob;
     datasize = strlen(s);
     sss = s;
   
     while (flag == 0) {
           fprintf(stderr,"Waiting in socketReadBlock (spin lock to wait an empty line).\n");
           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++) {
                   fprintf(stderr,"%3x",sss[i]);
             }
             fprintf(stderr,"\n");
           }
           sleep(2);
           ob = KsocketRead(socketObj);
           s = KopString(ob);
           flag = 0;
           for (i=strlen(s)-1; i>=0; i--) {
             if ((s[i] == '\n') && (i==0)) {
                   flag = 1;
             }else if ((s[i] == '\n') && (s[i-1] == '\n')) {
                   flag = 1;
             }else if ((s[i] == 0xd) && (s[i+1] == 0xa) && (i == 0)) {
                   flag = 1;
             }else if ((s[i] == 0xa) && (s[i-1] == 0xd) && (s[i+1] == 0xd) && (s[i+2] == 0xa)) {
                   flag = 1;
             }
           }
           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);
           }
     }
   
     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 611  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,"readBlock") == 0) {
       robj = KsocketReadBlock(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) {
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.6
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>