version 1.2, 1999/12/24 06:57:22 |
version 1.19, 2003/01/28 08:38:59 |
|
|
/* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.1.1.1 1999/12/03 07:39:11 noro Exp $ */ |
/* |
#if INET |
* Copyright (c) 1994-2000 FUJITSU LABORATORIES LIMITED |
|
* All rights reserved. |
|
* |
|
* FUJITSU LABORATORIES LIMITED ("FLL") hereby grants you a limited, |
|
* non-exclusive and royalty-free license to use, copy, modify and |
|
* redistribute, solely for non-commercial and non-profit purposes, the |
|
* computer program, "Risa/Asir" ("SOFTWARE"), subject to the terms and |
|
* conditions of this Agreement. For the avoidance of doubt, you acquire |
|
* only a limited right to use the SOFTWARE hereunder, and FLL or any |
|
* third party developer retains all rights, including but not limited to |
|
* copyrights, in and to the SOFTWARE. |
|
* |
|
* (1) FLL does not grant you a license in any way for commercial |
|
* purposes. You may use the SOFTWARE only for non-commercial and |
|
* non-profit purposes only, such as academic, research and internal |
|
* business use. |
|
* (2) The SOFTWARE is protected by the Copyright Law of Japan and |
|
* international copyright treaties. If you make copies of the SOFTWARE, |
|
* with or without modification, as permitted hereunder, you shall affix |
|
* to all such copies of the SOFTWARE the above copyright notice. |
|
* (3) An explicit reference to this SOFTWARE and its copyright owner |
|
* shall be made on your publication or presentation in any form of the |
|
* results obtained by use of the SOFTWARE. |
|
* (4) In the event that you modify the SOFTWARE, you shall notify FLL by |
|
* e-mail at risa-admin@sec.flab.fujitsu.co.jp of the detailed specification |
|
* for such modification or the source code of the modified part of the |
|
* SOFTWARE. |
|
* |
|
* THE SOFTWARE IS PROVIDED AS IS WITHOUT ANY WARRANTY OF ANY KIND. FLL |
|
* MAKES ABSOLUTELY NO WARRANTIES, EXPRESSED, IMPLIED OR STATUTORY, AND |
|
* EXPRESSLY DISCLAIMS ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS |
|
* FOR A PARTICULAR PURPOSE OR NONINFRINGEMENT OF THIRD PARTIES' |
|
* RIGHTS. NO FLL DEALER, AGENT, EMPLOYEES IS AUTHORIZED TO MAKE ANY |
|
* MODIFICATIONS, EXTENSIONS, OR ADDITIONS TO THIS WARRANTY. |
|
* UNDER NO CIRCUMSTANCES AND UNDER NO LEGAL THEORY, TORT, CONTRACT, |
|
* OR OTHERWISE, SHALL FLL BE LIABLE TO YOU OR ANY OTHER PERSON FOR ANY |
|
* DIRECT, INDIRECT, SPECIAL, INCIDENTAL, PUNITIVE OR CONSEQUENTIAL |
|
* DAMAGES OF ANY CHARACTER, INCLUDING, WITHOUT LIMITATION, DAMAGES |
|
* ARISING OUT OF OR RELATING TO THE SOFTWARE OR THIS AGREEMENT, DAMAGES |
|
* FOR LOSS OF GOODWILL, WORK STOPPAGE, OR LOSS OF DATA, OR FOR ANY |
|
* DAMAGES, EVEN IF FLL SHALL HAVE BEEN INFORMED OF THE POSSIBILITY OF |
|
* SUCH DAMAGES, OR FOR ANY CLAIM BY ANY OTHER PARTY. EVEN IF A PART |
|
* OF THE SOFTWARE HAS BEEN DEVELOPED BY A THIRD PARTY, THE THIRD PARTY |
|
* DEVELOPER SHALL HAVE NO LIABILITY IN CONNECTION WITH THE USE, |
|
* PERFORMANCE OR NON-PERFORMANCE OF THE SOFTWARE. |
|
* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.18 2002/10/03 07:12:30 noro Exp $ |
|
*/ |
#include "ca.h" |
#include "ca.h" |
|
#include <setjmp.h> |
#include "ox.h" |
#include "ox.h" |
#if defined(VISUAL) |
#if defined(VISUAL) |
#include <winsock.h> |
#include <winsock2.h> |
|
#include <io.h> |
#else |
#else |
#include <sys/time.h> |
#include <sys/time.h> |
#include <sys/uio.h> |
#include <sys/uio.h> |
|
|
|
|
extern int little_endian; |
extern int little_endian; |
|
|
|
int I_am_server; |
struct IOFP iofp[MAXIOFP]; |
struct IOFP iofp[MAXIOFP]; |
|
|
#if !defined(_PA_RISC1_1) |
#if !defined(_PA_RISC1_1) |
Line 27 struct IOFP iofp[MAXIOFP]; |
|
Line 76 struct IOFP iofp[MAXIOFP]; |
|
|
|
void init_socket(void); |
void init_socket(void); |
|
|
int getremotesocket(s) |
int getremotesocket(int s) |
int s; |
|
{ |
{ |
return iofp[s].s; |
return iofp[s].s; |
} |
} |
|
|
void getremotename(s,name) |
void getremotename(int s,char *name) |
int s; |
|
char *name; |
|
{ |
{ |
struct sockaddr_in peer; |
struct sockaddr_in peer; |
struct hostent *hp; |
struct hostent *hp; |
|
|
strcpy(name,(char *)inet_ntoa(peer.sin_addr)); |
strcpy(name,(char *)inet_ntoa(peer.sin_addr)); |
} |
} |
|
|
int generate_port(use_unix,port_str) |
void generate_port(int use_unix,char *port_str) |
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 ( 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 |
|
{ |
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(use_unix,port_str) |
int try_bind_listen(int use_unix,char *port_str) |
int use_unix; |
|
char *port_str; |
|
{ |
{ |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
struct sockaddr *saddr; |
struct sockaddr *saddr; |
|
|
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(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; |
} |
} |
|
|
the original socket is always closed. |
the original socket is always closed. |
*/ |
*/ |
|
|
int try_accept(af_unix,s) |
int try_accept(int af_unix,int s) |
int af_unix,s; |
|
{ |
{ |
int len,c,i; |
int len,c,i; |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
|
|
return c; |
return c; |
} |
} |
|
|
int try_connect(use_unix,host,port_str) |
int try_connect(int use_unix,char *host,char *port_str) |
int use_unix; |
|
char *host,*port_str; |
|
{ |
{ |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
struct sockaddr *saddr; |
struct sockaddr *saddr; |
Line 199 char *host,*port_str; |
|
Line 241 char *host,*port_str; |
|
} else |
} else |
#endif /* VISUAL */ |
#endif /* VISUAL */ |
{ |
{ |
|
if ( !host ) |
|
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(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; |
Line 234 char *host,*port_str; |
|
Line 278 char *host,*port_str; |
|
return s; |
return s; |
} |
} |
|
|
close_allconnections() |
#if 0 |
|
void close_allconnections() |
{ |
{ |
int s; |
int s; |
|
|
Line 245 close_allconnections() |
|
Line 290 close_allconnections() |
|
close_connection(s); |
close_connection(s); |
} |
} |
|
|
close_connection(s) |
void close_connection(int s) |
int s; |
|
{ |
{ |
struct IOFP *r; |
struct IOFP *r; |
|
|
|
|
free_iofp(s); |
free_iofp(s); |
} |
} |
} |
} |
|
#else |
|
void close_allconnections() |
|
{ |
|
shutdown_all(); |
|
} |
|
#endif |
|
|
free_iofp(s) |
void free_iofp(int s) |
int s; |
|
{ |
{ |
struct IOFP *r; |
struct IOFP *r; |
|
|
r = &iofp[s]; |
r = &iofp[s]; |
r->in = r->out = 0; r->s = 0; |
#if defined(VISUAL) |
#if !defined(VISUAL) |
if ( r->s ) close(r->s); |
if ( r->socket ) |
#elif !MPI |
unlink(r->socket); |
if ( r->in ) fclose(r->in); |
|
if ( r->out ) fclose(r->out); |
|
if ( r->socket ) unlink(r->socket); |
#endif |
#endif |
|
r->in = r->out = 0; r->s = 0; |
} |
} |
|
|
#define LBUFSIZ BUFSIZ*10 |
int get_iofp(int s1,char *af_sock,int is_server) |
|
|
int get_iofp(s1,af_sock,is_server) |
|
int s1; |
|
char *af_sock; |
|
int is_server; |
|
{ |
{ |
int i; |
int i; |
unsigned char c,rc; |
unsigned char c,rc; |
|
extern int mpi_myid; |
|
|
|
#if MPI |
|
iofp[s1].s = s1; |
|
if ( mpi_myid == s1 ) { |
|
iofp[s1].in = 0; |
|
iofp[s1].out = 0; |
|
} else { |
|
iofp[s1].in = WSIO_open(s1,"r"); |
|
iofp[s1].out = WSIO_open(s1,"w"); |
|
} |
|
iofp[s1].conv = 0; |
|
iofp[s1].socket = 0; |
|
|
|
return s1; |
|
#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) || MPI |
#if defined(VISUAL) |
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__) |
setbuffer(iofp[i].in,(char *)malloc(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].in,(char *)malloc(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].out,(char *)malloc(LBUFSIZ),LBUFSIZ); |
setbuffer(iofp[i].out,(char *)malloc(LBUFSIZ),LBUFSIZ); |
#endif |
#endif |
#if MPI |
#endif |
iofp[i].conv = 0; |
|
iofp[i].socket = 0; |
|
#else |
|
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(iofp[i].out,&c); ox_flush_stream_force(i); |
write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); |
read_char(iofp[i].in,&rc); |
read_char((FILE *)iofp[i].in,&rc); |
} else { |
} else { |
/* client : read -> write */ |
/* client : read -> write */ |
read_char(iofp[i].in,&rc); |
read_char((FILE *)iofp[i].in,&rc); |
write_char(iofp[i].out,&c); ox_flush_stream_force(i); |
/* special care for a failure of spawing a server */ |
|
if ( rc !=0 && rc != 1 && rc != 0xff ) |
|
return -1; |
|
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] ) { |
|
|
strcpy(iofp[i].socket,af_sock); |
strcpy(iofp[i].socket,af_sock); |
} else |
} else |
iofp[i].socket = 0; |
iofp[i].socket = 0; |
#endif |
|
return i; |
return i; |
|
#endif |
} |
} |
|
|
#if defined(VISUAL) |
#if defined(VISUAL) |
Line 338 void init_socket() |
|
Line 401 void init_socket() |
|
} |
} |
#endif |
#endif |
|
|
get_fd(index) |
int get_fd(int index) |
int index; |
|
{ |
{ |
return iofp[index].s; |
return iofp[index].s; |
} |
} |
|
|
get_index(fd) |
int get_index(int fd) |
int fd; |
|
{ |
{ |
int i; |
int i; |
|
|
|
|
return i; |
return i; |
return -1; |
return -1; |
} |
} |
#endif /* INET */ |
|