OpenXM_contrib2/asir2000/io/ox.c - diff

Return to ox.c CVS log

Up to [local] / OpenXM_contrib2 / asir2000 / io

Diff for /OpenXM_contrib2/asir2000/io/ox.c between version 1.2 and 1.14

version 1.2, 2000/01/26 02:05:34

version 1.14, 2002/07/25 04:47:41

Line 1

/* $OpenXM: OpenXM_contrib2/asir2000/io/ox.c,v 1.1.1.1 1999/12/03 07:39:11 noro Exp $ */

* FUJITSU LABORATORIES LIMITED ("FLL") hereby grants you a limited,

* non-exclusive and royalty-free license to use, copy, modify and

* redistribute, solely for non-commercial and non-profit purposes, the

* computer program, "Risa/Asir" ("SOFTWARE"), subject to the terms and

* conditions of this Agreement. For the avoidance of doubt, you acquire

* only a limited right to use the SOFTWARE hereunder, and FLL or any

* third party developer retains all rights, including but not limited to

* copyrights, in and to the SOFTWARE.

* (1) FLL does not grant you a license in any way for commercial

* purposes. You may use the SOFTWARE only for non-commercial and

* non-profit purposes only, such as academic, research and internal

* business use.

* (2) The SOFTWARE is protected by the Copyright Law of Japan and

* international copyright treaties. If you make copies of the SOFTWARE,

* with or without modification, as permitted hereunder, you shall affix

* to all such copies of the SOFTWARE the above copyright notice.

* (3) An explicit reference to this SOFTWARE and its copyright owner

* shall be made on your publication or presentation in any form of the

* results obtained by use of the SOFTWARE.

* (4) In the event that you modify the SOFTWARE, you shall notify FLL by

* e-mail at risa-admin@sec.flab.fujitsu.co.jp of the detailed specification

* for such modification or the source code of the modified part of the

* SOFTWARE.

* THE SOFTWARE IS PROVIDED AS IS WITHOUT ANY WARRANTY OF ANY KIND. FLL

* MAKES ABSOLUTELY NO WARRANTIES, EXPRESSED, IMPLIED OR STATUTORY, AND

* EXPRESSLY DISCLAIMS ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS

* FOR A PARTICULAR PURPOSE OR NONINFRINGEMENT OF THIRD PARTIES'

* RIGHTS. NO FLL DEALER, AGENT, EMPLOYEES IS AUTHORIZED TO MAKE ANY

* MODIFICATIONS, EXTENSIONS, OR ADDITIONS TO THIS WARRANTY.

* UNDER NO CIRCUMSTANCES AND UNDER NO LEGAL THEORY, TORT, CONTRACT,

* OR OTHERWISE, SHALL FLL BE LIABLE TO YOU OR ANY OTHER PERSON FOR ANY

* DIRECT, INDIRECT, SPECIAL, INCIDENTAL, PUNITIVE OR CONSEQUENTIAL

* DAMAGES OF ANY CHARACTER, INCLUDING, WITHOUT LIMITATION, DAMAGES

* ARISING OUT OF OR RELATING TO THE SOFTWARE OR THIS AGREEMENT, DAMAGES

* FOR LOSS OF GOODWILL, WORK STOPPAGE, OR LOSS OF DATA, OR FOR ANY

* DAMAGES, EVEN IF FLL SHALL HAVE BEEN INFORMED OF THE POSSIBILITY OF

* SUCH DAMAGES, OR FOR ANY CLAIM BY ANY OTHER PARTY. EVEN IF A PART

* 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$

#include "ca.h"

#include "parse.h"

#include "signal.h"

#include "wsio.h"

#include "ox.h"

#define ISIZ sizeof(int)

void ox_flush_stream(),ox_write_int(),ox_write_cmo();

void ox_read_int(),ox_read_cmo();

void mclist_to_mc();

void ox_read_local();

extern Obj VOIDobj;

extern int ox_need_conv;

extern int ox_usr1_sent, ox_int_received, critical_when_signal;

int ox_usr1_sent, ox_int_received, critical_when_signal;

unsigned int ox_serial;

int ox_flushing;

int ox_batch;

int ox_check=1;

int ox_exchange_mathcap=1;

jmp_buf ox_env;

JMP_BUF ox_env;

MATHCAP my_mathcap;

Line 46 static struct mathcap my_mc;

Line 89 static struct mathcap my_mc;

static struct mathcap *remote_mc;

static int remote_mc_len;

void ox_resetenv(s)

void mclist_to_mc(LIST mclist,struct mathcap *mc);

char *s;

#if defined(VISUAL)

/* XXX : mainly used in engine2000/io.c, but declared here */

HANDLE hStreamNotify,hStreamNotify_Ack;

void cleanup_events()

{

/* ox_watch_stream may be waiting for hStreamNotify_Ack to be set */

ResetEvent(hStreamNotify);

SetEvent(hStreamNotify_Ack);

}

#endif

void ox_resetenv(char *s)

{

#if defined(VISUAL)

cleanup_events();

#endif

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

longjmp(ox_env,1);

LONGJMP(ox_env,1);

}

