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.22 and 1.64

version 1.22, 2000/11/14 08:38:39

version 1.64, 2006/09/26 05:35:26

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.21 2000/11/07 06:35:38 noro Exp $

* $OpenXM: OpenXM_contrib2/asir2000/io/ox_asir.c,v 1.63 2006/06/21 09:46:06 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();

/* 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;

extern jmp_buf ox_env;

extern JMP_BUF ox_env;

extern MATHCAP my_mathcap;

extern int little_endian,ox_sock_id;

extern char LastError[];

extern LIST LastStackTrace;

int ox_sock_id;

int lib_ox_need_conv;

void create_error(ERR *,unsigned int ,char *);

void create_error(ERR *,unsigned int ,char *,LIST trace);

int asir_OperandStackSize;

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 96 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 109 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 134 void ox_main(int argc,char **argv) {

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

int id;

int cmd;

Obj obj;

USINT ui;

ERR err;

LIST list;

NODE n,n1;

unsigned int serial;

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) ) {

if ( SETJMP(ox_env) ) {

while ( NEXT(asir_infile) )

closecurrentinput();

resetpvs();

reset_engine();

reset_io();

ox_send_sync(0);

}

while ( 1 ) {

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

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

break;

if ( do_message )

fprintf(stderr," %s\n",name_of_cmd(cmd));

if ( ret = setjmp(env) ) {

if ( ret = SETJMP(main_env) ) {

if ( ret == 1 ) {

create_error(&err,serial,LastError);

create_error(&err,serial,LastError,LastStackTrace);

asir_push_one((Obj)err);

while ( NEXT(asir_infile) )

closecurrentinput();

resetpvs();

}

break;

}

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

Line 274 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 339 char *name_of_cmd(int cmd)

Line 371 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 387 void asir_popCMO(unsigned int serial)

Line 436 void asir_popCMO(unsigned int serial)

if ( valid_as_cmo(obj) )

ox_send_data(0,obj);

else {

create_error(&err,serial,"cannot convert to CMO object");

create_error(&err,serial,"cannot convert to CMO object",0);

ox_send_data(0,err);

asir_push_one(obj);

}

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",0);

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",0);

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",0);

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",0);

asir_push_one((Obj)err);

}

void asir_pushCMOtag(unsigned int serial)

{

Obj obj;

Line 405 void asir_pushCMOtag(unsigned int serial)

Line 592 void asir_pushCMOtag(unsigned int serial)

MKUSINT(ui,tag);

asir_push_one((Obj)ui);

} else {

create_error(&err,serial,"cannot convert to CMO object");

create_error(&err,serial,"cannot convert to CMO object",0);

asir_push_one((Obj)err);

}

void print_to_wfep(Obj obj)

{

asir_push_one(obj);

asir_popString();

}

void asir_popString()

{

Obj val;

char *buf,*obuf;

char *buf;

int l;

STRING str;

val = asir_pop_one();

if ( !val )

obuf = 0;

buf = "0";

else {

l = estimate_length(CO,val);

buf = (char *)ALLOCA(l+1);

soutput_init(buf);

sprintexpr(CO,val);

l = strlen(buf);

obuf = (char *)MALLOC(l+1);

strcpy(obuf,buf);

}

MKSTR(str,obuf);

MKSTR(str,buf);

ox_send_data(0,str);

}

Line 455 void asir_setName(unsigned int serial)

Line 645 void asir_setName(unsigned int serial)

parse_strp = (char *)ALLOCA(n);

sprintf(parse_strp,"%s%s",name,dummy);

if ( mainparse(&snode) ) {

create_error(&err,serial,"cannot set to variable");

create_error(&err,serial,"cannot set to variable",0);

asir_push_one((Obj)err);

} else {

FA1((FNODE)FA0(snode)) = (pointer)mkfnode(1,I_FORMULA,asir_pop_one());

Line 477 void asir_evalName(unsigned int serial)

Line 667 void asir_evalName(unsigned int serial)

parse_strp = (char *)ALLOCA(n);

sprintf(parse_strp,"%s;",name);

if ( mainparse(&snode) ) {

create_error(&err,serial,"no such variable");

create_error(&err,serial,"no such variable",0);

val = (pointer)err;

} else

val = evalstat(snode);

asir_push_one(val);

}

char *augment_backslash(char *s)

{

char *p,*r;

int i;

for ( i = 0, p = s; *p; p++, i++ ) if ( *p == '\\' ) i++;

r = (char *)MALLOC_ATOMIC((i+1)*sizeof(char));

for ( i = 0, p = s; *p; p++, i++ ) {

if ( *p == '\\' ) r[i++] = '\\';

r[i] = *p;

}

return r;

}

int asir_executeString()

{

SNODE snode;

pointer val;

char *cmd;

#if PARI

#if defined(PARI)

recover(0);

/* 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;

/* XXX : probably this is useless */

