=================================================================== RCS file: /home/cvs/OpenXM_contrib2/asir2000/io/sio.c,v retrieving revision 1.3 retrieving revision 1.26 diff -u -p -r1.3 -r1.26 --- OpenXM_contrib2/asir2000/io/sio.c 2000/02/08 04:47:11 1.3 +++ OpenXM_contrib2/asir2000/io/sio.c 2015/08/06 10:01:52 1.26 @@ -1,10 +1,57 @@ -/* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.2 1999/12/24 06:57:22 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.25 2012/12/17 07:20:45 noro Exp $ +*/ #include "ca.h" -#include "setjmp.h" +#include #include "ox.h" -#if defined(VISUAL) -#include +#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__) +#include +#include #else #include #include @@ -18,6 +65,7 @@ extern int little_endian; +int I_am_server; struct IOFP iofp[MAXIOFP]; #if !defined(_PA_RISC1_1) @@ -28,15 +76,16 @@ struct IOFP iofp[MAXIOFP]; void init_socket(void); -int getremotesocket(s) -int s; +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) +#define closesocket(s) (close((s))) +#endif + +int getremotesocket(int s) { return iofp[s].s; } -void getremotename(s,name) -int s; -char *name; +void getremotename(int s,char *name) { struct sockaddr_in peer; struct hostent *hp; @@ -51,35 +100,34 @@ char *name; strcpy(name,(char *)inet_ntoa(peer.sin_addr)); } -int generate_port(use_unix,port_str) -int use_unix; -char *port_str; +void generate_port(int use_unix,char *port_str) { double get_current_time(); unsigned long mt_genrand(); unsigned int port; static int count=0; +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) if ( use_unix ) { sprintf(port_str,"/tmp/ox%02x.XXXXXX",count); count++; mktemp(port_str); - } else { + } else +#endif + { port = ((unsigned int)mt_genrand()+(unsigned int)get_current_time()) %(65536-1024)+1024; sprintf(port_str,"%d",port); } } -int try_bind_listen(use_unix,port_str) -int use_unix; -char *port_str; +int try_bind_listen(int use_unix,char *port_str) { struct sockaddr_in sin; struct sockaddr *saddr; int len; int service; -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) struct sockaddr_un s_un; if ( use_unix ) { @@ -106,23 +154,23 @@ char *port_str; return -1; } 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); saddr = (struct sockaddr *)&sin; } if (bind(service, saddr, len) < 0) { perror("in bind"); - close(service); + closesocket(service); return -1; } if (getsockname(service,saddr, &len) < 0) { perror("in getsockname"); - close(service); + closesocket(service); return -1; } if (listen(service, SOCKQUEUELENGTH) < 0) { perror("in listen"); - close(service); + closesocket(service); return -1; } return service; @@ -142,13 +190,12 @@ char *port_str; the original socket is always closed. */ -int try_accept(af_unix,s) -int af_unix,s; +int try_accept(int af_unix,int s) { int len,c,i; struct sockaddr_in sin; -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) struct sockaddr_un s_un; if ( af_unix ) { len = sizeof(s_un); @@ -164,24 +211,22 @@ int af_unix,s; } if ( i == 10 ) c = -1; - close(s); + closesocket(s); return c; } -int try_connect(use_unix,host,port_str) -int use_unix; -char *host,*port_str; +int try_connect(int use_unix,char *host,char *port_str) { struct sockaddr_in sin; struct sockaddr *saddr; struct hostent *hp; int len,s,i; -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) struct sockaddr_un s_un; #endif for ( i = 0; i < 10; i++ ) { -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__) if ( use_unix ) { if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) { perror("socket"); @@ -200,12 +245,14 @@ char *host,*port_str; } else #endif /* VISUAL */ { + if ( !host ) + host = "127.0.0.1"; if ( (s = socket(AF_INET,SOCK_STREAM,0)) < 0 ) { perror("socket"); return -1; } 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); if ( sin.sin_addr.s_addr != -1 ) { sin.sin_family = AF_INET; @@ -220,8 +267,8 @@ char *host,*port_str; if ( connect(s,saddr,len) >= 0 ) break; else { - close(s); -#if defined(VISUAL) + closesocket(s); +#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__) Sleep(100); #else usleep(100000); @@ -235,7 +282,8 @@ char *host,*port_str; return s; } -close_allconnections() +#if 0 +void close_allconnections() { int s; @@ -246,8 +294,7 @@ close_allconnections() close_connection(s); } -close_connection(s) -int s; +void close_connection(int s) { struct IOFP *r; @@ -258,59 +305,79 @@ int s; free_iofp(s); } } +#else +void close_allconnections() +{ + shutdown_all(); +} +#endif -free_iofp(s) -int s; +void free_iofp(int s) { struct IOFP *r; r = &iofp[s]; - r->in = r->out = 0; r->s = 0; -#if !defined(VISUAL) - if ( r->socket ) - unlink(r->socket); +#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__) + if ( r->s ) closesocket(r->s); +#elif !defined(MPI) + if ( r->in ) fclose(r->in); + if ( r->out ) fclose(r->out); + if ( r->socket ) unlink(r->socket); #endif + r->inbuf = r->outbuf = 0; + r->in = r->out = 0; r->s = 0; } -#define LBUFSIZ BUFSIZ*10 - -int get_iofp(s1,af_sock,is_server) -int s1; -char *af_sock; -int is_server; +int get_iofp(int s1,char *af_sock,int is_server) { int i; unsigned char c,rc; + extern int mpi_myid; +#if defined(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++ ) if ( !iofp[i].in ) break; iofp[i].s = s1; -#if defined(VISUAL) || MPI +#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__) iofp[i].in = WSIO_open(s1,"r"); iofp[i].out = WSIO_open(s1,"w"); #else iofp[i].in = fdopen(s1,"r"); iofp[i].out = fdopen(s1,"w"); - setbuffer(iofp[i].in,(char *)malloc(LBUFSIZ),LBUFSIZ); - setbuffer(iofp[i].out,(char *)malloc(LBUFSIZ),LBUFSIZ); +#if !defined(__CYGWIN__) + setbuffer(iofp[i].in,iofp[i].inbuf = (char *)MALLOC_ATOMIC(LBUFSIZ),LBUFSIZ); + setbuffer(iofp[i].out,iofp[i].outbuf = (char *)MALLOC_ATOMIC(LBUFSIZ),LBUFSIZ); #endif -#if MPI - iofp[i].conv = 0; - iofp[i].socket = 0; -#else +#endif if ( little_endian ) c = 1; else c = 0xff; if ( is_server ) { /* server : write -> read */ - write_char(iofp[i].out,&c); ox_flush_stream_force(i); - read_char(iofp[i].in,&rc); + write_char((FILE *)iofp[i].out,&c); ox_flush_stream_force(i); + read_char((FILE *)iofp[i].in,&rc); } else { /* client : read -> write */ - read_char(iofp[i].in,&rc); - write_char(iofp[i].out,&c); ox_flush_stream_force(i); + read_char((FILE *)iofp[i].in,&rc); + /* 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; if ( af_sock && af_sock[0] ) { @@ -318,11 +385,11 @@ int is_server; strcpy(iofp[i].socket,af_sock); } else iofp[i].socket = 0; -#endif return i; +#endif } -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__) void init_socket() { static int socket_is_initialized; @@ -339,14 +406,12 @@ void init_socket() } #endif -get_fd(index) -int index; +int get_fd(int index) { return iofp[index].s; } -get_index(fd) -int fd; +int get_index(int fd) { int i; @@ -355,4 +420,4 @@ int fd; return i; return -1; } -#endif /* INET */ +