version 1.24, 2011/02/06 07:07:39 |
version 1.28, 2018/03/29 01:32:53 |
|
|
* OF THE SOFTWARE HAS BEEN DEVELOPED BY A THIRD PARTY, THE THIRD PARTY |
* OF THE SOFTWARE HAS BEEN DEVELOPED BY A THIRD PARTY, THE THIRD PARTY |
* DEVELOPER SHALL HAVE NO LIABILITY IN CONNECTION WITH THE USE, |
* DEVELOPER SHALL HAVE NO LIABILITY IN CONNECTION WITH THE USE, |
* PERFORMANCE OR NON-PERFORMANCE OF THE SOFTWARE. |
* PERFORMANCE OR NON-PERFORMANCE OF THE SOFTWARE. |
* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.23 2003/03/07 06:39:57 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.27 2015/08/14 13:51:55 fujimoto Exp $ |
*/ |
*/ |
#include "ca.h" |
#include "ca.h" |
#include <setjmp.h> |
#include <setjmp.h> |
#include "ox.h" |
#include "ox.h" |
#if defined(VISUAL) |
#if defined(VISUAL) || defined(__MINGW32__) |
#include <winsock2.h> |
#include <winsock2.h> |
#include <io.h> |
#include <io.h> |
#else |
#else |
Line 76 struct IOFP iofp[MAXIOFP]; |
|
Line 76 struct IOFP iofp[MAXIOFP]; |
|
|
|
void init_socket(void); |
void init_socket(void); |
|
|
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
#define closesocket(s) (close((s))) |
#define closesocket(s) (close((s))) |
#endif |
#endif |
|
|
int getremotesocket(int s) |
int getremotesocket(int s) |
{ |
{ |
return iofp[s].s; |
return iofp[s].s; |
} |
} |
|
|
void getremotename(int s,char *name) |
void getremotename(int s,char *name) |
{ |
{ |
struct sockaddr_in peer; |
struct sockaddr_in peer; |
struct hostent *hp; |
struct hostent *hp; |
int peerlen; |
int peerlen; |
|
|
peerlen = sizeof(peer); |
peerlen = sizeof(peer); |
getpeername(getremotesocket(s),(struct sockaddr *)&peer,&peerlen); |
getpeername(getremotesocket(s),(struct sockaddr *)&peer,&peerlen); |
hp = gethostbyaddr((char *)&peer.sin_addr,sizeof(struct in_addr),AF_INET); |
hp = gethostbyaddr((char *)&peer.sin_addr,sizeof(struct in_addr),AF_INET); |
if ( hp ) |
if ( hp ) |
strcpy(name,hp->h_name); |
strcpy(name,hp->h_name); |
else |
else |
strcpy(name,(char *)inet_ntoa(peer.sin_addr)); |
strcpy(name,(char *)inet_ntoa(peer.sin_addr)); |
} |
} |
|
|
void generate_port(int use_unix,char *port_str) |
void generate_port(int use_unix,char *port_str) |
{ |
{ |
double get_current_time(); |
double get_current_time(); |
unsigned long mt_genrand(); |
unsigned long mt_genrand(); |
unsigned int port; |
unsigned int port; |
static int count=0; |
static int count=0; |
|
|
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
if ( use_unix ) { |
if ( use_unix ) { |
sprintf(port_str,"/tmp/ox%02x.XXXXXX",count); |
sprintf(port_str,"/tmp/ox%02x.XXXXXX",count); |
count++; |
count++; |
mktemp(port_str); |
mktemp(port_str); |
} else |
} else |
#endif |
#endif |
{ |
{ |
port = ((unsigned int)mt_genrand()+(unsigned int)get_current_time()) |
port = ((unsigned int)mt_genrand()+(unsigned int)get_current_time()) |
%(65536-1024)+1024; |
%(65536-1024)+1024; |
sprintf(port_str,"%d",port); |
sprintf(port_str,"%d",port); |
} |
} |
} |
} |
|
|
int try_bind_listen(int use_unix,char *port_str) |
int try_bind_listen(int use_unix,char *port_str) |
{ |
{ |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
struct sockaddr *saddr; |
struct sockaddr *saddr; |
int len; |
int len; |
int service; |
int service; |
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
struct sockaddr_un s_un; |
struct sockaddr_un s_un; |
|
|
if ( use_unix ) { |
if ( use_unix ) { |
service = socket(AF_UNIX, SOCK_STREAM, 0); |
service = socket(AF_UNIX, SOCK_STREAM, 0); |
if (service < 0) { |
if (service < 0) { |
perror("in socket"); |
perror("in socket"); |
return -1; |
return -1; |
} |
} |
s_un.sun_family = AF_UNIX; |
s_un.sun_family = AF_UNIX; |
strcpy(s_un.sun_path,port_str); |
strcpy(s_un.sun_path,port_str); |
#if defined(__FreeBSD__) |
#if defined(__FreeBSD__) |
len = SUN_LEN(&s_un); |
len = SUN_LEN(&s_un); |
s_un.sun_len = len+1; /* XXX */ |
s_un.sun_len = len+1; /* XXX */ |
#else |
#else |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
#endif |
#endif |
saddr = (struct sockaddr *)&s_un; |
saddr = (struct sockaddr *)&s_un; |
} else |
} else |
#endif |
#endif |
{ |
{ |
service = socket(AF_INET, SOCK_STREAM, 0); |
service = socket(AF_INET, SOCK_STREAM, 0); |
if ( service < 0 ) { |
if ( service < 0 ) { |
perror("in socket"); |
perror("in socket"); |
return -1; |
return -1; |
} |
} |
sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY; |
sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY; |
sin.sin_port = htons((unsigned short)atoi(port_str)); |
sin.sin_port = htons((unsigned short)atoi(port_str)); |
len = sizeof(sin); |
len = sizeof(sin); |
saddr = (struct sockaddr *)&sin; |
saddr = (struct sockaddr *)&sin; |
} |
} |
if (bind(service, saddr, len) < 0) { |
if (bind(service, saddr, len) < 0) { |
perror("in bind"); |
perror("in bind"); |
closesocket(service); |
closesocket(service); |
return -1; |
return -1; |
} |
} |
if (getsockname(service,saddr, &len) < 0) { |
if (getsockname(service,saddr, &len) < 0) { |
perror("in getsockname"); |
perror("in getsockname"); |
closesocket(service); |
closesocket(service); |
return -1; |
return -1; |
} |
} |
if (listen(service, SOCKQUEUELENGTH) < 0) { |
if (listen(service, SOCKQUEUELENGTH) < 0) { |
perror("in listen"); |
perror("in listen"); |
closesocket(service); |
closesocket(service); |
return -1; |
return -1; |
} |
} |
return service; |
return service; |
} |
} |
|
|
/* |
/* |
Line 192 int try_bind_listen(int use_unix,char *port_str) |
|
Line 192 int try_bind_listen(int use_unix,char *port_str) |
|
|
|
int try_accept(int af_unix,int s) |
int try_accept(int af_unix,int s) |
{ |
{ |
int len,c,i; |
int len,c,i; |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
|
|
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
struct sockaddr_un s_un; |
struct sockaddr_un s_un; |
if ( af_unix ) { |
if ( af_unix ) { |
len = sizeof(s_un); |
len = sizeof(s_un); |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
c = accept(s, (struct sockaddr *) &s_un, &len); |
c = accept(s, (struct sockaddr *) &s_un, &len); |
} else |
} else |
#endif |
#endif |
{ |
{ |
|
|
len = sizeof(sin); |
len = sizeof(sin); |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
c = accept(s, (struct sockaddr *) &sin, &len); |
c = accept(s, (struct sockaddr *) &sin, &len); |
} |
} |
if ( i == 10 ) |
if ( i == 10 ) |
c = -1; |
c = -1; |
closesocket(s); |
closesocket(s); |
return c; |
return c; |
} |
} |
|
|
int try_connect(int use_unix,char *host,char *port_str) |
int try_connect(int use_unix,char *host,char *port_str) |
{ |
{ |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
struct sockaddr *saddr; |
struct sockaddr *saddr; |
struct hostent *hp; |
struct hostent *hp; |
int len,s,i; |
int len,s,i; |
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
struct sockaddr_un s_un; |
struct sockaddr_un s_un; |
#endif |
#endif |
|
|
for ( i = 0; i < 10; i++ ) { |
for ( i = 0; i < 10; i++ ) { |
#if !defined(VISUAL) |
#if !defined(VISUAL) && !defined(__MINGW32__) |
if ( use_unix ) { |
if ( use_unix ) { |
if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) { |
if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) { |
perror("socket"); |
perror("socket"); |
return -1; |
return -1; |
} |
} |
bzero(&s_un,sizeof(s_un)); |
bzero(&s_un,sizeof(s_un)); |
s_un.sun_family = AF_UNIX; |
s_un.sun_family = AF_UNIX; |
strcpy(s_un.sun_path,port_str); |
strcpy(s_un.sun_path,port_str); |
#if defined(__FreeBSD__) |
#if defined(__FreeBSD__) |
len = SUN_LEN(&s_un); |
len = SUN_LEN(&s_un); |
s_un.sun_len = len+1; /* XXX */ |
s_un.sun_len = len+1; /* XXX */ |
#else |
#else |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
#endif |
#endif |
saddr = (struct sockaddr *)&s_un; |
saddr = (struct sockaddr *)&s_un; |
} else |
} else |
#endif /* VISUAL */ |
#endif /* VISUAL */ |
{ |
{ |
if ( !host ) |
if ( !host ) |
host = "127.0.0.1"; |
host = "127.0.0.1"; |
if ( (s = socket(AF_INET,SOCK_STREAM,0)) < 0 ) { |
if ( (s = socket(AF_INET,SOCK_STREAM,0)) < 0 ) { |
perror("socket"); |
perror("socket"); |
return -1; |
return -1; |
} |
} |
bzero(&sin,sizeof(sin)); |
bzero(&sin,sizeof(sin)); |
sin.sin_port = htons((unsigned short)atoi(port_str)); |
sin.sin_port = htons((unsigned short)atoi(port_str)); |
sin.sin_addr.s_addr = inet_addr(host); |
sin.sin_addr.s_addr = inet_addr(host); |
if ( sin.sin_addr.s_addr != -1 ) { |
if ( sin.sin_addr.s_addr != -1 ) { |
sin.sin_family = AF_INET; |
sin.sin_family = AF_INET; |
} else { |
} else { |
hp = gethostbyname(host); |
hp = gethostbyname(host); |
bcopy(hp->h_addr,&sin.sin_addr,hp->h_length); |
bcopy(hp->h_addr,&sin.sin_addr,hp->h_length); |
sin.sin_family = hp->h_addrtype; |
sin.sin_family = hp->h_addrtype; |
} |
} |
len = sizeof(sin); |
len = sizeof(sin); |
saddr = (struct sockaddr *)&sin; |
saddr = (struct sockaddr *)&sin; |
} |
} |
if ( connect(s,saddr,len) >= 0 ) |
if ( connect(s,saddr,len) >= 0 ) |
break; |
break; |
else { |
else { |
closesocket(s); |
closesocket(s); |
#if defined(VISUAL) |
#if defined(VISUAL) || defined(__MINGW32__) |
Sleep(100); |
Sleep(100); |
#else |
#else |
usleep(100000); |
usleep(100000); |
#endif |
#endif |
} |
} |
} |
} |
if ( i == 10 ) { |
if ( i == 10 ) { |
perror("connect"); |
perror("connect"); |
return -1; |
return -1; |
} else |
} else |
return s; |
return s; |
} |
} |
|
|
#if 0 |
#if 0 |
void close_allconnections() |
void close_allconnections() |
{ |
{ |
int s; |
int s; |
|
|
#if defined(SIGPIPE) |
#if defined(SIGPIPE) |
signal(SIGPIPE,SIG_IGN); |
signal(SIGPIPE,SIG_IGN); |
#endif |
#endif |
for ( s = 0; s < MAXIOFP; s++ ) |
for ( s = 0; s < MAXIOFP; s++ ) |
close_connection(s); |
close_connection(s); |
} |
} |
|
|
void close_connection(int s) |
void close_connection(int s) |
{ |
{ |
struct IOFP *r; |
struct IOFP *r; |
|
|
r = &iofp[s]; |
r = &iofp[s]; |
if ( r->in && r->out ) { |
if ( r->in && r->out ) { |
if ( check_sm_by_mc(s,SM_shutdown) ) |
if ( check_sm_by_mc(s,SM_shutdown) ) |
ox_send_cmd(s,SM_shutdown); |
ox_send_cmd(s,SM_shutdown); |
free_iofp(s); |
free_iofp(s); |
} |
} |
} |
} |
#else |
#else |
void close_allconnections() |
void close_allconnections() |
{ |
{ |
shutdown_all(); |
shutdown_all(); |
} |
} |
#endif |
#endif |
|
|
void free_iofp(int s) |
void free_iofp(int s) |
{ |
{ |
struct IOFP *r; |
struct IOFP *r; |
|
|
r = &iofp[s]; |
r = &iofp[s]; |
#if defined(VISUAL) |
#if defined(VISUAL) || defined(__MINGW32__) |
if ( r->s ) closesocket(r->s); |
if ( r->s ) closesocket(r->s); |
#elif !defined(MPI) |
#elif !defined(MPI) |
if ( r->in ) fclose(r->in); |
if ( r->in ) fclose(r->in); |
if ( r->out ) fclose(r->out); |
if ( r->out ) fclose(r->out); |
if ( r->socket ) unlink(r->socket); |
if ( r->socket ) unlink(r->socket); |
#endif |
#endif |
r->inbuf = r->outbuf = 0; |
r->inbuf = r->outbuf = 0; |
r->in = r->out = 0; r->s = 0; |
r->in = r->out = 0; r->s = 0; |
} |
} |
|
|
int get_iofp(int s1,char *af_sock,int is_server) |
int get_iofp(int s1,char *af_sock,int is_server) |
{ |
{ |
int i; |
int i; |
unsigned char c,rc; |
unsigned char c,rc; |
extern int mpi_myid; |
extern int mpi_myid; |
|
|
#if defined(MPI) |
#if defined(MPI) |
iofp[s1].s = s1; |
iofp[s1].s = s1; |
if ( mpi_myid == s1 ) { |
if ( mpi_myid == s1 ) { |
iofp[s1].in = 0; |
iofp[s1].in = 0; |
iofp[s1].out = 0; |
iofp[s1].out = 0; |
} else { |
} else { |
iofp[s1].in = WSIO_open(s1,"r"); |
iofp[s1].in = WSIO_open(s1,"r"); |
iofp[s1].out = WSIO_open(s1,"w"); |
iofp[s1].out = WSIO_open(s1,"w"); |
} |
} |
iofp[s1].conv = 0; |
iofp[s1].conv = 0; |
iofp[s1].socket = 0; |
iofp[s1].socket = 0; |
|
|
return s1; |
return s1; |
#else |
#else |
for ( i = 0; i < MAXIOFP; i++ ) |
for ( i = 0; i < MAXIOFP; i++ ) |
if ( !iofp[i].in ) |
if ( !iofp[i].in ) |
break; |
break; |
iofp[i].s = s1; |
iofp[i].s = s1; |
#if defined(VISUAL) |
#if defined(VISUAL) || defined(__MINGW32__) |
iofp[i].in = WSIO_open(s1,"r"); |
iofp[i].in = WSIO_open(s1,"r"); |
iofp[i].out = WSIO_open(s1,"w"); |
iofp[i].out = WSIO_open(s1,"w"); |
#else |
#else |
iofp[i].in = fdopen(s1,"r"); |
iofp[i].in = fdopen(s1,"r"); |
iofp[i].out = fdopen(s1,"w"); |
iofp[i].out = fdopen(s1,"w"); |
#if !defined(__CYGWIN__) |
#if !defined(__CYGWIN__) |
setbuffer(iofp[i].in,iofp[i].inbuf = (char *)GC_malloc_atomic(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].in,iofp[i].inbuf = (char *)MALLOC_ATOMIC(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].out,iofp[i].outbuf = (char *)GC_malloc_atomic(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].out,iofp[i].outbuf = (char *)MALLOC_ATOMIC(LBUFSIZ),LBUFSIZ); |
#endif |
#endif |
#endif |
#endif |
if ( little_endian ) |
if ( little_endian ) |
c = 1; |
c = 1; |
else |
else |
c = 0xff; |
c = 0xff; |
if ( is_server ) { |
if ( is_server ) { |
/* server : write -> read */ |
/* server : write -> read */ |
write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); |
write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); |
read_char((FILE *)iofp[i].in,&rc); |
read_char((FILE *)iofp[i].in,&rc); |
} else { |
} else { |
/* client : read -> write */ |
/* client : read -> write */ |
read_char((FILE *)iofp[i].in,&rc); |
read_char((FILE *)iofp[i].in,&rc); |
/* special care for a failure of spawing a server */ |
/* special care for a failure of spawing a server */ |
if ( rc !=0 && rc != 1 && rc != 0xff ) |
if ( rc !=0 && rc != 1 && rc != 0xff ) |
return -1; |
return -1; |
write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); |
write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); |
} |
} |
iofp[i].conv = c == rc ? 0 : 1; |
iofp[i].conv = c == rc ? 0 : 1; |
if ( af_sock && af_sock[0] ) { |
if ( af_sock && af_sock[0] ) { |
iofp[i].socket = (char *)malloc(strlen(af_sock)+1); |
iofp[i].socket = (char *)malloc(strlen(af_sock)+1); |
strcpy(iofp[i].socket,af_sock); |
strcpy(iofp[i].socket,af_sock); |
} else |
} else |
iofp[i].socket = 0; |
iofp[i].socket = 0; |
return i; |
return i; |
#endif |
#endif |
} |
} |
|
|
#if defined(VISUAL) |
#if defined(VISUAL) || defined(__MINGW32__) |
void init_socket() |
void init_socket() |
{ |
{ |
static int socket_is_initialized; |
static int socket_is_initialized; |
WORD wVersionRequested; |
WORD wVersionRequested; |
WSADATA wsaData; |
WSADATA wsaData; |
int err; |
int err; |
wVersionRequested = MAKEWORD(2,0); |
wVersionRequested = MAKEWORD(2,0); |
|
|
if ( socket_is_initialized ) |
if ( socket_is_initialized ) |
return; |
return; |
err = WSAStartup(wVersionRequested,&wsaData); |
err = WSAStartup(wVersionRequested,&wsaData); |
if ( err ) |
if ( err ) |
return; |
return; |
} |
} |
#endif |
#endif |
|
|
int get_fd(int index) |
int get_fd(int index) |
{ |
{ |
return iofp[index].s; |
return iofp[index].s; |
} |
} |
|
|
int get_index(int fd) |
int get_index(int fd) |
{ |
{ |
int i; |
int i; |
|
|
for ( i = 0; i < MAXIOFP; i++ ) |
for ( i = 0; i < MAXIOFP; i++ ) |
if ( iofp[i].s == fd ) |
if ( iofp[i].s == fd ) |
return i; |
return i; |
return -1; |
return -1; |
} |
} |
|
|