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.21 and 1.52

version 1.21, 2000/11/07 06:35:38

version 1.52, 2004/02/26 06:37:09

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.20 2000/10/06 06:05:22 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 "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;

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

Line 144 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();

ox_send_sync(0);

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

Line 181 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);

asir_push_one((Obj)err);

Line 260 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 339 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 393 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 419 void asir_popString()

Line 599 void asir_popString()

val = asir_pop_one();

if ( !val )

obuf = 0;

obuf = "0";

else {

l = estimate_length(CO,val);

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

soutput_init(buf);

sprintexpr(CO,val);

#if 0

l = strlen(buf);

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

strcpy(obuf,buf);

#endif

}

MKSTR(str,obuf);

MKSTR(str,buf);

ox_send_data(0,str);

}

Line 489 int asir_executeString()

Line 671 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;

parse_strp = cmd;

Line 522 static void asir_executeFunction(int serial)

Line 707 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 639 Obj asir_peek_one() {

Line 822 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;

#if !defined(VISUAL)

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

#if defined(THINK_C)

param_init();

#endif

StackBottom = &tmp + 1; /* XXX */

rtime_init();

env_init();

endian_init();

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

/* check_key(); */

#endif

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

Line 878 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 705 void ox_asir_init(int argc,char **argv)

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

homedir = rootname;

}

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

#endif

}

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

input_init(ifp,ifname);

if ( !setjmp(env) ) {

if ( !SETJMP(main_env) ) {

read_exec_file = 1;

read_eval_loop();

read_exec_file = 0;

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

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

fclose(ifp);

}

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 738 void ox_io_init() {

Line 936 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 778 void asir_ox_push_cmo(void *cmo)

Line 978 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 802 int asir_ox_pop_cmo(void *cmo, int limit)

Line 1002 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 812 void asir_ox_push_cmd(int cmd)

Line 1036 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 */

Line 839 void asir_ox_execute_string(char *s)

Line 1063 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 */

Line 863 int asir_ox_peek_cmo_size()

Line 1087 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 873 int asir_ox_peek_cmo_size()

Line 1096 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 891 int asir_ox_init(int byteorder)

Line 1128 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());

#if defined(THINK_C)

param_init();

#endif

StackBottom = &tmp + 1; /* XXX */

rtime_init();

env_init();

endian_init();

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

/* check_key(); */

#endif

GC_init();

/* process_args(argc,argv); */

output_init();

Line 928 int asir_ox_init(int byteorder)

Line 1158 int asir_ox_init(int byteorder)

#if defined(UINIT)

reg_sysf();

#endif

#if defined(THINK_C)

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

if ( !SETJMP(main_env) ) {

read_exec_file = 1;

read_eval_loop();

read_exec_file = 0;

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