version 1.5, 2000/08/21 08:31:39 |
version 1.9.2.4, 2000/11/11 06:37:08 |
|
|
* shall be made on your publication or presentation in any form of the |
* shall be made on your publication or presentation in any form of the |
* results obtained by use of the SOFTWARE. |
* results obtained by use of the SOFTWARE. |
* (4) In the event that you modify the SOFTWARE, you shall notify FLL by |
* (4) In the event that you modify the SOFTWARE, you shall notify FLL by |
* e-mail at risa-admin@flab.fujitsu.co.jp of the detailed specification |
* 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 |
* for such modification or the source code of the modified part of the |
* SOFTWARE. |
* SOFTWARE. |
* |
* |
|
|
* 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.4 2000/07/13 05:09:02 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.9.2.3 2000/11/10 14:57:24 maekawa Exp $ |
*/ |
*/ |
#if INET |
#if INET |
#include "ca.h" |
#include "ca.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 85 void getremotename(s,name) |
|
Line 86 void getremotename(s,name) |
|
int s; |
int s; |
char *name; |
char *name; |
{ |
{ |
struct sockaddr_in peer; |
struct sockaddr_storage ss; |
struct hostent *hp; |
struct sockaddr *sa; |
int peerlen; |
socklen_t len; |
|
char host[NI_MAXHOST]; |
|
int rs; |
|
|
peerlen = sizeof(peer); |
rs = getremotesocket(s); |
getpeername(getremotesocket(s),(struct sockaddr *)&peer,&peerlen); |
len = sizeof(ss); |
hp = gethostbyaddr((char *)&peer.sin_addr,sizeof(struct in_addr),AF_INET); |
getpeername(rs, (struct sockaddr *)&ss, &len); |
if ( hp ) |
sa = (struct sockaddr *)&ss; |
strcpy(name,hp->h_name); |
getnameinfo(sa, sa->sa_len, host, sizeof(host), NULL, 0, 0); |
else |
strcpy(name, host); |
strcpy(name,(char *)inet_ntoa(peer.sin_addr)); |
|
} |
} |
|
|
int generate_port(use_unix,port_str) |
int generate_port(use_unix,port_str) |
|
|
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); |
Line 122 int try_bind_listen(use_unix,port_str) |
|
Line 127 int try_bind_listen(use_unix,port_str) |
|
int use_unix; |
int use_unix; |
char *port_str; |
char *port_str; |
{ |
{ |
struct sockaddr_in sin; |
struct addrinfo hints, *res, *ai; |
struct sockaddr *saddr; |
int s, error; |
int len; |
char *errstr; |
int service; |
|
#if !defined(VISUAL) |
|
struct sockaddr_un s_un; |
|
|
|
if ( use_unix ) { |
memset(&hints, 0, sizeof(hints)); |
service = socket(AF_UNIX, SOCK_STREAM, 0); |
#if defined(VISUAL) |
if (service < 0) { |
hints.ai_family = PF_UNSPEC; |
perror("in socket"); |
|
return -1; |
|
} |
|
s_un.sun_family = AF_UNIX; |
|
strcpy(s_un.sun_path,port_str); |
|
#if defined(__FreeBSD__) |
|
len = SUN_LEN(&s_un); |
|
s_un.sun_len = len+1; /* XXX */ |
|
#else |
#else |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
if (use_unix) |
#endif |
hints.ai_family = PF_UNIX; |
saddr = (struct sockaddr *)&s_un; |
else |
} else |
hints.ai_family = PF_UNSPEC; |
#endif |
#endif /* VISUAL */ |
{ |
hints.ai_socktype = SOCK_STREAM; |
service = socket(AF_INET, SOCK_STREAM, 0); |
|
if ( service < 0 ) { |
error = getaddrinfo(NULL, port_str, &hints, &res); |
perror("in socket"); |
if (error) { |
return -1; |
warnx("try_bind_listen(): %s", gai_strerror(error)); |
|
return (-1); |
|
} |
|
|
|
s = -1; |
|
for (ai = res ; ai != NULL ; ai = ai->ai_next) { |
|
if ((s = socket(ai->ai_family, ai->ai_socktype, |
|
ai->ai_protocol)) < 0 ) { |
|
errstr = "in socket"; |
|
continue; |
} |
} |
sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY; |
|
sin.sin_port = htons(atoi(port_str)); |
if (bind(s, ai->ai_addr, ai->ai_addrlen) < 0) { |
len = sizeof(sin); |
errstr = "in bind"; |
saddr = (struct sockaddr *)&sin; |
close(s); |
|
s = -1; |
|
continue; |
|
} |
|
|
|
if (listen(s, SOCKQUEUELENGTH) < 0) { |
|
errstr = "in listen"; |
|
close(s); |
|
s = -1; |
|
continue; |
|
} |
|
|
|
/* established connection */ |
|
break; |
} |
} |
if (bind(service, saddr, len) < 0) { |
freeaddrinfo(res); |
perror("in bind"); |
|
close(service); |
if (s < 0) |
return -1; |
perror(errstr); |
} |
return (s); |
if (getsockname(service,saddr, &len) < 0) { |
|
perror("in getsockname"); |
|
close(service); |
|
return -1; |
|
} |
|
if (listen(service, SOCKQUEUELENGTH) < 0) { |
|
perror("in listen"); |
|
close(service); |
|
return -1; |
|
} |
|
return service; |
|
} |
} |
|
|
/* |
/* |
try to accept a connection request |
try to accept a connection request |
|
|
Input |
Input |
af_unix: s is UNIX domain socket if af_unix is nonzero |
|
s: socket |
s: socket |
|
|
Output |
Output |
|
|
the original socket is always closed. |
the original socket is always closed. |
*/ |
*/ |
|
|
int try_accept(af_unix,s) |
int try_accept(s) |
int af_unix,s; |
int s; |
{ |
{ |
int len,c,i; |
struct sockaddr_storage ss; |
struct sockaddr_in sin; |
socklen_t len; |
|
int c, i; |
|
|
#if !defined(VISUAL) |
len = sizeof(ss); |
struct sockaddr_un s_un; |
if (getsockname(s, (struct sockaddr *)&ss, &len) < 0) { |
if ( af_unix ) { |
close(s); |
len = sizeof(s_un); |
return (-1); |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
} |
c = accept(s, (struct sockaddr *) &s_un, &len); |
|
} else |
|
#endif |
|
{ |
|
|
|
len = sizeof(sin); |
for (i = 0 ; i < 10 ; i++) { |
for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ ) |
c = accept(s, (struct sockaddr *)&ss, &len); |
c = accept(s, (struct sockaddr *) &sin, &len); |
if (c >= 0) { |
|
close(s); |
|
return (c); |
|
} |
} |
} |
if ( i == 10 ) |
|
c = -1; |
|
close(s); |
close(s); |
return c; |
return (-1); |
} |
} |
|
|
int try_connect(use_unix,host,port_str) |
int try_connect(use_unix,host,port_str) |
int use_unix; |
int use_unix; |
char *host,*port_str; |
char *host,*port_str; |
{ |
{ |
struct sockaddr_in sin; |
struct addrinfo hints, *res, *ai; |
struct sockaddr *saddr; |
int s, error, i; |
struct hostent *hp; |
char *errstr; |
int len,s,i; |
|
#if !defined(VISUAL) |
|
struct sockaddr_un s_un; |
|
#endif |
|
|
|
for ( i = 0; i < 10; i++ ) { |
memset(&hints, 0, sizeof(hints)); |
#if !defined(VISUAL) |
#if defined(VISUAL) |
if ( use_unix ) { |
hints.ai_family = PF_UNSPEC; |
if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) { |
|
perror("socket"); |
|
return -1; |
|
} |
|
bzero(&s_un,sizeof(s_un)); |
|
s_un.sun_family = AF_UNIX; |
|
strcpy(s_un.sun_path,port_str); |
|
#if defined(__FreeBSD__) |
|
len = SUN_LEN(&s_un); |
|
s_un.sun_len = len+1; /* XXX */ |
|
#else |
#else |
len = strlen(s_un.sun_path)+sizeof(s_un.sun_family); |
if (use_unix) |
#endif |
hints.ai_family = PF_UNIX; |
saddr = (struct sockaddr *)&s_un; |
else |
} else |
hints.ai_family = PF_UNSPEC; |
#endif /* VISUAL */ |
#endif /* VISUAL */ |
{ |
hints.ai_socktype = SOCK_STREAM; |
if ( (s = socket(AF_INET,SOCK_STREAM,0)) < 0 ) { |
|
perror("socket"); |
error = getaddrinfo(host, port_str, &hints, &res); |
return -1; |
if (error) { |
|
warnx("try_connect: %s", gai_strerror(error)); |
|
return (-1); |
|
} |
|
for (i = 0 ; i < 10 ; i++) { |
|
s = -1; |
|
for (ai = res ; ai != NULL ; ai = ai->ai_next) { |
|
if ((s = socket(ai->ai_family, ai->ai_socktype, |
|
ai->ai_protocol)) < 0 ) { |
|
errstr = "socket"; |
|
continue; |
} |
} |
bzero(&sin,sizeof(sin)); |
if (connect(s, ai->ai_addr, ai->ai_addrlen) < 0) { |
sin.sin_port = htons(atoi(port_str)); |
errstr = "connect"; |
sin.sin_addr.s_addr = inet_addr(host); |
close(s); |
if ( sin.sin_addr.s_addr != -1 ) { |
s = -1; |
sin.sin_family = AF_INET; |
continue; |
} else { |
|
hp = gethostbyname(host); |
|
bcopy(hp->h_addr,&sin.sin_addr,hp->h_length); |
|
sin.sin_family = hp->h_addrtype; |
|
} |
} |
len = sizeof(sin); |
|
saddr = (struct sockaddr *)&sin; |
/* established a connection */ |
} |
|
if ( connect(s,saddr,len) >= 0 ) |
|
break; |
break; |
else { |
} |
close(s); |
|
|
if (s >= 0) { |
|
freeaddrinfo(res); |
|
return (s); |
|
} |
|
|
#if defined(VISUAL) |
#if defined(VISUAL) |
Sleep(100); |
Sleep(100); |
#else |
#else |
usleep(100000); |
usleep(100000); |
#endif |
#endif |
} |
|
} |
} |
if ( i == 10 ) { |
freeaddrinfo(res); |
perror("connect"); |
|
return -1; |
perror(errstr); |
} else |
return (-1); |
return s; |
|
} |
} |
|
|
|
#if 0 |
close_allconnections() |
close_allconnections() |
{ |
{ |
int s; |
int s; |
|
|
free_iofp(s); |
free_iofp(s); |
} |
} |
} |
} |
|
#else |
|
close_allconnections() |
|
{ |
|
shutdown_all(); |
|
} |
|
#endif |
|
|
free_iofp(s) |
free_iofp(s) |
int s; |
int s; |
|
|
} else { |
} else { |
/* client : read -> write */ |
/* client : read -> write */ |
read_char(iofp[i].in,&rc); |
read_char(iofp[i].in,&rc); |
|
/* special care for a failure of spawing a server */ |
|
if ( rc !=0 && rc != 1 && rc != 0xff ) |
|
return -1; |
write_char(iofp[i].out,&c); ox_flush_stream_force(i); |
write_char(iofp[i].out,&c); ox_flush_stream_force(i); |
} |
} |
iofp[i].conv = c == rc ? 0 : 1; |
iofp[i].conv = c == rc ? 0 : 1; |
|
|
return i; |
return i; |
return -1; |
return -1; |
} |
} |
|
|
#endif /* INET */ |
#endif /* INET */ |
|
|