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

version 1.10, 2003/07/20 07:18:45 version 1.12, 2003/09/16 02:57:39
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.11 2003/07/20 07:23:31 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 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);
Legend:
Removed from v.1.10  
changed lines
  Added in v.1.12
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>