version 1.21, 2003/02/14 22:29:15 |
version 1.24, 2011/02/06 07:07:39 |
|
|
* 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.20 2003/01/28 08:58:23 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.23 2003/03/07 06:39:57 noro Exp $ |
*/ |
*/ |
#include "ca.h" |
#include "ca.h" |
#include <setjmp.h> |
#include <setjmp.h> |
Line 76 struct IOFP iofp[MAXIOFP]; |
|
Line 76 struct IOFP iofp[MAXIOFP]; |
|
|
|
void init_socket(void); |
void init_socket(void); |
|
|
|
#if !defined(VISUAL) |
|
#define closesocket(s) (close((s))) |
|
#endif |
|
|
int getremotesocket(int s) |
int getremotesocket(int s) |
{ |
{ |
return iofp[s].s; |
return iofp[s].s; |
Line 156 int try_bind_listen(int use_unix,char *port_str) |
|
Line 160 int try_bind_listen(int use_unix,char *port_str) |
|
} |
} |
if (bind(service, saddr, len) < 0) { |
if (bind(service, saddr, len) < 0) { |
perror("in bind"); |
perror("in bind"); |
close(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"); |
close(service); |
closesocket(service); |
return -1; |
return -1; |
} |
} |
if (listen(service, SOCKQUEUELENGTH) < 0) { |
if (listen(service, SOCKQUEUELENGTH) < 0) { |
perror("in listen"); |
perror("in listen"); |
close(service); |
closesocket(service); |
return -1; |
return -1; |
} |
} |
return service; |
return service; |
Line 207 int try_accept(int af_unix,int s) |
|
Line 211 int try_accept(int af_unix,int s) |
|
} |
} |
if ( i == 10 ) |
if ( i == 10 ) |
c = -1; |
c = -1; |
close(s); |
closesocket(s); |
return c; |
return c; |
} |
} |
|
|
Line 263 int try_connect(int use_unix,char *host,char *port_str |
|
Line 267 int try_connect(int use_unix,char *host,char *port_str |
|
if ( connect(s,saddr,len) >= 0 ) |
if ( connect(s,saddr,len) >= 0 ) |
break; |
break; |
else { |
else { |
close(s); |
closesocket(s); |
#if defined(VISUAL) |
#if defined(VISUAL) |
Sleep(100); |
Sleep(100); |
#else |
#else |
Line 314 void free_iofp(int s) |
|
Line 318 void free_iofp(int s) |
|
|
|
r = &iofp[s]; |
r = &iofp[s]; |
#if defined(VISUAL) |
#if defined(VISUAL) |
if ( r->s ) close(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); |