=================================================================== RCS file: /home/cvs/OpenXM/src/OpenMath/OMproxy.java,v retrieving revision 1.12 retrieving revision 1.25 diff -u -p -r1.12 -r1.25 --- OpenXM/src/OpenMath/OMproxy.java 1999/11/17 08:47:55 1.12 +++ OpenXM/src/OpenMath/OMproxy.java 2000/01/20 18:55:22 1.25 @@ -1,5 +1,5 @@ /** - * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.11 1999/11/16 13:16:22 tam Exp $ + * $OpenXM: OpenXM/src/OpenMath/OMproxy.java,v 1.24 2000/01/20 18:14:32 tam Exp $ */ import JP.ac.kobe_u.math.tam.OpenXM.*; @@ -9,8 +9,8 @@ import java.io.*; class OMproxy implements Runnable{ private OpenXM ox; private Stack stack = new Stack(); - private boolean debug = true; - final int version = 199911110; + protected boolean debug = false; + final int version = 200001190; public OMproxy(String host,int ControlPort,int DataPort) throws IOException{ ox = new OpenXM(this,host,ControlPort,DataPort); @@ -20,8 +20,8 @@ class OMproxy implements Runnable{ OM2OXM P = new OM2OXM(); debug("OMproxy started."); - try{ - while(true){ + while(true){ + try{ int ox_tag = ox.receiveOXtag(); switch(ox_tag){ @@ -34,13 +34,13 @@ class OMproxy implements Runnable{ debug("push: "+ stack.peek()); break; } + }catch(Throwable e){ + System.err.println(e.getMessage()); + e.printStackTrace(); + debug("error occured. stack was cleared."); } - }catch(java.io.IOException e){ - System.err.println(e.getMessage()); - e.printStackTrace(); } - - System.out.println("breaking..."); + //System.out.println("breaking..."); } /* @@ -57,11 +57,15 @@ class OMproxy implements Runnable{ */ private void SM_popCMO() throws java.io.IOException{ - if(stack.empty()){ - ox.send(new CMO_NULL()); - }else{ - debug("pushing CMO: "+ stack.peek()); - ox.send(stack.pop()); + try{ + if(stack.empty()){ + ox.send(new CMO_NULL()); + }else{ + debug("sending CMO: "+ stack.peek()); + ox.send(stack.pop()); + } + }catch(MathcapViolation e){ + stack.push(new CMO_STRING(e.getMessage())); } } @@ -113,13 +117,13 @@ class OMproxy implements Runnable{ CMO[] list = {new CMO_INT32(SM.SM_popCMO), new CMO_INT32(SM.SM_executeFunction), new CMO_INT32(SM.SM_mathcap), + new CMO_INT32(SM.SM_setMathCap), new CMO_INT32(SM.SM_control_kill), new CMO_INT32(SM.SM_control_reset_connection)}; mathcap[1] = new CMO_LIST(list); } { - CMO[] DataFormat = {new CMO_INT32(OpenXM.OX_DATA)}; CMO[] CMOFormat = {new CMO_INT32(CMO.CMO_NULL), new CMO_INT32(CMO.CMO_INT32), new CMO_INT32(CMO.CMO_STRING), @@ -129,14 +133,16 @@ class OMproxy implements Runnable{ new CMO_INT32(CMO.CMO_QQ), new CMO_INT32(CMO.CMO_ZERO), new CMO_INT32(CMO.CMO_DMS_GENERIC), - //new CMO_INT32(CMO.CMO_RECURSIVE_POLYNOMIAL), + new CMO_INT32(CMO.CMO_RECURSIVE_POLYNOMIAL), new CMO_INT32(CMO.CMO_DISTRIBUTED_POLYNOMIAL), - //new CMO_INT32(CMO.CMO_POLYNOMIAL_IN_ONE_VARIABLE), + new CMO_INT32(CMO.CMO_POLYNOMIAL_IN_ONE_VARIABLE), new CMO_INT32(CMO.CMO_BIGFLOAT), new CMO_INT32(CMO.CMO_INDETERMINATE), new CMO_INT32(CMO.CMO_TREE)}; - CMO[] list = {new CMO_LIST(DataFormat), - new CMO_LIST(CMOFormat)}; + CMO[] DataFormat1 = {new CMO_INT32(OpenXM.OX_DATA), + new CMO_LIST(CMOFormat)}; + CMO[] list = {new CMO_LIST(DataFormat1)}; + mathcap[2] = new CMO_LIST(list); } @@ -144,6 +150,15 @@ class OMproxy implements Runnable{ debug("push: "+ stack.peek()); } + private void SM_setMathCap() throws java.io.IOException{ + Object mathcap = stack.pop(); + + if(mathcap instanceof CMO_MATHCAP){ + stack.push(new CMO_ERROR2()); + } + ox.setMathCap((CMO_MATHCAP)mathcap); + } + private void StackMachine(SM mesg) throws java.io.IOException{ debug("receive: "+mesg); @@ -160,6 +175,10 @@ class OMproxy implements Runnable{ SM_mathcap(); break; + case SM.SM_setMathCap: + SM_setMathCap(); + break; + default: System.out.println("received "+ mesg); } @@ -220,6 +239,7 @@ class OMproxy implements Runnable{ ret += "\t -data port \t (default 1300)\n"; ret += "\t -control port \t (default 1200)\n"; ret += "\t -insecure \t this version ignore this option\n"; + ret += "\t -debug \t display debug messages\n"; return ret; } @@ -227,6 +247,7 @@ class OMproxy implements Runnable{ public static void main(String argv[]){ String host = "localhost"; int DataPort = 1300, ControlPort = 1200; + boolean debug = false; for(int i=0;i