OpenXM_contrib2/asir2000/io/ox_asir.c - diff

Return to ox_asir.c CVS log

Up to [local] / OpenXM_contrib2 / asir2000 / io

Diff for /OpenXM_contrib2/asir2000/io/ox_asir.c between version 1.35 and 1.51

version 1.35, 2001/12/25 02:39:05

version 1.51, 2004/02/13 05:48:36

Line 44

* 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_asir.c,v 1.34 2001/12/21 08:23:14 noro Exp $

* $OpenXM: OpenXM_contrib2/asir2000/io/ox_asir.c,v 1.50 2003/12/13 08:03:56 noro Exp $

#include "ca.h"

#include "parse.h"

#include "signal.h"

#include "ox.h"

#include "version.h"

#if PARI

#if defined(PARI)

#include "genpari.h"

#endif

void ox_usr1_handler();

int asir_ox_init();

extern JMP_BUF environnement;

/* environement is defined in libpari.a */

# if !( PARI_VERSION_CODE > 131588)

extern jmp_buf environnement;

# endif

extern int myrank_102,nserver_102;

extern int do_message;

extern int ox_flushing;

Line 77 Obj *asir_OperandStack;

Line 81 Obj *asir_OperandStack;

int asir_OperandStackPtr = -1;

void ox_io_init();

void ox_asir_init(int,char **);

void ox_asir_init(int,char **,char *);

Obj asir_pop_one();

Obj asir_peek_one();

void asir_push_one(Obj);

Line 90 void asir_popString();

Line 94 void asir_popString();

void asir_popCMO(unsigned int);

void asir_popSerializedLocalObject();

void asir_pushCMOtag(unsigned int);

void asir_set_rank_102(unsigned int);

void asir_tcp_accept_102(unsigned int);

void asir_tcp_connect_102(unsigned int);

void asir_reset_102(unsigned int serial);

void asir_bcast_102(unsigned int serial);

void asir_reduce_102(unsigned int serial);

LIST asir_GetErrorList();

char *name_of_cmd(int);

char *name_of_id(int);

Line 97 char *name_of_id(int);

Line 107 char *name_of_id(int);

static void asir_do_cmd(int,unsigned int);

static void asir_executeFunction(int);

#if MPI

#if defined(MPI)

/* XXX : currently MPI version supports only a homogeneous cluster. */

extern int mpi_nprocs,mpi_myid;