#if 0

parse_strp = augment_backslash(cmd);

#else

parse_strp = cmd;

#endif

asir_infile->ln = 1;

if ( mainparse(&snode) ) {

return -1;

}

Line 522 static void asir_executeFunction(int serial)

Line 735 static void asir_executeFunction(int serial)

int argc;

FUNC f;

Obj result;

VL vl;

NODE n,n1;

STRING fname;

char *path;

USINT ui;

ERR err;

Obj arg;

static char buf[BUFSIZ];

Line 552 static void asir_executeFunction(int serial)

Line 763 static void asir_executeFunction(int serial)

if ( n )

NEXT(n1) = 0;

#if 0

if ( !strcmp(func,"load") ) {

fname = (STRING)BDY(n);

if ( OID(fname) == O_STR ) {

Line 566 static void asir_executeFunction(int serial)

Line 778 static void asir_executeFunction(int serial)

}

result = 0;

} else {

#endif

searchf(noargsysf,func,&f);

if ( !f )

searchf(sysf,func,&f);

Line 579 static void asir_executeFunction(int serial)

Line 792 static void asir_executeFunction(int serial)

} else {

result = (Obj)bevalf(f,n);

}

#if 0

}

#endif

asir_push_one(result);

return;

error:

create_error(&err,serial,buf);

create_error(&err,serial,buf,0);

result = (Obj)err;

asir_push_one(result);

}

