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.63 and 1.75

version 1.63, 2006/06/21 09:46:06

version 1.75, 2015/08/08 14:19:42

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.62 2006/02/25 06:33:31 noro Exp $

* $OpenXM: OpenXM_contrib2/asir2000/io/ox_asir.c,v 1.74 2015/08/06 10:01:52 fujimoto Exp $

#include "ca.h"

#include "parse.h"

#include "signal.h"

#include "ox.h"

#include "version.h"

#if defined(PARI)

#include "genpari.h"

#endif

char *find_asirrc();

void ox_usr1_handler();

int asir_ox_init();

/* environement is defined in libpari.a */

#if 0

# if !( PARI_VERSION_CODE > 131588)

extern jmp_buf environnement;

# endif

#endif

extern int myrank_102,nserver_102;

extern int do_message;

Line 108 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 122 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 135 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 165 void ox_main(int argc,char **argv) {

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

extern int recv_intr;

serial = ox_recv(0,&id,&obj);

#if defined(VISUAL)

#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)

if ( recv_intr ) {

if ( recv_intr == 1 ) {

recv_intr = 0;

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

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

if ( do_message )

fprintf(stderr,"\n");

}

#if defined(__MINGW32__) || defined(__MINGW64__)

fflush(stderr);

#endif

}

static void asir_do_cmd(int cmd,unsigned int serial)

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

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

Line 395 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 597 void asir_pushCMOtag(unsigned int serial)

Line 607 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 607 void asir_popString()

Line 625 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 628 void asir_pops()

Line 649 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 650 void asir_setName(unsigned int serial)

Line 671 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 687 int asir_executeString()

Line 708 int asir_executeString()

SNODE snode;

pointer val;

char *cmd;

#if 0

#if defined(PARI)

recover(0);

/* environement is defined in libpari.a */

Line 697 int asir_executeString()

Line 719 int asir_executeString()

}

# endif

#endif

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

/* XXX : probably this is useless */

#if 0

Line 775 static void asir_executeFunction(int serial)

Line 798 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 789 static void asir_executeFunction(int serial)

Line 808 static void asir_executeFunction(int serial)

#if 0

}

#endif

printf("executeFunction done\n");

asir_push_one(result);

return;

Line 798 error:

Line 818 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 850 Obj asir_peek_one() {

Line 944 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)

#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)

int tmp;

#endif

GC_init();

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

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

do_server_in_X11 = 1; /* XXX */

#endif

asir_save_handler();

#if 0

#if defined(PARI)

risa_pari_init();

#endif

srandom((int)get_current_time());

rtime_init();

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

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

pf_init();

sysf_init();

parif_init();

#if defined(VISUAL)

order_init();

#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)

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

Line 1034 void ox_io_init() {

I_am_server = 1;

endian_init();

#if defined(VISUAL)

#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)

if ( !ox_sock_id )

exit(0);

iofp[0].in = WSIO_open(ox_sock_id,"r");

Line 983 void ox_io_init() {

Line 1061 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)

#if !defined(VISUAL) && !defined(__MINGW32__) && !defined(__MINGW64__)

* Library mode functions

Line 1148 int asir_ox_peek_cmo_string_length()

Line 1226 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)

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

do_server_in_X11 = 0; /* XXX */

#endif

asir_save_handler();

#if 0

#if defined(PARI)

risa_pari_init();

#endif

srandom((int)get_current_time());

rtime_init();

Line 1180 int asir_ox_init(int byteorder)

Line 1258 int asir_ox_init(int byteorder)

pf_init();

sysf_init();

parif_init();

#if defined(VISUAL)

#if defined(VISUAL) || defined(__MINGW32__) || defined(__MINGW64__)

init_socket();

#endif

#if defined(UINIT)

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>