![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to sio.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM_contrib2 / asir2000 / io|
Return to sio.c CVS log | Up to [local] / OpenXM_contrib2 / asir2000 / io |
1.1 ! noro 1: /* $OpenXM: OpenXM/src/asir99/io/sio.c,v 1.3 1999/11/18 09:00:38 noro Exp $ */
! 2: #if INET
! 3: #include "ca.h"
! 4: #include "ox.h"
! 5: #if defined(VISUAL)
! 6: #include <winsock.h>
! 7: #else
! 8: #include <sys/time.h>
! 9: #include <sys/uio.h>
! 10: #include <sys/ioctl.h>
! 11: #include <sys/un.h>
! 12: #endif
! 13: #include<signal.h>
! 14:
! 15: #define SOCKQUEUELENGTH 5
! 16: #define ISIZ sizeof(int)
! 17:
! 18: extern int little_endian;
! 19:
! 20: struct IOFP iofp[MAXIOFP];
! 21:
! 22: #if !defined(_PA_RISC1_1)
! 23: #define RSH "rsh"
! 24: #else
! 25: #define RSH "remsh"
! 26: #endif
! 27:
! 28: void init_socket(void);
! 29:
! 30: int getremotesocket(s)
! 31: int s;
! 32: {
! 33: return iofp[s].s;
! 34: }
! 35:
! 36: void getremotename(s,name)
! 37: int s;
! 38: char *name;
! 39: {
! 40: struct sockaddr_in peer;
! 41: struct hostent *hp;
! 42: int peerlen;
! 43:
! 44: peerlen = sizeof(peer);
! 45: getpeername(getremotesocket(s),(struct sockaddr *)&peer,&peerlen);
! 46: hp = gethostbyaddr((char *)&peer.sin_addr,sizeof(struct in_addr),AF_INET);
! 47: if ( hp )
! 48: strcpy(name,hp->h_name);
! 49: else
! 50: strcpy(name,(char *)inet_ntoa(peer.sin_addr));
! 51: }
! 52:
! 53: int generate_port(use_unix,port_str)
! 54: int use_unix;
! 55: char *port_str;
! 56: {
! 57: double get_current_time();
! 58: unsigned long mt_genrand();
! 59: unsigned int port;
! 60: static int count=0;
! 61:
! 62: if ( use_unix ) {
! 63: sprintf(port_str,"/tmp/ox%02x.XXXXXX",count);
! 64: count++;
! 65: mktemp(port_str);
! 66: } else {
! 67: port = ((unsigned int)mt_genrand()+(unsigned int)get_current_time())
! 68: %(65536-1024)+1024;
! 69: sprintf(port_str,"%d",port);
! 70: }
! 71: }
! 72:
! 73: int try_bind_listen(use_unix,port_str)
! 74: int use_unix;
! 75: char *port_str;
! 76: {
! 77: struct sockaddr_in sin;
! 78: struct sockaddr_un s_un;
! 79: struct sockaddr *saddr;
! 80: int len;
! 81: int service;
! 82:
! 83: if ( use_unix ) {
! 84: service = socket(AF_UNIX, SOCK_STREAM, 0);
! 85: if (service < 0) {
! 86: perror("in socket");
! 87: return -1;
! 88: }
! 89: s_un.sun_family = AF_UNIX;
! 90: strcpy(s_un.sun_path,port_str);
! 91: #if defined(__FreeBSD__)
! 92: len = SUN_LEN(&s_un);
! 93: s_un.sun_len = len+1; /* XXX */
! 94: #else
! 95: len = strlen(s_un.sun_path)+sizeof(s_un.sun_family);
! 96: #endif
! 97: saddr = (struct sockaddr *)&s_un;
! 98: } else {
! 99: service = socket(AF_INET, SOCK_STREAM, 0);
! 100: if ( service < 0 ) {
! 101: perror("in socket");
! 102: return -1;
! 103: }
! 104: sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY;
! 105: sin.sin_port = htons(atoi(port_str));
! 106: len = sizeof(sin);
! 107: saddr = (struct sockaddr *)&sin;
! 108: }
! 109: if (bind(service, saddr, len) < 0) {
! 110: perror("in bind");
! 111: close(service);
! 112: return -1;
! 113: }
! 114: if (getsockname(service,saddr, &len) < 0) {
! 115: perror("in getsockname");
! 116: close(service);
! 117: return -1;
! 118: }
! 119: if (listen(service, SOCKQUEUELENGTH) < 0) {
! 120: perror("in listen");
! 121: close(service);
! 122: return -1;
! 123: }
! 124: return service;
! 125: }
! 126:
! 127: /*
! 128: try to accept a connection request
! 129:
! 130: Input
! 131: af_unix: s is UNIX domain socket if af_unix is nonzero
! 132: s: socket
! 133:
! 134: Output
! 135: c: an accepted socket which is newly created
! 136: -1: if failed to accept
! 137:
! 138: the original socket is always closed.
! 139: */
! 140:
! 141: int try_accept(af_unix,s)
! 142: int af_unix,s;
! 143: {
! 144: int len,c,i;
! 145: struct sockaddr_un s_un;
! 146: struct sockaddr_in sin;
! 147:
! 148: if ( af_unix ) {
! 149: len = sizeof(s_un);
! 150: for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ )
! 151: c = accept(s, (struct sockaddr *) &s_un, &len);
! 152: } else {
! 153:
! 154: len = sizeof(sin);
! 155: for ( c = -1, i = 0; (c < 0)&&(i = 10) ; i++ )
! 156: c = accept(s, (struct sockaddr *) &sin, &len);
! 157: }
! 158: if ( i == 10 )
! 159: c = -1;
! 160: close(s);
! 161: return c;
! 162: }
! 163:
! 164: int try_connect(use_unix,host,port_str)
! 165: int use_unix;
! 166: char *host,*port_str;
! 167: {
! 168: struct sockaddr_in sin;
! 169: struct sockaddr_un s_un;
! 170: struct sockaddr *saddr;
! 171: struct hostent *hp;
! 172: int len,s,i;
! 173:
! 174: for ( i = 0; i < 10; i++ ) {
! 175: if ( use_unix ) {
! 176: if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) {
! 177: perror("socket");
! 178: return -1;
! 179: }
! 180: bzero(&s_un,sizeof(s_un));
! 181: s_un.sun_family = AF_UNIX;
! 182: strcpy(s_un.sun_path,port_str);
! 183: #if defined(__FreeBSD__)
! 184: len = SUN_LEN(&s_un);
! 185: s_un.sun_len = len+1; /* XXX */
! 186: #else
! 187: len = strlen(s_un.sun_path)+sizeof(s_un.sun_family);
! 188: #endif
! 189: saddr = (struct sockaddr *)&s_un;
! 190: } else {
! 191: if ( (s = socket(AF_INET,SOCK_STREAM,0)) < 0 ) {
! 192: perror("socket");
! 193: return -1;
! 194: }
! 195: bzero(&sin,sizeof(sin));
! 196: sin.sin_port = htons(atoi(port_str));
! 197: sin.sin_addr.s_addr = inet_addr(host);
! 198: if ( sin.sin_addr.s_addr != -1 ) {
! 199: sin.sin_family = AF_INET;
! 200: } else {
! 201: hp = gethostbyname(host);
! 202: bcopy(hp->h_addr,&sin.sin_addr,hp->h_length);
! 203: sin.sin_family = hp->h_addrtype;
! 204: }
! 205: len = sizeof(sin);
! 206: saddr = (struct sockaddr *)&sin;
! 207: }
! 208: if ( connect(s,saddr,len) >= 0 )
! 209: break;
! 210: else {
! 211: close(s);
! 212: usleep(100000);
! 213: }
! 214: }
! 215: if ( i == 10 ) {
! 216: perror("connect");
! 217: return -1;
! 218: } else
! 219: return s;
! 220: }
! 221:
! 222: close_allconnections()
! 223: {
! 224: int s;
! 225:
! 226: #if defined(SIGPIPE)
! 227: signal(SIGPIPE,SIG_IGN);
! 228: #endif
! 229: for ( s = 0; s < MAXIOFP; s++ )
! 230: close_connection(s);
! 231: }
! 232:
! 233: close_connection(s)
! 234: int s;
! 235: {
! 236: struct IOFP *r;
! 237:
! 238: r = &iofp[s];
! 239: if ( r->in && r->out ) {
! 240: if ( check_sm_by_mc(s,SM_shutdown) )
! 241: ox_send_cmd(s,SM_shutdown);
! 242: free_iofp(s);
! 243: }
! 244: }
! 245:
! 246: free_iofp(s)
! 247: int s;
! 248: {
! 249: struct IOFP *r;
! 250:
! 251: r = &iofp[s];
! 252: r->in = r->out = 0; r->s = 0;
! 253: #if !defined(VISUAL)
! 254: if ( r->socket )
! 255: unlink(r->socket);
! 256: #endif
! 257: }
! 258:
! 259: #define LBUFSIZ BUFSIZ*10
! 260:
! 261: int get_iofp(s1,af_sock,is_server)
! 262: int s1;
! 263: char *af_sock;
! 264: int is_server;
! 265: {
! 266: int i;
! 267: unsigned char c,rc;
! 268:
! 269: for ( i = 0; i < MAXIOFP; i++ )
! 270: if ( !iofp[i].in )
! 271: break;
! 272: iofp[i].s = s1;
! 273: #if defined(VISUAL) || MPI
! 274: iofp[i].in = WSIO_open(s1,"r");
! 275: iofp[i].out = WSIO_open(s1,"w");
! 276: #else
! 277: iofp[i].in = fdopen(s1,"r");
! 278: iofp[i].out = fdopen(s1,"w");
! 279: setbuffer(iofp[i].in,(char *)malloc(LBUFSIZ),LBUFSIZ);
! 280: setbuffer(iofp[i].out,(char *)malloc(LBUFSIZ),LBUFSIZ);
! 281: #endif
! 282: #if MPI
! 283: iofp[i].conv = 0;
! 284: iofp[i].socket = 0;
! 285: #else
! 286: if ( little_endian )
! 287: c = 1;
! 288: else
! 289: c = 0xff;
! 290: if ( is_server ) {
! 291: /* server : write -> read */
! 292: write_char(iofp[i].out,&c); ox_flush_stream_force(i);
! 293: read_char(iofp[i].in,&rc);
! 294: } else {
! 295: /* client : read -> write */
! 296: read_char(iofp[i].in,&rc);
! 297: write_char(iofp[i].out,&c); ox_flush_stream_force(i);
! 298: }
! 299: iofp[i].conv = c == rc ? 0 : 1;
! 300: if ( af_sock && af_sock[0] ) {
! 301: iofp[i].socket = (char *)malloc(strlen(af_sock)+1);
! 302: strcpy(iofp[i].socket,af_sock);
! 303: } else
! 304: iofp[i].socket = 0;
! 305: #endif
! 306: return i;
! 307: }
! 308:
! 309: #if defined(VISUAL)
! 310: void init_socket()
! 311: {
! 312: static int socket_is_initialized;
! 313: WORD wVersionRequested;
! 314: WSADATA wsaData;
! 315: int err;
! 316: wVersionRequested = MAKEWORD(2,0);
! 317:
! 318: if ( socket_is_initialized )
! 319: return;
! 320: err = WSAStartup(wVersionRequested,&wsaData);
! 321: if ( err )
! 322: return;
! 323: }
! 324: #endif
! 325:
! 326: get_fd(index)
! 327: int index;
! 328: {
! 329: return iofp[index].s;
! 330: }
! 331:
! 332: get_index(fd)
! 333: int fd;
! 334: {
! 335: int i;
! 336:
! 337: for ( i = 0; i < MAXIOFP; i++ )
! 338: if ( iofp[i].s == fd )
! 339: return i;
! 340: return -1;
! 341: }
! 342: #endif /* INET */