Line 139 void ox_main(int argc,char **argv) {

Line 149 void ox_main(int argc,char **argv) {

int ret;

extern char LastError[];

ox_asir_init(argc,argv);

ox_asir_init(argc,argv,"ox_asir");

if ( do_message )

fprintf(stderr,"I'm an ox_asir, Version %d.\n",ASIR_VERSION);

if ( SETJMP(ox_env) ) {

Line 257 static void asir_do_cmd(int cmd,unsigned int serial)

Line 267 static void asir_do_cmd(int cmd,unsigned int serial)

case SM_pushCMOtag:

asir_pushCMOtag(serial);

break;

case SM_set_rank_102:

asir_set_rank_102(serial);

break;

case SM_tcp_accept_102:

asir_tcp_accept_102(serial);

break;

case SM_tcp_connect_102:

asir_tcp_connect_102(serial);

break;

case SM_reset_102:

asir_reset_102(serial);

break;

case SM_bcast_102:

asir_bcast_102(serial);

break;

case SM_reduce_102:

asir_reduce_102(serial);

break;

case SM_nop:

default:

break;

Line 336 char *name_of_cmd(int cmd)

Line 364 char *name_of_cmd(int cmd)

return "SM_nop";

case SM_pushCMOtag:

return "SM_pushCMOtag";

case SM_set_rank_102:

return "SM_set_rank_102";

break;

case SM_tcp_accept_102:

return "SM_tcp_accept_102";

break;

case SM_tcp_connect_102:

return "SM_tcp_connect_102";

case SM_reset_102:

return "SM_reset_102";

break;

case SM_bcast_102:

return "SM_bcast_102";

break;

case SM_reduce_102:

return "SM_reduce_102";

break;

default:

return "Unknown cmd";

break;

Line 390 void asir_popCMO(unsigned int serial)

Line 435 void asir_popCMO(unsigned int serial)

}

void asir_reduce_102(unsigned int serial)

{

Q r;

int root;

Obj data,obj;

ERR err;

STRING op;

char *opname;

void (*func)();

func = 0;

op = (STRING)asir_pop_one();

opname = BDY(op);

r = (Q)asir_pop_one();

root = QTOS(r);

if ( !strcmp(opname,"+") )

func = arf_add;

else if ( !strcmp(opname,"*") )

func = arf_mul;

if ( !func ) {

create_error(&err,serial,"Invalid opration in ox_reduce_102");

asir_push_one(obj);

} else

ox_reduce_102(root,func);

}

void asir_bcast_102(unsigned int serial)

{

Q r;

int root;

Obj data;

r = (Q)asir_pop_one();

root = QTOS(r);

ox_bcast_102(root);

}

void asir_reset_102(unsigned int serial)

{

int i,j,id;

Obj obj;

for ( i = 0; i < myrank_102; i++ )

do {

ox_recv_102(i,&id,&obj);

} while ( id != OX_SYNC_BALL );

for ( i = myrank_102+1; i < nserver_102; i++ )

ox_send_sync_102(i);

}

void asir_set_rank_102(unsigned int serial)

{

Obj obj;

Q rank,nserver;

int n,r,stat;

NODE arg;

ERR err;

rank = (Q)asir_pop_one();

nserver = (Q)asir_pop_one();

stat = 0;

if ( !nserver || !INT(nserver) || !INT(rank) ) {

stat = -1;

} else {

n = QTOS(nserver); r = QTOS(rank);

if ( n <= 0 || r < 0 || r >= n ) {

stat = -1;

}

myrank_102 = r;

nserver_102 = n;

}

if ( !stat ) return;

else {

create_error(&err,serial,"Invalid argument(s) in ox_set_rank_102");

asir_push_one(obj);

}

void asir_tcp_accept_102(unsigned int serial)

{

Obj obj;

Q r,p;

ERR err;

char port_str[BUFSIZ];

int port,s,use_unix,rank;

r = (Q)asir_pop_one();

p = (Q)asir_pop_one();

if ( IS_CYGWIN || !p || NUM(p) ) {

port = QTOS(p);

sprintf(port_str,"%d",port);

use_unix = 0;

} else {

strcpy(port_str,BDY((STRING)p));

use_unix = 1;

}

s = try_bind_listen(use_unix,port_str);

s = try_accept(use_unix,s);

rank = QTOS((Q)r);

if ( register_102(s,rank,1) < 0 ) {

create_error(&err,serial,

"failed to bind or accept in ox_tcp_accept_102");

asir_push_one((Obj)err);

}

void asir_tcp_connect_102(unsigned int serial)

{

Obj obj;

Q r,p;

STRING h;

ERR err;

char *host;

char port_str[BUFSIZ];

int port,s,use_unix,rank;

r = (Q)asir_pop_one();

p = (Q)asir_pop_one();

h = (STRING)asir_pop_one();

if ( IS_CYGWIN || !p || NUM(p) ) {

port = QTOS(p);

sprintf(port_str,"%d",port);

use_unix = 0;

host = BDY((STRING)h);

} else {

strcpy(port_str,BDY((STRING)p));

use_unix = 1;

host = 0;

}

s = try_connect(use_unix,host,port_str);

rank = QTOS((Q)r);

if ( register_102(s,rank,1) < 0 ) {

create_error(&err,serial,

"failed to connect in ox_tcp_connect_102");

asir_push_one((Obj)err);

}

void asir_pushCMOtag(unsigned int serial)

{

Obj obj;

Line 486 int asir_executeString()

Line 669 int asir_executeString()

SNODE snode;

pointer val;

char *cmd;

#if PARI

#if defined(PARI)

recover(0);

if ( SETJMP(environnement) ) {

/* environement is defined in libpari.a */

# if !(PARI_VERSION_CODE > 131588 )

if ( setjmp(environnement) ) {

avma = top; recover(1);

resetenv("");

}

# endif

#endif

cmd = ((STRING)asir_pop_one())->body;

parse_strp = cmd;

Line 634 Obj asir_peek_one() {

Line 820 Obj asir_peek_one() {

}

void ox_asir_init(int argc,char **argv)

void ox_asir_init(int argc,char **argv,char *servername)

{

char ifname[BUFSIZ];

extern int GC_dont_gc;

extern int read_exec_file;

extern int do_asirrc;

extern int do_server_in_X11;

extern char displayname[];

char *getenv();

static ox_asir_initialized = 0;

FILE *ifp;

Line 650 void ox_asir_init(int argc,char **argv)

Line 837 void ox_asir_init(int argc,char **argv)

int tmp;

#endif

#if !defined(VISUAL) && !MPI

#if !defined(VISUAL) && !defined(MPI)

do_server_in_X11 = 1; /* XXX */

#endif

asir_save_handler();

#if PARI

#if defined(PARI)

risa_pari_init();

#endif

srandom((int)get_current_time());

Line 663 void ox_asir_init(int argc,char **argv)

Line 850 void ox_asir_init(int argc,char **argv)

env_init();

endian_init();

GC_init();

cppname_init();

process_args(--argc,++argv);

#if defined(__CYGWIN__)

if ( !displayname[0] )

do_server_in_X11 = 0; /* XXX */

#endif

output_init();

arf_init();

nglob_init();

Line 705 void ox_asir_init(int argc,char **argv)

Line 897 void ox_asir_init(int argc,char **argv)

input_init(0,"string");

/* XXX Windows compatibility */

ox_io_init();

create_my_mathcap("ox_asir");

create_my_mathcap(servername);

}

void ox_io_init() {

Line 893 int asir_ox_peek_cmo_size()

Line 1085 int asir_ox_peek_cmo_size()

Obj obj;

int len;

obj = asir_pop_one();

obj = asir_peek_one();

asir_push_one(obj);

if ( !valid_as_cmo(obj) ) {

fprintf(stderr,"The object at the stack top is invalid as a CMO.\n");

return 0;

Line 903 int asir_ox_peek_cmo_size()

Line 1094 int asir_ox_peek_cmo_size()

return len;

}

int asir_ox_peek_cmo_string_length()

{

Obj obj;

int len;

obj = asir_peek_one();

if ( !valid_as_cmo(obj) ) {

fprintf(stderr,"The object at the stack top is invalid as a CMO.\n");

return 0;

}

len = estimate_length(CO,obj);

return len+1;

}

* Initialization.

* byteorder=0 => native

Line 921 int asir_ox_init(int byteorder)

Line 1126 int asir_ox_init(int byteorder)

static ox_asir_initialized = 0;

FILE *ifp;

#if !defined(VISUAL) && !MPI

#if !defined(VISUAL) && !defined(MPI)

do_server_in_X11 = 0; /* XXX */

#endif

asir_save_handler();

#if PARI

#if defined(PARI)

risa_pari_init();

#endif

srandom((int)get_current_time());

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>