version 1.1, 1999/10/08 02:12:05 |
version 1.4, 2000/09/08 16:08:42 |
|
|
|
/* $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.3 2000/03/20 01:53:47 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 22 static void errorMsg1s(char *s) { |
|
Line 23 static void errorMsg1s(char *s) { |
|
fprintf(stderr,"%s\n",s); |
fprintf(stderr,"%s\n",s); |
} |
} |
|
|
FILE *TcpioError = stdout; |
#define SET_TCPIOERROR { if (TcpioError == NULL) TcpioError = stdout; } |
|
FILE *TcpioError = NULL; |
int OpenedSocket = 0; |
int OpenedSocket = 0; |
extern int Quiet; |
extern int Quiet; |
|
|
Line 34 socketOpen(char *serverName,int portNumber) { |
|
Line 36 socketOpen(char *serverName,int portNumber) { |
|
extern int errno; |
extern int errno; |
int tt; |
int tt; |
|
|
|
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) { |
Line 80 socketOpen(char *serverName,int portNumber) { |
|
Line 82 socketOpen(char *serverName,int portNumber) { |
|
socketAccept(int snum) { |
socketAccept(int snum) { |
int s, news; |
int s, news; |
|
|
|
SET_TCPIOERROR; |
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) { |
Line 99 socketAcceptLocal(int snum) { |
|
Line 102 socketAcceptLocal(int snum) { |
|
struct sockaddr peer; |
struct sockaddr peer; |
int len; |
int len; |
int i; |
int i; |
|
|
|
SET_TCPIOERROR; |
s = snum; |
s = 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); |
Line 117 socketAcceptLocal(int snum) { |
|
Line 121 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 138 int oxSocketSelect0(int fd,int t) { |
|
Line 142 int oxSocketSelect0(int fd,int t) { |
|
struct timeval timeout; |
struct timeval timeout; |
int debug = 0; |
int debug = 0; |
extern int errno; |
extern int errno; |
|
SET_TCPIOERROR; |
FD_ZERO(&readfds); |
FD_ZERO(&readfds); |
FD_SET(fd,&readfds); |
FD_SET(fd,&readfds); |
timeout.tv_sec = 0; |
timeout.tv_sec = 0; |
Line 170 oxSocketMultiSelect(int sid[],int size,int t,int resul |
|
Line 175 oxSocketMultiSelect(int sid[],int size,int t,int resul |
|
int isdata = 0; |
int isdata = 0; |
extern errno; |
extern errno; |
|
|
|
SET_TCPIOERROR; |
FD_ZERO(&readfds); |
FD_ZERO(&readfds); |
timeout.tv_sec = 0; |
timeout.tv_sec = 0; |
timeout.tv_usec = (long)t; |
timeout.tv_usec = (long)t; |
Line 219 socketConnect(char *serverName,int portNumber) { |
|
Line 225 socketConnect(char *serverName,int portNumber) { |
|
int socketid; |
int socketid; |
int on; |
int on; |
|
|
|
SET_TCPIOERROR; |
if ((servhost = gethostbyname(serverName)) == NULL) { |
if ((servhost = gethostbyname(serverName)) == NULL) { |
errorMsg1s("bad server name.\n"); |
errorMsg1s("bad server name.\n"); |
return(-1); |
return(-1); |
Line 249 socketConnectWithPass(char *servername,int port,char * |
|
Line 256 socketConnectWithPass(char *servername,int port,char * |
|
{ |
{ |
int fd; |
int fd; |
int m; |
int m; |
|
SET_TCPIOERROR; |
fd = socketConnect(servername,port); |
fd = socketConnect(servername,port); |
if (fd >= 0) { |
if (fd >= 0) { |
m = write(fd,pass,strlen(pass)); |
m = write(fd,pass,strlen(pass)+1); |
if (m != strlen(pass)) { |
if (m != strlen(pass)+1) { |
fprintf(TcpioError,"Fail to send password to fd=%d.\n",fd); |
fprintf(TcpioError,"Fail to send password to fd=%d.\n",fd); |
return(-1); |
return(-1); |
} |
} |