[BACK]Return to sio.c CVS log [TXT][DIR] Up to [local] / OpenXM_contrib2 / asir2000 / io

Diff for /OpenXM_contrib2/asir2000/io/sio.c between version 1.26 and 1.27

version 1.26, 2015/08/06 10:01:52 version 1.27, 2015/08/14 13:51:55
Line 44 
Line 44 
  * 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.25 2012/12/17 07:20:45 noro Exp $   * $OpenXM: OpenXM_contrib2/asir2000/io/sio.c,v 1.26 2015/08/06 10:01:52 fujimoto Exp $
 */  */
 #include "ca.h"  #include "ca.h"
 #include <setjmp.h>  #include <setjmp.h>
 #include "ox.h"  #include "ox.h"
 #if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)  #if defined(VISUAL) || defined(__MINGW32__)
 #include <winsock2.h>  #include <winsock2.h>
 #include <io.h>  #include <io.h>
 #else  #else
Line 76  struct IOFP iofp[MAXIOFP];
Line 76  struct IOFP iofp[MAXIOFP];
   
 void init_socket(void);  void init_socket(void);
   
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
 #define closesocket(s)   (close((s)))  #define closesocket(s)   (close((s)))
 #endif  #endif
   
Line 107  void generate_port(int use_unix,char *port_str)
Line 107  void generate_port(int use_unix,char *port_str)
         unsigned int port;          unsigned int port;
         static int count=0;          static int count=0;
   
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
         if ( use_unix ) {          if ( use_unix ) {
                 sprintf(port_str,"/tmp/ox%02x.XXXXXX",count);                  sprintf(port_str,"/tmp/ox%02x.XXXXXX",count);
                 count++;                  count++;
Line 127  int try_bind_listen(int use_unix,char *port_str)
Line 127  int try_bind_listen(int use_unix,char *port_str)
         struct sockaddr *saddr;          struct sockaddr *saddr;
         int len;          int len;
         int service;          int service;
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
         struct sockaddr_un s_un;          struct sockaddr_un s_un;
   
         if ( use_unix ) {          if ( use_unix ) {
Line 195  int try_accept(int af_unix,int s)
Line 195  int try_accept(int af_unix,int s)
         int len,c,i;          int len,c,i;
         struct sockaddr_in sin;          struct sockaddr_in sin;
   
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
         struct sockaddr_un s_un;          struct sockaddr_un s_un;
         if ( af_unix ) {          if ( af_unix ) {
                 len = sizeof(s_un);                  len = sizeof(s_un);
Line 221  int try_connect(int use_unix,char *host,char *port_str
Line 221  int try_connect(int use_unix,char *host,char *port_str
         struct sockaddr *saddr;          struct sockaddr *saddr;
         struct hostent *hp;          struct hostent *hp;
         int len,s,i;          int len,s,i;
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
         struct sockaddr_un s_un;          struct sockaddr_un s_un;
 #endif  #endif
   
         for ( i = 0; i < 10; i++ ) {          for ( i = 0; i < 10; i++ ) {
 #if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)  #if !defined(VISUAL) && !defined(__MINGW32__)
                 if ( use_unix ) {                  if ( use_unix ) {
                         if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) {                          if ( (s = socket(AF_UNIX,SOCK_STREAM,0)) < 0 ) {
                                 perror("socket");                                  perror("socket");
Line 268  int try_connect(int use_unix,char *host,char *port_str
Line 268  int try_connect(int use_unix,char *host,char *port_str
                         break;                          break;
                 else {                  else {
                         closesocket(s);                          closesocket(s);
 #if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)  #if defined(VISUAL) || defined(__MINGW32__)
                         Sleep(100);                          Sleep(100);
 #else  #else
                         usleep(100000);                          usleep(100000);
Line 317  void free_iofp(int s)
Line 317  void free_iofp(int s)
         struct IOFP *r;          struct IOFP *r;
   
         r = &iofp[s];          r = &iofp[s];
 #if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)  #if defined(VISUAL) || defined(__MINGW32__)
         if ( r->s ) closesocket(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);
Line 352  int get_iofp(int s1,char *af_sock,int is_server)
Line 352  int get_iofp(int s1,char *af_sock,int is_server)
                 if ( !iofp[i].in )                  if ( !iofp[i].in )
                         break;                          break;
         iofp[i].s = s1;          iofp[i].s = s1;
 #if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)  #if defined(VISUAL) || defined(__MINGW32__)
         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
Line 389  int get_iofp(int s1,char *af_sock,int is_server)
Line 389  int get_iofp(int s1,char *af_sock,int is_server)
 #endif  #endif
 }  }
   
 #if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)  #if defined(VISUAL) || defined(__MINGW32__)
 void init_socket()  void init_socket()
 {  {
         static int socket_is_initialized;          static int socket_is_initialized;
Legend:
Removed from v.1.26  
changed lines
  Added in v.1.27
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>