Line 639 Obj asir_peek_one() {

Line 854 Obj asir_peek_one() {

}

void ox_asir_init(int argc,char **argv)

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

{

int tmp;

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;

char *homedir;

char *ptr;

int do_server_sav;

#if !defined(VISUAL)

int tmp;

#endif

#if !defined(VISUAL) && !MPI

GC_init();

#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());

#if defined(THINK_C)

param_init();

#endif

rtime_init();

env_init();

endian_init();

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

cppname_init();

/* check_key(); */

#endif

GC_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 693 void ox_asir_init(int argc,char **argv)

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

if ( ptr = getenv("ASIR_CONFIG") )

strcpy(ifname,ptr);

else {

#if defined(THINK_C)

sprintf(ifname,"asirrc");

#else

homedir = getenv("HOME");

if ( !homedir ) {

char rootname[BUFSIZ];

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

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

homedir = rootname;

}

sprintf(ifname,"%s/.asirrc",homedir);

#endif

}

/* the bottom of the input stack */

input_init(0,"string");

if ( do_asirrc && (ifp = fopen(ifname,"r")) ) {

input_init(ifp,ifname);

if ( !setjmp(env) ) {

read_exec_file = 1;

read_eval_loop();

read_exec_file = 0;

}

fclose(ifp);

do_server_sav = do_server_in_X11;

do_server_in_X11 = 0;

if ( !SETJMP(main_env) )

execasirfile(ifname);

do_server_in_X11 = do_server_sav;

}

input_init(0,"string");

#if !MPI

/* XXX Windows compatibility */

ox_io_init();

#endif

create_my_mathcap(servername);

create_my_mathcap("ox_asir");

}

void ox_io_init() {

unsigned char c,rc;

extern int I_am_server;

/* XXX : ssh forwards stdin to a remote host on PC Unix */

#if defined(linux)

#include <sys/param.h>

int i;

close(0);

for ( i = 5; i < NOFILE; i++ )

close(i);

#elif defined(__FreeBSD__)

#include <sys/resource.h>

int i;

struct rlimit rl;

getrlimit(RLIMIT_NOFILE,&rl);

close(0);

for ( i = 5; i < rl.rlim_cur; i++ )

close(i);

#endif

I_am_server = 1;

endian_init();

#if defined(VISUAL)

Line 737 void ox_io_init() {

Line 971 void ox_io_init() {

iofp[0].in = fdopen(3,"r");

iofp[0].out = fdopen(4,"w");

#if !defined(__CYGWIN__)

setbuffer(iofp[0].in,(char *)malloc(LBUFSIZ),LBUFSIZ);

setbuffer(iofp[0].out,(char *)malloc(LBUFSIZ),LBUFSIZ);

#endif

signal(SIGUSR1,ox_usr1_handler);

#endif

asir_OperandStackSize = BUFSIZ;

Line 777 void asir_ox_push_cmo(void *cmo)

Line 1013 void asir_ox_push_cmo(void *cmo)

* Pop an object from the stack and converts it

* int a binary encoded CMO.

* into a binary encoded CMO.

int asir_ox_pop_cmo(void *cmo, int limit)

Line 789 int asir_ox_pop_cmo(void *cmo, int limit)

Line 1025 int asir_ox_pop_cmo(void *cmo, int limit)

obj = asir_pop_one();

if ( !valid_as_cmo(obj) ) {

asir_push_one(obj);

create_error(&err,0,"The object at the stack top is invalid as a CMO.");

create_error(&err,0,"The object at the stack top is invalid as a CMO.",0);

obj = (Obj)err;

}

len = count_as_cmo(obj);

Line 801 int asir_ox_pop_cmo(void *cmo, int limit)

Line 1037 int asir_ox_pop_cmo(void *cmo, int limit)

return -1;

}

int asir_ox_pop_string(void *string, int limit)

{

Obj val;

int l;

val = asir_pop_one();

if ( !val ) {

if ( limit >= 2 ) {

sprintf(string,"0");

l = strlen(string);

} else

l = -1;

} else {

l = estimate_length(CO,val);

if ( l+1 <= limit ) {

soutput_init(string);

sprintexpr(CO,val);

l = strlen(string);

} else

l = -1;

}

return l;

}

* Executes an SM command.

Line 811 void asir_ox_push_cmd(int cmd)

Line 1071 void asir_ox_push_cmd(int cmd)

ERR err;

extern char LastError[];

if ( ret = setjmp(env) ) {

if ( ret = SETJMP(main_env) ) {

asir_reset_handler();

if ( ret == 1 ) {

create_error(&err,0,LastError); /* XXX */

create_error(&err,0,LastError,LastStackTrace); /* XXX */

asir_push_one((Obj)err);

}

} else {

Line 838 void asir_ox_execute_string(char *s)

Line 1098 void asir_ox_execute_string(char *s)

MKSTR(str,s);

asir_push_one((Obj)str);

if ( ret = setjmp(env) ) {

if ( ret = SETJMP(main_env) ) {

asir_reset_handler();

if ( ret == 1 ) {

create_error(&err,0,LastError); /* XXX */

create_error(&err,0,LastError,LastStackTrace); /* XXX */

asir_push_one((Obj)err);

}

} else {

Line 862 int asir_ox_peek_cmo_size()

Line 1122 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 872 int asir_ox_peek_cmo_size()

Line 1131 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 883 int asir_ox_init(int byteorder)

Line 1156 int asir_ox_init(int byteorder)

int tmp;

char ifname[BUFSIZ];

extern int GC_dont_gc;

extern int read_exec_file;

extern int do_asirrc;

extern int do_server_in_X11;

char *getenv();

static ox_asir_initialized = 0;

FILE *ifp;

#if !defined(VISUAL) && !MPI

GC_init();

#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());

#if defined(THINK_C)

param_init();

#endif

rtime_init();

env_init();

endian_init();

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

/* check_key(); */

#endif

GC_init();

/* process_args(argc,argv); */

output_init();

arf_init();

Line 926 int asir_ox_init(int byteorder)

Line 1192 int asir_ox_init(int byteorder)

#if defined(UINIT)

reg_sysf();

#endif

#if defined(THINK_C)

input_init(0,"string");

sprintf(ifname,"asirrc");

#else

sprintf(ifname,"%s/.asirrc",getenv("HOME"));

#endif

if ( do_asirrc && (ifp = fopen(ifname,"r")) ) {

input_init(ifp,ifname);

if ( !setjmp(env) ) {

read_exec_file = 1;

read_eval_loop();

read_exec_file = 0;

}

fclose(ifp);

if ( !SETJMP(main_env) )

execasirfile(ifname);

}

input_init(0,"string");

asir_OperandStackSize = BUFSIZ;

asir_OperandStack = (Obj *)CALLOC(asir_OperandStackSize,sizeof(Obj));

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