static int available_cmo[] = {

Line 61 static int available_cmo[] = {

Line 121 static int available_cmo[] = {

CMO_RING_BY_NAME, CMO_DISTRIBUTED_POLYNOMIAL,

CMO_RECURSIVE_POLYNOMIAL, CMO_UNIVARIATE_POLYNOMIAL,

CMO_INDETERMINATE,

CMO_TREE,

};

static int available_sm[] = {

SM_dupErrors, SM_getsp, SM_popSerializedLocalObject,

SM_popCMO, SM_popString, SM_setName,

SM_popCMO, SM_popString, SM_pushCMOtag, SM_setName,

SM_evalName, SM_executeStringByLocalParser,

SM_executeStringByLocalParserInBatchMode,

SM_executeFunction, SM_shutdown, SM_pops,

Line 93 void create_my_mathcap(char *system)

Line 154 void create_my_mathcap(char *system)

NODE n,n0;

int i,k;

STRING str;

LIST sname,smlist,oxlist,cmolist,asirlist,oxtag,oxasir,r;

LIST sname,smlist,oxlist,cmolist,asirlist,oxasir,r;

USINT tag,t,t1;

if ( my_mathcap )

Line 186 void store_remote_mathcap(int s,MATHCAP mc)

Line 247 void store_remote_mathcap(int s,MATHCAP mc)

void mclist_to_mc(LIST mclist,struct mathcap *mc)

{

int id,l,i,j;

int l,i,j;

NODE n,t,oxcmo,ox,cap;

NODE n,t,oxcmo,cap;

int *ptr;

Line 233 void mclist_to_mc(LIST mclist,struct mathcap *mc)

Line 294 void mclist_to_mc(LIST mclist,struct mathcap *mc)

}

int check_sm_by_mc(s,smtag)

int check_sm_by_mc(int s,unsigned int smtag)

int s;

unsigned int smtag;

{

struct mathcap *rmc;

int nsmcap,i;

Line 258 unsigned int smtag;

Line 317 unsigned int smtag;

return 1;

}

int check_by_mc(s,oxtag,cmotag)

int check_by_mc(int s,unsigned int oxtag,unsigned int cmotag)

int s;

unsigned int oxtag,cmotag;

{

struct mathcap *rmc;

int noxcap,ncap,i,j;

Line 298 void begin_critical() {

Line 355 void begin_critical() {

void end_critical() {

critical_when_signal = 0;

if ( ox_usr1_sent ) {

ox_usr1_sent = 0; ox_usr1_handler();

ox_usr1_sent = 0;

#if !defined(VISUAL)

ox_usr1_handler(SIGUSR1);

#else

ox_usr1_handler(0);

#endif

}

if ( ox_int_received ) {

ox_int_received = 0; int_handler(SIGINT);

}

void ox_usr1_handler(sig)

void ox_usr1_handler(int sig)

int sig;

{

extern jmp_buf env;

unsigned int cmd;

#if !defined(VISUAL)

signal(SIGUSR1,ox_usr1_handler);

#endif

Line 325 int sig;

Line 383 int sig;

void clear_readbuffer()

{

char c;

fd_set r,w,e;

struct timeval interval;

int n,sock;

#if defined(linux)

iofp[0].in->_IO_read_ptr = iofp[0].in->_IO_read_end;

#elif defined(__FreeBSD__)

Line 376 void wait_for_data(int s)

Line 429 void wait_for_data(int s)

#if defined(VISUAL)

sock = iofp[s].in->fildes;

FD_ZERO(&r);

FD_SET(sock,&r);

FD_SET((unsigned int)sock,&r);

select(0,&r,NULL,NULL,NULL);

#else

sock = fileno(iofp[s].in);

Line 390 void wait_for_data(int s)

Line 443 void wait_for_data(int s)

void ox_send_data(int s,pointer p)

{

if ( ox_check && !ox_check_cmo(s,(Obj)p) )

ERR err;

error("ox_send_data : Mathcap violation");

if ( ox_check && !ox_check_cmo(s,(Obj)p) ) {

create_error(&err,ox_serial,"ox_send_data : Mathcap violation");

p = (pointer)err;

}

begin_critical();

ox_write_int(s,OX_DATA);

ox_write_int(s,ox_serial++);

Line 427 void ox_send_local_data(int s,Obj p)

Line 484 void ox_send_local_data(int s,Obj p)

ox_write_int(s,OX_LOCAL_OBJECT_ASIR);

ox_write_int(s,ox_serial++);

ox_write_int(s,ASIR_OBJ);

saveobj(iofp[s].out,p);

saveobj((FILE *)iofp[s].out,p);

ox_flush_stream(s);

end_critical();

}

Line 438 void ox_send_local_ring(int s,VL vl)

Line 495 void ox_send_local_ring(int s,VL vl)

ox_write_int(s,OX_LOCAL_OBJECT_ASIR);

ox_write_int(s,ox_serial++);

ox_write_int(s,ASIR_VL);

savevl(iofp[s].out,vl);

savevl((FILE *)iofp[s].out,vl);

ox_flush_stream(s);

end_critical();

}

unsigned int ox_recv(int s, int *id, pointer *p)

unsigned int ox_recv(int s, int *id, Obj *p)

{

unsigned int cmd,serial;

USINT ui;

Line 456 unsigned int ox_recv(int s, int *id, pointer *p)

Line 513 unsigned int ox_recv(int s, int *id, pointer *p)

case OX_COMMAND:

ox_read_int(s,&cmd);

MKUSINT(ui,cmd);

*p = (pointer)ui;

*p = (Obj)ui;

break;

case OX_DATA:

ox_read_cmo(s,p);

Line 472 unsigned int ox_recv(int s, int *id, pointer *p)

Line 529 unsigned int ox_recv(int s, int *id, pointer *p)

return serial;

}

void ox_get_result(s,rp)

void ox_get_result(int s,Obj *rp)

int s;

Obj *rp;

{

int id;

Obj obj,r;

Line 483 Obj *rp;

Line 538 Obj *rp;

level = 0;

r = 0;

do {

ox_recv(s,&id,(pointer *)&obj);

ox_recv(s,&id,&obj);

if ( id == OX_COMMAND ) {

switch ( ((USINT)obj)->body ) {

case SM_beginBlock:

Line 501 Obj *rp;

Line 556 Obj *rp;

void ox_read_int(int s, int *n)

{

ox_need_conv = iofp[s].conv;

read_int(iofp[s].in,n);

read_int((FILE *)iofp[s].in,n);

}

void ox_read_cmo(int s, Obj *rp)

{

ox_need_conv = iofp[s].conv;

read_cmo(iofp[s].in,rp);

read_cmo((FILE *)iofp[s].in,rp);

}

void ox_read_local(int s, Obj *rp)

Line 515 void ox_read_local(int s, Obj *rp)

Line 570 void ox_read_local(int s, Obj *rp)

int id;

ox_need_conv = iofp[s].conv;

read_int(iofp[s].in,&id);

read_int((FILE *)iofp[s].in,&id);

switch ( id ) {

case ASIR_VL:

loadvl(iofp[s].in);

loadvl((FILE *)iofp[s].in);

*rp = VOIDobj;

break;

case ASIR_OBJ:

loadobj(iofp[s].in,rp);

loadobj((FILE *)iofp[s].in,rp);

break;

default:

error("ox_read_local : unsupported id");

Line 533 void ox_read_local(int s, Obj *rp)

Line 588 void ox_read_local(int s, Obj *rp)

void ox_write_int(int s, int n)

{

ox_need_conv = iofp[s].conv;

write_int(iofp[s].out,&n);

write_int((FILE *)iofp[s].out,&n);

}

void ox_write_cmo(int s, Obj obj)

{

ox_need_conv = iofp[s].conv;

write_cmo(iofp[s].out,obj);

write_cmo((FILE *)iofp[s].out,obj);

}

int ox_check_cmo(int s, Obj obj)

Line 550 int ox_check_cmo(int s, Obj obj)

Line 605 int ox_check_cmo(int s, Obj obj)

return 1;

switch ( OID(obj) ) {

case O_MATHCAP: case O_STR: case O_ERR: case O_USINT: case O_VOID:

case O_BYTEARRAY:

return 1;

case O_P:

if ( !check_by_mc(s,OX_DATA,CMO_RECURSIVE_POLYNOMIAL) )

Line 566 int ox_check_cmo(int s, Obj obj)

Line 622 int ox_check_cmo(int s, Obj obj)

case O_DP:

return ox_check_cmo_dp(s,(DP)obj);

case O_N:

if ( NID((Num)obj) == N_Q ) {

switch ( NID((Num)obj) ) {

if ( INT((Q)obj) )

case N_Q:

return check_by_mc(s,OX_DATA,CMO_ZZ);

if ( INT((Q)obj) )

else

return check_by_mc(s,OX_DATA,CMO_ZZ);

return check_by_mc(s,OX_DATA,CMO_QQ);

else

} else

return check_by_mc(s,OX_DATA,CMO_QQ);

return 0;

case N_R:

return 1;

default:

return 0;

}

break;

case O_LIST:

for ( m = BDY((LIST)obj); m; m = NEXT(m) )

if ( !ox_check_cmo(s,(BDY(m))) )

return 0;

return 1;

case O_QUOTE: /* XXX */

return 1;

default:

return 0;

}

Line 616 int ox_check_cmo_dp(int s, DP p)

Line 679 int ox_check_cmo_dp(int s, DP p)

return 1;

}

void ox_flush_stream(s)

void ox_flush_stream(int s)

int s;

{

if ( ox_batch )

return;

Line 630 int s;

Line 692 int s;

cflush(iofp[s].out);

else

#endif

fflush(iofp[s].out);

fflush((FILE *)iofp[s].out);

}

void ox_flush_stream_force(s)

void ox_flush_stream_force(int s)

int s;

{

#if defined(VISUAL)

if ( _fileno(&iofp[s].out->fp) < 0 )

Line 645 int s;

Line 706 int s;

cflush(iofp[s].out);

else

#endif

fflush(iofp[s].out);

fflush((FILE *)iofp[s].out);

}

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