| version 1.48, 2003/12/12 04:59:59 |
version 1.52, 2004/02/26 06:37:09 |
|
|
| * 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/ox_asir.c,v 1.47 2003/12/11 05:48:04 noro Exp $ |
* $OpenXM: OpenXM_contrib2/asir2000/io/ox_asir.c,v 1.51 2004/02/13 05:48:36 saito Exp $ |
| */ |
*/ |
| #include "ca.h" |
#include "ca.h" |
| #include "parse.h" |
#include "parse.h" |
| Line 59 void ox_usr1_handler(); |
|
| Line 59 void ox_usr1_handler(); |
|
| int asir_ox_init(); |
int asir_ox_init(); |
| |
|
| /* environement is defined in libpari.a */ |
/* environement is defined in libpari.a */ |
| |
# if !( PARI_VERSION_CODE > 131588) |
| extern jmp_buf environnement; |
extern jmp_buf environnement; |
| |
# endif |
| extern int myrank_102,nserver_102; |
extern int myrank_102,nserver_102; |
| |
|
| extern int do_message; |
extern int do_message; |
| Line 479 void asir_reset_102(unsigned int serial) |
|
| Line 481 void asir_reset_102(unsigned int serial) |
|
| do { |
do { |
| ox_recv_102(i,&id,&obj); |
ox_recv_102(i,&id,&obj); |
| } while ( id != OX_SYNC_BALL ); |
} while ( id != OX_SYNC_BALL ); |
| for ( i = myrank_102; i < nserver_102; i++ ) |
for ( i = myrank_102+1; i < nserver_102; i++ ) |
| ox_send_sync_102(i); |
ox_send_sync_102(i); |
| } |
} |
| |
|
| Line 556 void asir_tcp_connect_102(unsigned int serial) |
|
| Line 558 void asir_tcp_connect_102(unsigned int serial) |
|
| port = QTOS(p); |
port = QTOS(p); |
| sprintf(port_str,"%d",port); |
sprintf(port_str,"%d",port); |
| use_unix = 0; |
use_unix = 0; |
| |
host = BDY((STRING)h); |
| } else { |
} else { |
| strcpy(port_str,BDY((STRING)p)); |
strcpy(port_str,BDY((STRING)p)); |
| use_unix = 1; |
use_unix = 1; |
| |
host = 0; |
| } |
} |
| host = BDY((STRING)h); |
|
| s = try_connect(use_unix,host,port_str); |
s = try_connect(use_unix,host,port_str); |
| rank = QTOS((Q)r); |
rank = QTOS((Q)r); |
| if ( register_102(s,rank,1) < 0 ) { |
if ( register_102(s,rank,1) < 0 ) { |
| Line 602 void asir_popString() |
|
| Line 605 void asir_popString() |
|
| buf = (char *)ALLOCA(l+1); |
buf = (char *)ALLOCA(l+1); |
| soutput_init(buf); |
soutput_init(buf); |
| sprintexpr(CO,val); |
sprintexpr(CO,val); |
| |
#if 0 |
| l = strlen(buf); |
l = strlen(buf); |
| obuf = (char *)MALLOC(l+1); |
obuf = (char *)MALLOC(l+1); |
| strcpy(obuf,buf); |
strcpy(obuf,buf); |
| |
#endif |
| } |
} |
| MKSTR(str,obuf); |
MKSTR(str,buf); |
| ox_send_data(0,str); |
ox_send_data(0,str); |
| } |
} |
| |
|
| Line 669 int asir_executeString() |
|
| Line 674 int asir_executeString() |
|
| #if defined(PARI) |
#if defined(PARI) |
| recover(0); |
recover(0); |
| /* environement is defined in libpari.a */ |
/* environement is defined in libpari.a */ |
| |
# if !(PARI_VERSION_CODE > 131588 ) |
| if ( setjmp(environnement) ) { |
if ( setjmp(environnement) ) { |
| avma = top; recover(1); |
avma = top; recover(1); |
| resetenv(""); |
resetenv(""); |
| } |
} |
| |
# endif |
| #endif |
#endif |
| cmd = ((STRING)asir_pop_one())->body; |
cmd = ((STRING)asir_pop_one())->body; |
| parse_strp = cmd; |
parse_strp = cmd; |
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ox_asir.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM_contrib2 / asir2000 / io