=================================================================== RCS file: /home/cvs/OpenXM_contrib2/asir2000/io/ox.c,v retrieving revision 1.31 retrieving revision 1.35 diff -u -p -r1.31 -r1.35 --- OpenXM_contrib2/asir2000/io/ox.c 2015/08/04 06:20:45 1.31 +++ OpenXM_contrib2/asir2000/io/ox.c 2015/08/14 13:51:55 1.35 @@ -44,7 +44,7 @@ * 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/ox.c,v 1.30 2013/06/13 18:40:31 ohara Exp $ + * $OpenXM: OpenXM_contrib2/asir2000/io/ox.c,v 1.34 2015/08/08 14:19:42 fujimoto Exp $ */ #include "ca.h" #include "parse.h" @@ -94,8 +94,9 @@ void mclist_to_mc(LIST mclist,struct mathcap *mc); Obj asir_pop_one(); void asir_push_one(Obj); -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) /* XXX : mainly used in engine2000/io.c, but declared here */ +typedef void *HANDLE; HANDLE hStreamNotify,hStreamNotify_Ack; void cleanup_events() @@ -109,7 +110,7 @@ void cleanup_events() void ox_resetenv(char *s) { -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) cleanup_events(); #endif fprintf(stderr,"%s\n",s); @@ -395,7 +396,7 @@ void end_critical() { critical_when_signal = 0; if ( ox_usr1_sent ) { ox_usr1_sent = 0; -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) ox_usr1_handler(SIGUSR1); #else ox_usr1_handler(0); @@ -412,7 +413,7 @@ void ox_usr1_handler(int sig) { NODE t; -#if !defined(VISUAL) +#if !defined(VISUAL) && !defined(__MINGW32__) signal(SIGUSR1,ox_usr1_handler); #endif if ( critical_when_signal ) { @@ -481,7 +482,7 @@ void wait_for_data(int s) int sock; if ( !FP_DATA_IS_AVAILABLE(iofp[s].in) ) { -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) sock = iofp[s].in->fildes; FD_ZERO(&r); FD_SET((unsigned int)sock,&r); @@ -501,7 +502,7 @@ void wait_for_data_102(int rank) int sock; if ( !FP_DATA_IS_AVAILABLE(iofp_102[rank].in) ) { -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) sock = iofp_102[rank].in->fildes; FD_ZERO(&r); FD_SET((unsigned int)sock,&r); @@ -887,6 +888,8 @@ int ox_check_cmo(int s, Obj obj) return 1; case O_QUOTE: /* XXX */ return 1; + case O_MAT: /* MAT is sent as a list */ + return 1; default: return 0; } @@ -935,7 +938,7 @@ void ox_flush_stream(int s) { if ( ox_batch ) return; -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) if ( _fileno(&iofp[s].out->fp) < 0 ) cflush(iofp[s].out); else @@ -949,7 +952,7 @@ void ox_flush_stream(int s) void ox_flush_stream_force(int s) { -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) if ( _fileno(&iofp[s].out->fp) < 0 ) cflush(iofp[s].out); else @@ -970,7 +973,7 @@ void ox_flush_stream_102(int rank) void ox_flush_stream_force_102(int rank) { if ( iofp_102[rank].out ) -#if defined(VISUAL) +#if defined(VISUAL) || defined(__MINGW32__) cflush(iofp_102[rank].out); #elif MPI cflush(iofp_102[rank].out);