| version 1.3, 2000/03/20 01:53:47 |
version 1.7, 2002/10/20 07:58:18 |
|
|
| /* $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.2 1999/10/30 02:22:16 takayama Exp $ */ |
/* $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.6 2002/02/24 10:27:20 takayama Exp $ */ |
| #include <stdio.h> |
#include <stdio.h> |
| #include <sys/types.h> |
#include <sys/types.h> |
| #include <sys/socket.h> |
#include <sys/socket.h> |
|
|
| #if defined(sun) |
#if defined(sun) |
| int MyEnv_oxmisc[2000]; |
int MyEnv_oxmisc[2000]; |
| #else |
#else |
| |
#if defined(__CYGWIN__) |
| |
sigjmp_buf MyEnv_oxmisc; /* may cause a trouble in Solaris. */ |
| |
#else |
| jmp_buf MyEnv_oxmisc; /* may cause a trouble in Solaris. */ |
jmp_buf MyEnv_oxmisc; /* may cause a trouble in Solaris. */ |
| #endif |
#endif |
| |
#endif |
| |
|
| #define READBUFSIZE 10000 |
#define READBUFSIZE 10000 |
| |
#define MAX_LISTEN_QUEUE 3 |
| static void errorMsg1s(char *s) { |
static void errorMsg1s(char *s) { |
| fprintf(stderr,"%s\n",s); |
fprintf(stderr,"%s\n",s); |
| } |
} |
| Line 38 socketOpen(char *serverName,int portNumber) { |
|
| Line 43 socketOpen(char *serverName,int portNumber) { |
|
| |
|
| SET_TCPIOERROR; |
SET_TCPIOERROR; |
| fprintf(TcpioError,"Hello from open. serverName is %s and portnumber is %d\n", |
fprintf(TcpioError,"Hello from open. serverName is %s and portnumber is %d\n", |
| serverName,portNumber); |
serverName,portNumber); |
| if ((myhost = gethostbyname(serverName)) == NULL) { |
if ((myhost = gethostbyname(serverName)) == NULL) { |
| errorMsg1s("Bad server name."); |
errorMsg1s("Bad server name."); |
| return(-1); |
return(-1); |
| Line 47 socketOpen(char *serverName,int portNumber) { |
|
| Line 52 socketOpen(char *serverName,int portNumber) { |
|
| 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 69 socketOpen(char *serverName,int portNumber) { |
|
| Line 74 socketOpen(char *serverName,int portNumber) { |
|
| return(-1); |
return(-1); |
| } |
} |
| |
|
| if (listen(s_waiting,1) < 0) { |
if (listen(s_waiting,MAX_LISTEN_QUEUE) < 0) { |
| errorMsg1s("Listen failed"); |
errorMsg1s("Listen failed"); |
| return(-1); |
return(-1); |
| } |
} |
| Line 121 socketAcceptLocal(int snum) { |
|
| Line 126 socketAcceptLocal(int snum) { |
|
| printf("\n"); |
printf("\n"); |
| if (peer.sa_data[2] == 0x7f && peer.sa_data[3] == 0 && |
if (peer.sa_data[2] == 0x7f && peer.sa_data[3] == 0 && |
| peer.sa_data[4] == 0 && peer.sa_data[5] == 1) { |
peer.sa_data[4] == 0 && peer.sa_data[5] == 1) { |
| fprintf(stderr,"Authentification: localhost is allowed to be accepted.\n"); |
fprintf(stderr,"Authentication: localhost is allowed to be accepted.\n"); |
| }else{ |
}else{ |
| errorMsg1s("Authentification: The connection is not from the localhost."); |
errorMsg1s("Authentication: The connection is not from the localhost."); |
| close(s); |
close(s); |
| fprintf(stderr,"The connection is refused."); |
fprintf(stderr,"The connection is refused."); |
| return(-1); |
return(-1); |
| Line 234 socketConnect(char *serverName,int portNumber) { |
|
| Line 239 socketConnect(char *serverName,int portNumber) { |
|
| 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"); |