version 1.8, 2002/10/20 08:26:00 |
version 1.12, 2003/09/16 02:57:39 |
|
|
/* $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.7 2002/10/20 07:58:18 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 113 socketAcceptLocal(int snum) { |
|
Line 117 socketAcceptLocal(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"); |
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 154 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 299 socketConnectWithPass(char *servername,int port,char * |
|
Line 311 socketConnectWithPass(char *servername,int port,char * |
|
int m; |
int m; |
SET_TCPIOERROR; |
SET_TCPIOERROR; |
fd = socketConnect(servername,port); |
fd = socketConnect(servername,port); |
|
if ((pass == NULL) && (fd >= 0)) return fd; |
|
if ((pass == NULL) && (fd < 0)) return -1; |
if (fd >= 0) { |
if (fd >= 0) { |
m = write(fd,pass,strlen(pass)+1); |
m = write(fd,pass,strlen(pass)+1); |
if (m != strlen(pass)+1) { |
if (m != strlen(pass)+1) { |