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

Diff for /OpenXM/src/kan96xx/plugin/mytcpio.c between version 1.10 and 1.13

version 1.10, 2003/07/20 07:18:45 version 1.13, 2004/02/25 23:14:35
Line 1 
Line 1 
 /*  $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.9 2002/10/23 08:42:22 takayama Exp $ */  /*  $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.12 2003/09/16 02:57:39 takayama Exp $ */
 #include <stdio.h>  #include <stdio.h>
 #include <sys/types.h>  #include <sys/types.h>
 #include <sys/socket.h>  #include <sys/socket.h>
Line 6 
Line 6 
 #include <netinet/in.h>  #include <netinet/in.h>
 #include <netdb.h>  #include <netdb.h>
 #include <setjmp.h>  #include <setjmp.h>
   #include <errno.h>
 /* -lnsl -lsocket /usr/ucblib/libucb.a */  /* -lnsl -lsocket /usr/ucblib/libucb.a */
 #include "ox_kan.h"  #include "ox_kan.h"
 /*  /*
Line 38  socketOpen(char *serverName,int portNumber) {
Line 39  socketOpen(char *serverName,int portNumber) {
   static struct sockaddr_in me;    static struct sockaddr_in me;
   static int s_waiting;    static int s_waiting;
   static int on;    static int on;
   extern int errno;  
   int tt;    int tt;
   
   SET_TCPIOERROR;    SET_TCPIOERROR;
Line 91  socketAccept(int snum) {
Line 91  socketAccept(int snum) {
   s = snum;    s = snum;
   fprintf(TcpioError,"Trying to accept... "); fflush(TcpioError);    fprintf(TcpioError,"Trying to accept... "); fflush(TcpioError);
   if ((news = accept(s,NULL,NULL)) < 0) {    if ((news = accept(s,NULL,NULL)) < 0) {
     errorMsg1s("Error in accept.");      errorMsg1s("Error in accept. Retrying (socketAccept).");
     return(-1);      /* Code added for strange behavior on cygwin. */
       if ((news = accept(s,NULL,NULL)) < 0) {
         errorMsg1s("Error in accept. Retry failed.");
         return (-1);
       }
   }    }
   fprintf(TcpioError,"Accepted.\n"); fflush(TcpioError);    fprintf(TcpioError,"Accepted.\n"); fflush(TcpioError);
   if (close(s) < 0) {    if (close(s) < 0) {
Line 114  socketAcceptLocal(int snum) {
Line 118  socketAcceptLocal(int snum) {
   len = sizeof(struct sockaddr);    len = sizeof(struct sockaddr);
   if ((news = accept(s,&peer,&len)) < 0) {    if ((news = accept(s,&peer,&len)) < 0) {
     errorMsg1s("Error in accept. Retrying");      errorMsg1s("Error in accept. Retrying");
     {  /* Code added for strange behavior on cygwin. */      /* Code added for strange behavior on cygwin. */
       int i;     if ((news = accept(s,&peer,&len)) < 0) {
       for (i=0; i<5; i++) {        errorMsg1s("Error in accept. Retry failed.");
         if ((news = accept(s,&peer,&len)) < 0) {        return (-1);
           fprintf(stderr,"%d : ",i);     }
           errorMsg1s("Error in accept. Retrying");  
         }  
       }  
       if (news < 0) {  
         errorMsg1s("Error in accept. Retrying");  
         return(-1);  
       }  
     }  
   }    }
   
   len = sizeof(struct sockaddr);    len = sizeof(struct sockaddr);
Line 166  socketAcceptLocal2(int snum) {
Line 162  socketAcceptLocal2(int snum) {
   fprintf(TcpioError,"Trying to accept from localhost... "); fflush(TcpioError);    fprintf(TcpioError,"Trying to accept from localhost... "); fflush(TcpioError);
   len = sizeof(struct sockaddr);    len = sizeof(struct sockaddr);
   if ((news = accept(s,&peer,&len)) < 0) {    if ((news = accept(s,&peer,&len)) < 0) {
     errorMsg1s("Error in accept.");      errorMsg1s("Error in accept. Retrying (socketAcceptLocal2).");
     return(-1);      /* Code added for strange behavior on cygwin. */
       if ((news = accept(s,&peer,&len)) < 0) {
         errorMsg1s("Error in accept. Retry failed.");
         return (-1);
       }
   }    }
   
   len = sizeof(struct sockaddr);    len = sizeof(struct sockaddr);
Line 194  int oxSocketSelect0(int fd,int t) {
Line 194  int oxSocketSelect0(int fd,int t) {
   fd_set readfds;    fd_set readfds;
   struct timeval timeout;    struct timeval timeout;
   int debug = 0;    int debug = 0;
   extern int errno;  
   SET_TCPIOERROR;    SET_TCPIOERROR;
   FD_ZERO(&readfds);    FD_ZERO(&readfds);
   FD_SET(fd,&readfds);    FD_SET(fd,&readfds);
Line 226  oxSocketMultiSelect(int sid[],int size,int t,int resul
Line 225  oxSocketMultiSelect(int sid[],int size,int t,int resul
   fd_set readfds;    fd_set readfds;
   struct timeval timeout;    struct timeval timeout;
   int isdata = 0;    int isdata = 0;
   extern errno;  
   
   SET_TCPIOERROR;    SET_TCPIOERROR;
   FD_ZERO(&readfds);    FD_ZERO(&readfds);
Legend:
Removed from v.1.10  
changed lines
  Added in v.1.13
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>