[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.17 and 1.20

version 1.17, 2004/02/25 23:14:35 version 1.20, 2005/07/03 11:08:54
Line 1 
Line 1 
 /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.16 2004/02/23 09:03:43 takayama Exp $ */  /* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.19 2005/06/16 05:07:24 takayama Exp $ */
 /* msg0s.c */  /* msg0s.c */
 #include <stdio.h>  #include <stdio.h>
   #include <string.h>
 #include <sys/types.h>  #include <sys/types.h>
 #include <sys/socket.h>  #include <sys/socket.h>
 #include <sys/time.h>  #include <sys/time.h>
Line 61  struct object KsocketOpen(struct object obj) {
Line 62  struct object KsocketOpen(struct object obj) {
   
   /* fprintf(stderr,"Hello from open.\n"); */    /* fprintf(stderr,"Hello from open.\n"); */
   if ((myhost = gethostbyname(serverName)) == NULL) {    if ((myhost = gethostbyname(serverName)) == NULL) {
     errorMsg1s("Bad server name.");      perror("gethostbyname"); errorMsg1s("Bad server name.");
   }    }
   bzero((char *)&me,sizeof(me));    bzero((char *)&me,sizeof(me));
   me.sin_family = AF_INET;    me.sin_family = AF_INET;
Line 70  struct object KsocketOpen(struct object obj) {
Line 71  struct object KsocketOpen(struct object obj) {
         &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.");      perror("socket"); errorMsg1s("Socket allocation is failed.");
   }    }
   
   on=1; setsockopt(s_waiting,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));    on=1; setsockopt(s_waiting,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));
   /* important */    /* important */
   if (bind(s_waiting,(struct sockaddr *) &me,sizeof(me)) == -1) {    if (bind(s_waiting,(struct sockaddr *) &me,sizeof(me)) == -1) {
     fprintf(stderr,"Bind error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);      fprintf(stderr,"Bind error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
     errorMsg1s("cannot bind");      perror("bind"); errorMsg1s("cannot bind");
   }    }
   
   tt = sizeof(me);    tt = sizeof(me);
   if (getsockname(s_waiting,(struct sockaddr *)&me,&tt) < 0) {    if (getsockname(s_waiting,(struct sockaddr *)&me,&tt) < 0) {
     fprintf(stderr,"getsockname error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);      fprintf(stderr,"getsockname error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
     errorMsg1s("cannot getsockname");      perror("getsockname"); errorMsg1s("cannot getsockname");
   }    }
   
   
   if (listen(s_waiting,MAX_LISTEN_QUEUE) < 0) {    if (listen(s_waiting,MAX_LISTEN_QUEUE) < 0) {
     errorMsg1s("Listen failed");      perror("listen"); 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));
Line 135  struct object KsocketConnect(struct object obj) {
Line 136  struct object KsocketConnect(struct object obj) {
   
   
   if ((servhost = gethostbyname(serverName)) == NULL) {    if ((servhost = gethostbyname(serverName)) == NULL) {
     errorMsg1s("bad server name.\n");      perror("gethostbyname"); errorMsg1s("bad server name.\n");
   }    }
   bzero((char *)&server,sizeof(server));    bzero((char *)&server,sizeof(server));
   server.sin_family = AF_INET;    server.sin_family = AF_INET;
Line 144  struct object KsocketConnect(struct object obj) {
Line 145  struct object KsocketConnect(struct object obj) {
         (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");      perror("socket"); errorMsg1s("socket allocation is failed.\n");
   }    }
   if (!Quiet) {    if (!Quiet) {
     fprintf(stderr,"Trying to connect port %d, ip=%x\n",ntohs(server.sin_port),server.sin_addr);      fprintf(stderr,"Trying to connect port %d, ip=%x\n",ntohs(server.sin_port),server.sin_addr);
   }    }
   if (connect(socketid,(struct sockaddr *)&server,sizeof(server)) == -1) {    if (connect(socketid,(struct sockaddr *)&server,sizeof(server)) == -1) {
     errorMsg1s("cannot connect");      perror("connect"); errorMsg1s("cannot connect");
   }    }
   /* fprintf(stderr,"connected.\n"); */    /* fprintf(stderr,"connected.\n"); */
   robj = newObjectArray(2);    robj = newObjectArray(2);
Line 162  struct object KsocketConnect(struct object obj) {
Line 163  struct object KsocketConnect(struct object obj) {
 /* [ integer socketid ]  /* [ integer socketid ]
    [ integer newsocketid ] */     [ integer newsocketid ] */
 struct object KsocketAccept(struct object obj) {  struct object KsocketAccept(struct object obj) {
   struct object obj1;    struct object obj1 = OINIT;
   struct object obj2;    struct object obj2 = OINIT;
   struct object robj;    struct object robj = OINIT;
   int s, news;    int s, news;
   
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
Line 182  struct object KsocketAccept(struct object obj) {
Line 183  struct object KsocketAccept(struct object obj) {
     fprintf(stderr,"Error in accept. Retrying (KsocketAccept).\n");      fprintf(stderr,"Error in accept. Retrying (KsocketAccept).\n");
     /* Code added for strange behavior on cygwin. */      /* Code added for strange behavior on cygwin. */
     if ((news = accept(s,NULL,NULL)) < 0) {      if ((news = accept(s,NULL,NULL)) < 0) {
       errorMsg1s("Error in accept. Retry failed.");        perror("accept"); errorMsg1s("Error in accept. Retry failed.");
     }      }
   }    }
   if (close(s) < 0) {    if (close(s) < 0) {
     errorMsg1s("Error in closing the old socket.");      perror("close"); errorMsg1s("Error in closing the old socket.");
   }    }
   robj = newObjectArray(1);    robj = newObjectArray(1);
   putoa(robj,0,KpoInteger(news));    putoa(robj,0,KpoInteger(news));
Line 202  struct object KsocketAccept(struct object obj) {
Line 203  struct object KsocketAccept(struct object obj) {
    ....     ....
    */     */
 struct object KsocketAccept2(struct object obj) {  struct object KsocketAccept2(struct object obj) {
   struct object obj1;    struct object obj1 = OINIT;
   struct object obj2;    struct object obj2 = OINIT;
   struct object robj;    struct object robj = OINIT;
   int s, news;    int s, news;
   
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
Line 222  struct object KsocketAccept2(struct object obj) {
Line 223  struct object KsocketAccept2(struct object obj) {
     fprintf(stderr,"Error in accept. Retrying (KsocketAccept2).\n");      fprintf(stderr,"Error in accept. Retrying (KsocketAccept2).\n");
     /* Code added for strange behavior on cygwin. */      /* Code added for strange behavior on cygwin. */
     if ((news = accept(s,NULL,NULL)) < 0) {      if ((news = accept(s,NULL,NULL)) < 0) {
       errorMsg1s("Error in accept. Retry failed.");        perror("accept"); errorMsg1s("Error in accept. Retry failed.");
     }      }
   }    }
   if (close(s) < 0) {    if (close(s) < 0) {
     errorMsg1s("Error in closing the old socket.");      perror("close"); errorMsg1s("Error in closing the old socket.");
   }    }
   robj = newObjectArray(1);    robj = newObjectArray(1);
   putoa(robj,0,KpoInteger(news));    putoa(robj,0,KpoInteger(news));
Line 244  int KsocketSelect0(int fd,int t) {
Line 245  int KsocketSelect0(int fd,int t) {
     if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {      if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
       /* It must be fd+1 !,  Not fd. */        /* It must be fd+1 !,  Not fd. */
       fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);        fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
       errorMsg1s("KsocketSelect0() : select failed.");        perror("select"); errorMsg1s("KsocketSelect0() : select failed.");
       return(0);        return(0);
     }      }
   }else{ /* block */    }else{ /* block */
     if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {      if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
       errorMsg1s("KsocketSelect0() : select failed.");        perror("select"); errorMsg1s("KsocketSelect0() : select failed.");
       fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);        fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
       return(0);        return(0);
     }      }
Line 262  int KsocketSelect0(int fd,int t) {
Line 263  int KsocketSelect0(int fd,int t) {
    integer true or false     integer true or false
 */  */
 struct object KsocketSelect(struct object obj) {  struct object KsocketSelect(struct object obj) {
   struct object robj;    struct object robj = OINIT;
   struct object ob1;    struct object ob1 = OINIT;
   struct object ob2;    struct object ob2 = OINIT;
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
     errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");      errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");
   }    }
Line 294  struct object KsocketSelectMulti(struct object obj) 
Line 295  struct object KsocketSelectMulti(struct object obj) 
    [ result1, result2, ....]     [ result1, result2, ....]
 */  */
 {  {
   struct object robj;    struct object robj = OINIT;
   struct object ob1;    struct object ob1 = OINIT;
   struct object ob2;    struct object ob2 = OINIT;
   struct object ob3;    struct object ob3 = OINIT;
   int size,i,fd,p,t;    int size,i,fd,p,t;
   fd_set readfds;    fd_set readfds;
   struct timeval timeout;    struct timeval timeout;
Line 345  struct object KsocketSelectMulti(struct object obj) 
Line 346  struct object KsocketSelectMulti(struct object obj) 
     if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {      if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
       /* It must be fd+1 !,  Not fd. */        /* It must be fd+1 !,  Not fd. */
       fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);        fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
       errorMsg1s("KsocketSelectMulti() : select failed.");        perror("select"); errorMsg1s("KsocketSelectMulti() : select failed.");
     }      }
   }else{ /* block */    }else{ /* block */
     if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {      if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
       fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);        fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
       errorMsg1s("KsocketSelectMulti() : (block) select failed.");        perror("select"); errorMsg1s("KsocketSelectMulti() : (block) select failed.");
     }      }
   }    }
   robj = newObjectArray(size);    robj = newObjectArray(size);
Line 373  static char Data00[1024];
Line 374  static char Data00[1024];
    string data     string data
 */  */
 struct object KsocketRead(struct object obj) {  struct object KsocketRead(struct object obj) {
   struct object ob1;    struct object ob1 = OINIT;
   struct object robj = NullObject;    struct object robj = NullObject;
   static int datasize = 1024;    static int datasize = 1024;
   static char *data = Data00;    static char *data = Data00;
Line 401  struct object KsocketRead(struct object obj) {
Line 402  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) {
                   perror("read");
         errorMsg1s("Read error.");          errorMsg1s("Read error.");
       }        }
       if (n < datasize-totalsize) {        if (n < datasize-totalsize) {
Line 434  struct object KsocketRead(struct object obj) {
Line 436  struct object KsocketRead(struct object obj) {
 /* [ integer socketid, string data ]  /* [ integer socketid, string data ]
    integer  */     integer  */
 struct object KsocketWrite(struct object obj) {  struct object KsocketWrite(struct object obj) {
   struct object ob1;    struct object ob1 = OINIT;
   struct object ob2;    struct object ob2 = OINIT;
   int socketid;    int socketid;
   int r;    int r;
     int k,k0;
     char *s;
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
     errorMsg1s("KsocketWrite([integer socketid, string data])");      errorMsg1s("KsocketWrite([integer socketid, string data])");
   }    }
Line 453  struct object KsocketWrite(struct object obj) {
Line 457  struct object KsocketWrite(struct object obj) {
   if (ob2.tag != Sdollar) {    if (ob2.tag != Sdollar) {
     errorMsg1s("KsocketWrite([integer socketid, string data]) : the second argument must be a string.");      errorMsg1s("KsocketWrite([integer socketid, string data]) : the second argument must be a string.");
   }    }
   r = write(socketid,KopString(ob2), strlen(KopString(ob2)));    s = KopString(ob2);
   return(KpoInteger(r));    k0 = k = strlen(s);
     while (1) {
       r = write(socketid,s,k);
       if (r < 0) {
         perror("write"); errorMsg1s("KsocketWrite: write failed.");
       }
       if (r >= k) break;
       k -= r;
       s = &(s[r]);
     }
     return(KpoInteger(k0));
   
 }  }
 struct object KsocketClose(struct object obj) {  struct object KsocketClose(struct object obj) {
   int socketid;    int socketid;
   struct object ob1;    struct object ob1 = OINIT;
   if (obj.tag != Sarray) {    if (obj.tag != Sarray) {
     errorMsg1s("KsocketClose([ integer socketid ])");      errorMsg1s("KsocketClose([ integer socketid ])");
   }    }
Line 486  struct object KsocketReadByte(struct object obj);
Line 500  struct object KsocketReadByte(struct object obj);
 struct object KsocketWriteByte(struct object obj);  struct object KsocketWriteByte(struct object obj);
   
 struct object KsocketReadByte(struct object obj) {  struct object KsocketReadByte(struct object obj) {
   struct object ob1;    struct object ob1 = OINIT;
   struct object robj = NullObject;    struct object robj = NullObject;
   char data[2];    char data[2];
   char *tmp;    char *tmp;
Line 510  struct object KsocketReadByte(struct object obj) {
Line 524  struct object KsocketReadByte(struct object obj) {
   
   n = read(socketid,data,1);    n = read(socketid,data,1);
   if (n < 0) {    if (n < 0) {
           perror("read");
     errorMsg1s("Read error.");      errorMsg1s("Read error.");
     robj = KpoInteger(-1);      robj = KpoInteger(-1);
     return(robj);      return(robj);
Line 526  struct object KsocketReadByte(struct object obj) {
Line 541  struct object KsocketReadByte(struct object obj) {
 /* [ integer socketid, int ]  /* [ integer socketid, int ]
    integer  */     integer  */
 struct object KsocketWriteByte(struct object obj) {  struct object KsocketWriteByte(struct object obj) {
   struct object ob1;    struct object ob1 = OINIT;
   struct object ob2;    struct object ob2 = OINIT;
   int socketid;    int socketid;
   int r,i,n,kk,r0;    int r,i,n,kk,r0;
 #define DATA_SIZE 1024  #define DATA_SIZE 1024
Line 550  struct object KsocketWriteByte(struct object obj) {
Line 565  struct object KsocketWriteByte(struct object obj) {
   if (ob2.tag == Sinteger) {    if (ob2.tag == Sinteger) {
     data[0] = KopInteger(ob2);      data[0] = KopInteger(ob2);
     r = write(socketid,data, 1);      r = write(socketid,data, 1);
       if (r < 0) {
             perror("write"); errorMsg1s("KsocketWriteByte: write error");
       }
   }else{    }else{
     n = getoaSize(ob2); kk = 0; r = 0;      n = getoaSize(ob2); kk = 0; r = 0;
     for (i=0; i<n; i++) {      for (i=0; i<n; i++) {
       if (getoa(ob2,i).tag != Sinteger)        if (getoa(ob2,i).tag != Sinteger)
             errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : elements of the second argument must be integers.");          errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : elements of the second argument must be integers.");
       data[kk] = KopInteger(getoa(ob2,i));        data[kk] = KopInteger(getoa(ob2,i));
       kk++;        kk++;
       if (kk >= DATA_SIZE) {        if (kk >= DATA_SIZE) {
         r0 = write(socketid,data,kk);          r0 = write(socketid,data,kk);
         if (r0 != kk) {          if (r0 < 0) { perror("write"); errorMsg1s("write failed."); }
           fprintf(stderr,"Warning: Could not write to the socket.\n");          if (r0 != kk) {
           return(KpoInteger(r+r0));            fprintf(stderr,"Warning: Could not write to the socket.\n");
         }            return(KpoInteger(r+r0));  /* bug: we should retry. */
           }
         r += r0;          r += r0;
         kk = 0;          kk = 0;
       }        }
     }      }
     if (kk > 0) {      if (kk > 0) {
       r0 = write(socketid,data,kk);        r0 = write(socketid,data,kk);
         if (r0 < 0) { perror("write"); errorMsg1s("write failed."); }
       if (r0 != kk) {        if (r0 != kk) {
         fprintf(stderr,"Warning: Could not write to the socket.\n");          fprintf(stderr,"Warning: Could not write to the socket.\n");
         return(KpoInteger(r+r0));          return(KpoInteger(r+r0));
       }        }
       r += r0;        r += r0;
     }      }
Line 581  struct object KsocketWriteByte(struct object obj) {
Line 601  struct object KsocketWriteByte(struct object obj) {
   
 struct object KsocketReadHTTP(struct object socketObj) {  struct object KsocketReadHTTP(struct object socketObj) {
   /* Read until two empty line appears. */    /* Read until two empty line appears. */
   struct object ob;    struct object ob = OINIT;
   struct object ob1;    struct object ob1 = OINIT;
   struct object nob;    struct object nob = OINIT;
   char *s;    char *s;
   char *sss;    char *sss;
   char *tmp;    char *tmp;
Legend:
Removed from v.1.17  
changed lines
  Added in v.1.20
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>