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.62 and 1.72

version 1.62, 2006/02/25 06:33:31

version 1.72, 2014/05/09 19:35:51

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.61 2006/02/13 10:07:19 noro Exp $

* $OpenXM: OpenXM_contrib2/asir2000/io/ox_asir.c,v 1.71 2013/06/13 18:42:11 ohara Exp $

#include "ca.h"

#include "parse.h"

Line 55

#include "genpari.h"

#endif

char *find_asirrc();

void ox_usr1_handler();

int asir_ox_init();

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

static void asir_executeFunctionSync(int);

#if defined(MPI)

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

Line 121 void ox_mpi_master_init() {

Line 123 void ox_mpi_master_init() {

/* ordering information is not exchanged */

/* idx should be equal to i */

idx = get_iofp(i,0,0);

register_server(0,idx,idx);

register_server(0,idx,idx,-1);

}

Line 134 void ox_mpi_slave_init() {

Line 136 void ox_mpi_slave_init() {

/* ordering information is not exchanged */

/* idx should be equal to i */

idx = get_iofp(i,0,0);

register_server(0,idx,idx);

register_server(0,idx,idx,-1);

}

asir_OperandStackSize = BUFSIZ;

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

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

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

asir_push_one((Obj)err);

while ( NEXT(asir_infile) )

closecurrentinput();

resetpvs();

}

break;

}

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

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

case SM_executeFunction:

asir_executeFunction(serial);

break;

case SM_executeFunctionSync:

asir_executeFunctionSync(serial);

break;

case SM_shutdown:

asir_terminate(2);

break;

Line 387 char *name_of_cmd(int cmd)

Line 393 char *name_of_cmd(int cmd)

case SM_reduce_102:

return "SM_reduce_102";

break;

case SM_executeFunctionSync:

return "SM_executeFunctionSync";

break;

default:

return "Unknown cmd";

break;

Line 596 void asir_pushCMOtag(unsigned int serial)

Line 605 void asir_pushCMOtag(unsigned int serial)

}

void print_to_wfep(Obj obj)

{

asir_push_one(obj);

asir_popString();

}

extern int wfep_mode;

void asir_popString()

{

Obj val;

Line 606 void asir_popString()

Line 623 void asir_popString()

val = asir_pop_one();

if ( !val )

buf = "0";

else {

else if ( wfep_mode && OID(val) == O_ERR ) {

/* XXX : for wfep */

ox_send_data(0,val); return;

} else {

l = estimate_length(CO,val);

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

soutput_init(buf);

Line 627 void asir_pops()

Line 647 void asir_pops()

void asir_setName(unsigned int serial)

{

char *name;

int l,n;

size_t l,n;

char *dummy = "=0;";

SNODE snode;

ERR err;

Line 649 void asir_setName(unsigned int serial)

Line 669 void asir_setName(unsigned int serial)

void asir_evalName(unsigned int serial)

{

char *name;

int l,n;

size_t l,n;

SNODE snode;

ERR err;

pointer val;

Line 774 static void asir_executeFunction(int serial)

Line 794 static void asir_executeFunction(int serial)

#endif

searchf(noargsysf,func,&f);

if ( !f )

searchf(sysf,func,&f);

gen_searchf_searchonly(func,&f);

if ( !f )

searchf(ubinf,func,&f);

if ( !f )

searchf(usrf,func,&f);

if ( !f ) {

sprintf(buf,"executeFunction : the function %s not found",func);

goto error;

Line 788 static void asir_executeFunction(int serial)

Line 804 static void asir_executeFunction(int serial)

#if 0

}

#endif

printf("executeFunction done\n");

asir_push_one(result);

return;

Line 797 error:

Line 814 error:

asir_push_one(result);

}

static void asir_executeFunctionSync(int serial)

{

char *func;

int argc,i;

FUNC f;

Obj result=0;

NODE n,n1;

STRING fname;

char *path;

ERR err;

Obj arg;

static char buf[BUFSIZ];

arg = asir_pop_one();

if ( !arg || OID(arg) != O_STR ) {

sprintf(buf,"executeFunction : invalid function name");

goto error;

} else

func = ((STRING)arg)->body;

arg = asir_pop_one();

if ( !arg || OID(arg) != O_USINT ) {

sprintf(buf,"executeFunction : invalid argc");

goto error;

} else

argc = (int)(((USINT)arg)->body);

for ( n = 0; argc; argc-- ) {

NEXTNODE(n,n1);

BDY(n1) = (pointer)asir_pop_one();

}

if ( n )

NEXT(n1) = 0;

ox_send_data(0,ONE);

#if 0

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

fname = (STRING)BDY(n);

if ( OID(fname) == O_STR ) {

searchasirpath(BDY(fname),&path);

if ( path ) {

if ( do_message )

fprintf(stderr,"loading %s\n",path);

execasirfile(path);

} else

if ( do_message )

fprintf(stderr,"load : %s not found in the search path\n",BDY(fname));

}

result = 0;

} else {

#endif

searchf(noargsysf,func,&f);

if ( !f )

gen_searchf_searchonly(func,&f);

if ( !f ) {

sprintf(buf,"executeFunction : the function %s not found",func);

goto error;

} else {

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

}

#if 0

}

#endif

printf("executeFunctionSync done\n");

ox_send_data(0,result);

return;

error:

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

result = (Obj)err;

ox_send_data(0,result);

}

void asir_end_flush()

{

ox_flushing = 0;

Line 849 Obj asir_peek_one() {

Line 940 Obj asir_peek_one() {

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

{

char ifname[BUFSIZ];

char *ifname;

extern int GC_dont_gc;

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;

Line 893 void ox_asir_init(int argc,char **argv,char *servernam

Line 980 void ox_asir_init(int argc,char **argv,char *servernam

pf_init();

sysf_init();

parif_init();

order_init();

#if defined(VISUAL)

init_socket();

#endif

#if defined(UINIT)

reg_sysf();

#endif

/* if ASIR_CONFIG is set, execute it; else execute .asirrc */

if ( ptr = getenv("ASIR_CONFIG") )

strcpy(ifname,ptr);

else {

homedir = getenv("HOME");

if ( !homedir ) {

char rootname[BUFSIZ];

get_rootdir(rootname,sizeof(rootname));

homedir = rootname;

}

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

}

/* the bottom of the input stack */

input_init(0,"string");

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

if ( do_asirrc && (ifname = find_asirrc()) ) {

fclose(ifp);

do_server_sav = do_server_in_X11;

do_server_in_X11 = 0;

if ( !SETJMP(main_env) )

Line 982 void ox_io_init() {

Line 1055 void ox_io_init() {

read_char(iofp[0].in,&rc);

iofp[0].conv = c == rc ? 0 : 1;

/* XXX; for raw I/O */

register_server(0,0,0);

register_server(0,0,0,-1);

}

#if !defined(VISUAL)

Line 1147 int asir_ox_peek_cmo_string_length()

Line 1220 int asir_ox_peek_cmo_string_length()

int asir_ox_init(int byteorder)

{

int tmp;

char ifname[BUFSIZ];

char *ifname;

extern int GC_dont_gc;

extern int do_asirrc;

extern int do_server_in_X11;

char *getenv();

static ox_asir_initialized = 0;

FILE *ifp;

GC_init();

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

Line 1186 int asir_ox_init(int byteorder)

Line 1257 int asir_ox_init(int byteorder)

reg_sysf();

#endif

input_init(0,"string");

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

if ( do_asirrc && (ifname = find_asirrc()) ) {

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

fclose(ifp);

if ( !SETJMP(main_env) )

execasirfile(ifname);

}

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